如何从数据库中检索/设置ItemReader的SQL查询？

Question

我有一个Spring批处理程序，它从数据库中读取数据并处理它，并将（使用ItemWriter）插入到数据库中的其他表中。在这里，我使用了一系列针对ItemReader、Item处理机和ItemWriter的SQL查询。

我的要求是将所有这些查询存储在一个具有参数和值格式的表中，并通过一个数据库调用来检索它，然后将其传递给ItemReader或Item处理机或ItemrWriter。因此，如果将来查询有任何变化，我们将最终只进行数据库更新，代码将保持不变。

我试图在beforeJob部分中这样做，但我遇到了一个错误：“java.lang.IllegalArgumentException:必须提供SQL查询”。但我可以通过在ItemReader方法中进行DB调用来成功地实现这一点。我试图避免这种方法，因为我需要对每个ItemReader、ItemProcessor和ItemWriter进行db调用。请让我知道如何做到这一点？

Answer 1

在我看来，这样的配置通常是将查询存储在属性中，而不是数据库中。比如：

batch.query.unload=SELECT ...

Answer 2

您可以使用从数据库中读取查询并将其添加到执行上下文中的tasklet创建一个步骤，然后使用执行上下文中的查询配置面向块步骤的读取器。以下是一个快速示例：

@Bean
public Tasklet queryRetrievalTasklet() {
    return (contribution, chunkContext) -> {
        String query = ""; // retrieve query from db (using a JdbcTemplate for example)
        chunkContext.getStepContext().getJobExecutionContext().put("query", query);
        return RepeatStatus.FINISHED;
    };
}

@Bean
@StepScope
public ItemReader<Integer> itemReader(@Value("#{jobExecutionContext['query']}") String query) {
    // return your reader configured with the query
    return null;
}

希望这有帮助。