如何将列表从 StepExecutionListener 传递到 MultiResourceItemReader

Question

在执行 StepExecutionListener.beforeStep() 期间，我正在启动一个包含数据库数据的资源列表。

@Component
public class DailyExportStepExecutionListener implements StepExecutionListener {

@Autowired
private JdbcTemplate jdbcTemplate;
@Autowired
private ResourceLoader resourceLoader;
private List<Resource> listResource;

public DailyExportStepExecutionListener() {
    listResource = new ArrayList<Resource>();
}

public List<Resource> getListResource() {
    return listResource;
}

@Override
public void beforeStep(StepExecution stepExecution) {
    jdbcTemplate.query("SELECT FullPath FROM DailyExportMetadata",
            (rs, row) -> listResource.add(resourceLoader.getResource(rs.getString(1))));
}

最终我想做的是使用 MultiResourceItemReader 的资源列表

@Bean
public MultiResourceItemReader<DailyExport> multiResourceItemReader(FieldSetMapper<DailyExport> testClassRowMapper) {

    MultiResourceItemReader<DailyExport> multiResourceItemReader = new MultiResourceItemReader<>();
    multiResourceItemReader.setName("dailyExportMultiReader");
    multiResourceItemReader.setDelegate(reader(testClassRowMapper));
    multiResourceItemReader.setStrict(true);
    multiResourceItemReader.setResources(??);
    
    return multiResourceItemReader;
}

如何在组件之间传递 ArrayList？

谢谢

Answer 1

名为 multiResourceItemReader 的方法的目的是构建将在作业中使用的项目 reader，以便它在作业开始之前执行，因此在 beforeStep 之前执行已执行。

如果可以，您应该执行 sql 以在配置时填充 listResource：例如在注释为 @Bean 的方法中：

@Bean
public List<Resource> listResource(JdbcTemplate jdbcTemplate, ResourceLoader resourceLoader) {
    List<Resource> listResource;
    jdbcTemplate.query("SELECT FullPath FROM DailyExportMetadata",
            (rs, row) -> listResource.add(resourceLoader.getResource(rs.getString(1))));
    return listResource;
}

而 multiResourceItemReader 方法就像：

@Bean
public MultiResourceItemReader<DailyExport> multiResourceItemReader(FieldSetMapper<DailyExport> testClassRowMapper, List<Resource> listResource) {

    MultiResourceItemReader<DailyExport> multiResourceItemReader = new MultiResourceItemReader<>();
    multiResourceItemReader.setName("dailyExportMultiReader");
    multiResourceItemReader.setDelegate(reader(testClassRowMapper));
    multiResourceItemReader.setStrict(true);
    multiResourceItemReader.setResources(listResource);
    
    return multiResourceItemReader;
}

如果您无法在开始作业前初始化 listResource，您应该按照此 post () 中的说明进行操作。 beforeStep 方法应该像这样将 listResource 放在步骤执行上下文中：

stepExecution.getExecutionContext().put("listResource", listResource);

"listResource"是multiResourceItemReader方法中@Value语句中用来获取列表的key

如何将列表从 StepExecutionListener 传递到 MultiResourceItemReader

How to pass List from StepExecutionListener to MultiResourceItemReader

spring

spring-batch

spring-boot