0

如何创建一个 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 进行处理？

4

1 回答 1

0

不明白选择的结果在哪里

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

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

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

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

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

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

于 2021-05-21T09:30:26.290 回答