FlatFileItemWriter 在每个 JobExecution 上写入一个新的（不存在的）文件

Question

我目前正在处理 Spring 批量 CSV 导出。使用基于 Chunk 的 reader、writer、processor。读取和处理工作完美，但 FlatFileItemWriter 总是覆盖输出 CSV 文件。我希望作业检查文件是否存在，如果存在则增加文件名并写入新文件。

这是我当前的代码：我的助手 class，用于检查文件是否存在以及 returns 供 Writer 使用的新字符串。

import java.io.File;

import org.springframework.stereotype.Component;

@Component
public class OrderFileManager {

    private final String orderDesc = "order";
    private final String fileEnding = ".csv";

    public String getEmptyOrderNameString() {

        int fileNumber = 1;
        String answer = orderDesc + fileNumber + fileEnding;

        while (new File(answer).exists()) {
            fileNumber = fileNumber + 1;
            answer = orderDesc + fileNumber + fileEnding;
        }
        return answer;
    }
}

我的 ItemWriter :

    @Bean
    public FlatFileItemWriter<UltravisionOrder> writer(String fileName) {
        FlatFileItemWriter<UltravisionOrder> writer = new FlatFileItemWriter<UltravisionOrder>();  
        writer.setResource(new FileSystemResource(fileName));
        DelimitedLineAggregator<UltravisionOrder> delimitedLineAggregator = new DelimitedLineAggregator<UltravisionOrder>();
        delimitedLineAggregator.setDelimiter(";");
        BeanWrapperFieldExtractor<UltravisionOrder> fieldExtractor = new BeanWrapperFieldExtractor<UltravisionOrder>();
        fieldExtractor.setNames(new String[] { "col1", "col2", "col3", ... });
        delimitedLineAggregator.setFieldExtractor(fieldExtractor);
        writer.setLineAggregator(delimitedLineAggregator);
        return writer;
    }

每次执行作业时，FileWriter 都会写入同一个输出文件。 OrderFileManager 在作业中自动装配。编写器接收 OrderFileManager。 getEmptyOrderNameString() 作为参数。

Answer 1

如果 Spring 应用程序上下文没有在每个作业中重新加载运行，文件写入器 bean 将被重新使用并且将始终写入相同的资源。

您可以做的是通过调用使用 SpEL 表达式生成文件名的方法来设置编写器步骤的范围并对其进行配置：

@Bean
@StepScope
public FlatFileItemWriter<UltravisionOrder> itemWriter(@Value("#{orderFileManager.getEmptyOrderNameString()}") String fileName) {
    // ...
}

FlatFileItemWriter 在每个 JobExecution 上写入一个新的（不存在的）文件

FlatFileItemWriter write to a new (non-existent) File on each JobExecution

java

csv

spring

spring-batch

itemwriter