使用选择查询从数据库中读取的批处理 Tasklet答案

【问题标题】：Batch Tasklet to read from database with select query使用选择查询从数据库中读取的批处理 Tasklet
【发布时间】：2021-05-20 17:17:51
【问题描述】：

如何创建一个 tasklet 类以从 DB 进行自定义选择查询并将数据传递给下一个 tasklet？我必须使用 tasklet（没有 jdbcReader 或任何阅读器）

代码示例：

public class Taskletreader implements Tasklet, StepExecutionListener{
    
    private final Logger logger = LoggerFactory.getLogger(Taskletreader.class);
    @Autowired
    private DataSource dataSource;
    private List<FichierEclate> FichierEclates;
private String query="select * from FicherEclate where .......some conditions...."

    @Override
    public void beforeStep(StepExecution stepExecution) {
        FichierEclates = new ArrayList<FichierEclate>();
       logger.debug("Reader initialized.");
    }

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
        new JdbcTemplate(dataSource)
        .execute(query);
        return RepeatStatus.FINISHED;
    }

     @Override
        public ExitStatus afterStep(StepExecution stepExecution) {
          //  fu.closeReader();
            stepExecution
              .getJobExecution()
              .getExecutionContext()
              .put("FichierEclates", this.FichierEclates);
            logger.debug("Reader ended.");
            return ExitStatus.COMPLETED;
        }

}

无法理解 select 的结果在哪里以及如何将其传递给下一个 tasklet 进行处理？

【问题讨论】：

标签： java spring spring-batch tasklet

【解决方案1】：

不明白select的结果在哪里

如果要消费查询的结果，可以在JdbcTemplate上使用query方法：

List<FichierEclate> fichierEclates = jdbcTemplate.query(query, new BeanPropertyRowMapper<>(FichierEclate.class));

此方法接受一个RowMapper，它将数据库中的每一行映射到您的域对象的一个实例。该示例使用BeanPropertyRowMapper，但如果需要，您可以提供自定义映射器。

如何将其传递给下一个 tasklet 进行处理？

您可以像以前一样使用执行上下文。但是，您不应该传递整个项目列表。执行上下文是持久的，不建议在这样的步骤之间传递大量数据。项目 ID 列表可能很好，但整个项目对象的列表不是一个好主意。有关详细信息，请参阅参考文档的Passing Data to Future Steps 部分。

也就是说，我真的建议为此使用面向块的 tasklet。我知道你说的是I have to use tasklet (no jdbcReader or any reader)，但我不明白这个限制。

【讨论】：