块处理模式下的Spring批处理事务回滚
共有1个答案
这是正常的，因为在重试期间会缓存项。如果您想禁用它，您需要设置FaultRevolantStepBuilder#ProcessorNonTransactional（）标志。
也就是说，这里有两个重要的细节要提：
- 应正确实现
equals和hashcode，因为这些方法用于在重试中标识项。 - 在容错步骤中，
ItemProcessor实现应该是幂等的，如参考文档 的容错部分所述
-
我在表中总共有8条记录，其中6条在spring批处理调用read时可以使用jpareader。现在我将页面大小和块大小设置为1以进行测试。期望作业运行时，它应该进行6次读取调用，然后它应该逐个处理，逐个写入。但实际上发生的是，它只是调用read 4次（从日志中我可以看到这样读取页面0...1）并处理4个，其中一个由于不匹配写入标准而被过滤掉，然后它只是更新了3个记录，作业标记为成功完成。
-
在happy path场景中，我有一个spring批处理工作，但现在我将重点放在错误处理上。 但是，在另一个测试中，我想证明一个不可预见的数据库错误会导致作业失败。为此，我创建了一个触发器，该触发器会导致对要插入的表的插入失败。 这似乎起作用了，在writer执行之后，在事务提交期间抛出异常，并且我得到以下日志消息： 这似乎也是预期的行为。问题是，这并不能阻止工作。该步骤退出到SimplyRetr
-
我使用FlatFileItemReader创建了一个spring批处理作业，它从一个分隔文件中读取数据，然后使用JdbcBatchItemWriter写入DB。我的setp配置如下所示。 上面的配置是为每100行打开单独的事务，因此，如果在完成tasklet（步骤1）之前发生故障，则我无法恢复之前提交的行。有没有办法在一个事务中运行整个tasklet？。 另外：我使用MapJobRepositor
-
如果我正在读写本地文件，那么对远程数据库服务器的更新相对昂贵。如果增加[chunk-size]，内存使用量就会上升。 提交频率对编写本地文件并没有太大的影响，所以对我来说，元数据更新才是一个问题。该步骤是可重新启动的，因此从技术上讲，我不需要记录中间提交计数。 对于JobRepository，我可以只使用map或内存数据库，但我需要其他信息，例如持久化的开始/结束时间，而且这个问题只涉及一个步骤。
-
问题内容： 我的问题与春季批次和交易有关。 假设我为我的步骤之一选择了 50 的 提交间隔 。 还要假设我总共有1000条记录，其中一条记录将导致itemWriter失败，从而导致整个块的回滚（在我的示例中为50条记录）。 确保作业完成（并忽略有问题的块）后将49个有效记录写入数据库的状态有哪些？ 问题答案： 经过研究，我得出以下结论： 如果项目编写者未能提交一个块（此处为50个项目）从而导致回滚
-
我有以下工作要处理在一定的时间间隔或特别的基础上。 作业中的步骤如下： 我也想要用户界面，在那里我可以触发一个特别的基础上的工作，而且我应该能够提供参数从用户界面。 我想用Spring batch来完成这个任务，但它更多的是用于读->处理->写之类的工作。这里，在第一步中，我正在生成由第二步读取的数据。我不确定我是否还可以使用Spring batch来实现这个，或者有更好的方法来实现这个。