我有一个简单的csv文件,我正在读取1000块,插入数据库。现在,如果我想检查该行是否存在于db中,是否等于insert前的输入,如果存在且行等于-ignore,则使用ItemProcessor。实现后,意识到jdbc调用太慢(120 is avg),希望在调用db和检查输入之前对is进行批处理。在这个阶段,ItemReader一次传递给ItemProcessor一个项目。现在,我正在尝试一次将1000个项传递给<e
我正在编写一个spring批处理作业,在我的一个步骤中,我为处理器编写了以下代码:public class SubscriberProcessor implements ItemProcessor我发现的一个解决方案是更改ItemProcessor和ItemWriter,以处理List<Account>类型而不是Account,但这有两个缺点:
ItemReader @StepScope
public FlatFileItemReader reader(@Value("#{jobParameters['inputFileName批处理为每个记录调用适当的读取器。问题是,当涉及到项目处理器时,我想使用与java.lang.ClassCastException相同的方法,因为spring批处理尝试将读取器<