我有一个自定义的阅读器定义如下：

@Component
@StepScope
public class CustomItemReader implements ItemReader<String> {

  @Autowired
  BookingInfoRepository bookingInfoRepository;

  private List<String> bookingIds;

  @Override
  public String read() {
    if(Objects.isNull(bookingIds)){
      bookingIds = bookingInfoRepository.findDistinctId();
    }
    if (! bookingIds.isEmpty()) {
      return bookingIds.remove(0);
    }
    return null;
  }
}

因此，我使用从数据库返回的id设置变量bookingIds。
然后，我有一些自定义处理器，它将与数据库对话并返回对象：

@Component
@StepScope
@Slf4j
public class CorrectionProcessor implements ItemProcessor<String, List<BookingInfo>> {

  @Autowired
  BookingInfoRepository bookingInfoRepository;

  @Override
  public List<BookingInfo> process(String bookingId) {
     
     List<BookingInfo> bookingInfoList = bookingInfoRepository.findById(bookingId);

     //do some processing, modify the objects in the list.

     return bookingInfoList;

  }

}

然后，我有一个自定义作家，如下所示：

@Component
@StepScope
public class CustomItemWriter implements ItemWriter<List<BookingInfo>> {

  @Autowired
  BookingInfoRepository bookingInfoRepository;

  @Override
  public void write(Chunk<? extends List<BookingInfo>> chunk) throws Exception {
    for(List<BookingInfo> bookingInfo: chunk){
      bookingInfoRepository(bookingInfo);
    }
  }
}

这是我的用例->

1. Reader期望在主数据之外操作，该主数据是bookingId的列表。
2. Reader将这个单独的bookingId传递给processor，Processor形成一个要返回给writer的自定义对象列表。请注意，处理器形成了list对象，而不是单个对象。
   1.作家需要采取的所有值列表中，并将它们保存到数据库。
   1.过程继续，直到所有bookingIds都被处理。
   我知道这可能不是利用 Spring 批次的理想方式。Reader到Processor的步骤看起来可能很奇怪，但我需要坚持使用这个实现。我觉得我在上面提到的一个或多个步骤中做错了什么。我看到chunks每次都附加了数据。因此，相同的数据被多次插入。我如何将新添加的块写入数据库，而不是一次又一次地添加所有内容？我的其他配置是否正确？