Spring Batch中我的业务逻辑应该在哪里？

Question

我有一个Spring批处理应用程序。我的Spring批处理应用程序由两个步骤组成。

1. 提取csv数据，添加到记录tbl
2. 提取记录tbl行，根据数据验证解析到Food tbl。

步骤2使用微线程完成
我需要处理记录行tbl，无论是否验证，当前日期时间都会添加回记录行
a.验证失败，DateTime错误代码也将添加到记录行中
b.通过验证，日期时间添加到记录行中。Row也将添加到食品tbl中。

在步骤2中，我有一个databaseReader和一个databaseWriter。我在哪里实现我的业务逻辑来检查验证是否通过/失败？它将从我的服务类中调用。

我想我的databaseWriter可以从我的服务类中调用添加/更新/删除方法。如果有任何错误，我的databaseWriter会捕获它。根据服务类引发的错误，databaseWriter将决定要解析回记录行的错误代码DateTime。

你的想法是什么？这是一个好的实现吗？

Answer 1

我想我的databaseWriter可以从我的服务类中调用添加/更新/删除方法。如果有任何错误，我的databaseWriter会捕获它。根据服务类引发的错误，databaseWriter将决定要解析回记录行的错误代码DateTime。

按其名称命名的ItemWriter应该只更新您的存储数据（例如数据库）。您可以使用项目读取器-处理器-写入器构建基于块的作业，并将处理器作为业务逻辑，您可以在其中过滤将在写入器上写入的记录基于您的验证。

https://docs-stage.spring.io/spring-batch/docs/current/reference/html/processor.html#filteringRecords

此外，块基作业应处理分区中的数据拆分，以防发生异常，只有一块数据会受到影响。

Answer 2

第2步是使用tasklet完成的。

在步骤2中，我有一个databaseReader和一个databaseWriter。我在哪里实现我的业务逻辑来检查验证是否通过/失败？

我不知道您是在简单的tasklet还是面向块的tasklet中使用这些读写器。但我将使用面向块的tasklet实现步骤2，并使用项目处理器进行验证逻辑。数据验证是项目处理器的典型用例：https://docs.spring.io/spring-batch/docs/4.3.x/reference/html/processor.html#validatingInput.您可以决定拒绝项目或在处理器中过滤项目。