如何更改作业配置以动态添加文件名

Question

我有一个spring批处理作业，它从数据库中读取数据，然后输出到多个csv。在我的数据库中，我有一个名为divisionId的特殊列。对于divisionId的每个不同值，都应该存在一个CSV文件。我使用ClassifierCompositeItemWriter拆分数据。

目前，我为divisionId的每个不同值定义了一个ItemWriter bean。bean是一样的，只是文件名不同。

如何更改下面的配置，创建一个分区ID自动挂起到文件名的文件，而不必为每个分区ID注册一个新的ItemWriter？

我一直在玩@JobScope和@StepScope注释，但无法正确使用。

提前谢谢。

@Bean
public Step readStgDbAndExportMasterListStep() {
    return  commonJobConfig.stepBuilderFactory
                .get("readStgDbAndExportMasterListStep")
                .<MasterList,MasterList>chunk(commonJobConfig.chunkSize)
                .reader(commonJobConfig.queryStagingDbReader())
                .processor(masterListOutputProcessor())
                .writer(masterListFileWriter())
                .stream((ItemStream) divisionMasterListFileWriter45())
                .stream((ItemStream) divisionMasterListFileWriter90())
                .build();
}

@Bean
public ItemWriter<MasterList> masterListFileWriter() {
    BackToBackPatternClassifier classifier = new BackToBackPatternClassifier();
    classifier.setRouterDelegate(new DivisionClassifier());
    classifier.setMatcherMap(new HashMap<String, ItemWriter<? extends MasterList>>() {{
        put("45", divisionMasterListFileWriter45());
        put("90", divisionMasterListFileWriter90());
    }});
    ClassifierCompositeItemWriter<MasterList> writer = new ClassifierCompositeItemWriter<MasterList>();
    writer.setClassifier(classifier);
    return writer;
}   

@Bean
public ItemWriter<MasterList> divisionMasterListFileWriter45() {
    FlatFileItemWriter<MasterList> writer = new FlatFileItemWriter<>();
    writer.setResource(new FileSystemResource(new File(commonJobConfig.outDir, "45_masterList" + "" + ".csv")));
    writer.setHeaderCallback(masterListFlatFileHeaderCallback());
    writer.setLineAggregator(masterListFormatterLineAggregator());
    return writer;
}   

@Bean
public ItemWriter<MasterList> divisionMasterListFileWriter90() {
    FlatFileItemWriter<MasterList> writer = new FlatFileItemWriter<>();
    writer.setResource(new FileSystemResource(new File(commonJobConfig.outDir, "90_masterList" + "" + ".csv")));
    writer.setHeaderCallback(masterListFlatFileHeaderCallback());
    writer.setLineAggregator(masterListFormatterLineAggregator());
    return writer;
}   

Answer 1

我想出了一个非常复杂的方法。我遵循了https://github.com/langmi/spring-batch-examples/wiki/Rename-Files.的教程

前提是使用步骤执行上下文将文件名放入其中。