Spring批处理-在读卡器和处理器之间传递值

Question

我有一个要求，我需要从xls（其中存在一个名为netCreditAmount的列）中读取值并将值保存在数据库中。要求是从所有行中添加netCreditAmount的值，然后在数据库中仅为xls中的第一行设置此总和，其余行插入相应的netCreditAmounts。我应该如何在Spring Batch中进行实施。普通的阅读器、处理器和写入器工作正常，但我应该在哪里插入这个实现？谢谢！

Answer 1

那么问题是什么呢？您需要设置批处理作业步骤以使用读取器-处理器-写入器。

阅读器有界面：

public interface ItemReader<T> {    
  T read();
}

处理器：

public interface ItemProcessor<I, O> {
  O process(I item);
}

所以你需要由阅读器提供相同的类型-T；并将其传递给处理器-I

stepBuilderFactory.get("myCoolStep")
            .<I, O>chunk(1)
            .reader(myReader)
            .processor(myProcessor)
            .writer(myWriter)
            .build();

Answer 2

哟可以通过添加额外的任务来解决这个问题。工作流程可以如下所示

@Bean
    public Job myJob(JobBuilderFactory jobs) throws Exception {
        return jobs.get("myJob")
                .start(step1LoadAllData())  // This step will load all data in database excpet first row in xls
                .next(updateNetCreditAmountStep()) //// This step will be a tasklet. and will update total sum in first row. You can use database sql for sum for this 
                .build();           

    }

Tasklet如下所示

@Component
public class updateNetCreditAmountTasklet implements Tasklet {  

    @Override
    public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext)
            throws Exception {
            Double sum = jdbctemplate.queryForObject("select sum(netCreditAmount) from XYZ", Double.class);
         // nouw update this some in database for first row 
        return null;
    }

}