自定义SpringBatch ItemReader，它使用自定义查询读取JPA存储库

sd2nnvve 于 2022-11-21 发布在 Spring

关注(0)|答案(1)|浏览(248)

我是Spring Batch的新手，我想向经验丰富的程序员寻求如何实现以下内容的建议：
我正在编写一个API，该API触发一个批处理任务，以便从JPA repo的事务列表中生成一个报告。
在Spring批处理中，每个步骤都有ItemReader、ItemProcessor和ItemWriter。
我应该如何实现ItemReader，以便它可以执行以下操作：
1.根据jobParameters中设置的参数生成自定义查询（从API查询中获取）
1.使用2中的自定义查询从Transactions JPA存储库中获取事务列表，这些事务将在ItemProcessor中进行处理，随后通过ItemWriter生成报告。
问题：我应该如何编写ItemReader，我正在查看JpaCursorItemReader（如果是正确的话，请使用dk），但无法在网上找到可供参考的实现示例。如有任何帮助，我们将不胜感激。谢谢。
我正处于试图理解Spring批处理是如何工作的阶段，我希望从这个领域的Maven那里寻求适当的指导方向去完成上面提到的任务。

spring

来源：https://stackoverflow.com/questions/74419660/custom-springbatch-itemreader-that-read-form-jpa-repository-using-custom-query

1条答案

按热度按时间

jchrr9hc1#

根据jobParameters中设置的参数生成自定义查询（从API查询中获取）
您可以定义步骤作用域Bean并注入作业参数，以便在查询中使用它们：

@Bean
@StepScope
public JpaCursorItemReader jpaCursorItemReader(@Value("#{jobParameters['parameter']}") String parameter) {
    return new JpaCursorItemReaderBuilder()
            .queryString("..") // use job parameter in your query here
            // set other properties on the item reader
            .build();
}

您可以在以下文档中找到有关步骤作用域组件的更多详细信息：作业和步骤属性的后期绑定。

赞(0）回复(0）举报 2022-11-21

我来回答

自定义SpringBatch ItemReader，它使用自定义查询读取JPA存储库

1条答案

相关问题

热门标签

最新问答