Spring批处理Java配置提交间隔

Question

如何使用Java配置实现这一点？

Answer 1

这种方法打破了Spring批处理的设计方法。

spring批处理背后的整个思想是，提交每个块，并且spring-batch跟踪哪些记录已经被处理，以便提供重新启动、跳过和失败处理策略。

如果您真的需要一个贯穿整个过程的事务，为什么要使用spring-batch呢？我的意思是，您可以直接使用读取器和写入器，并在您自己的简单循环中使用它们。像这样的东西。

transaction.open();
while (not all processed) {
  List currentChunk = new List..;
  for(int i<0;i<chunkSize;i++) {
      Object readItem = jdbcCursorItemReader.read();
      if (readItem == null) {
         break;
      }
      Object processedItem = processor.process(readItem);
      if (processedItem != null) {
          currentChunk.add(processedItem);
      }
  }

  yourWriter.write(currentChunk);
}
transaction.commit();