springbatch导出csv文件

要使用Spring Batch导出CSV文件，你可以按照以下步骤操作：

1. 配置JobBuilderFactory和StepBuilderFactory
在你的Spring Batch 配置文件中，你需要定义JobBuilderFactory和StepBuilderFactory。JobBuilderFactory是用来创建Job实例的工厂，而StepBuilderFactory则是用来创建Step实例的工厂。

@Bean
public JobBuilderFactory jobBuilderFactory() {
    return new JobBuilderFactory(new MapJobRepositoryFactoryBean());
}

@Bean
public StepBuilderFactory stepBuilderFactory() {
    return new StepBuilderFactory(new MapJobRepositoryFactoryBean(), new TransactionManager());
}

2. 配置ItemReader和ItemWriter
在Spring Batch中，ItemReader和ItemWriter是两个核心接口，用于读取和写入数据。对于CSV文件，你可以使用FlatFileItemReader和FlatFileItemWriter。

@Bean
public FlatFileItemReader<Person> reader() {
    FlatFileItemReader<Person> reader = new FlatFileItemReader<>();
    reader.setResource(new ClassPathResource("input.csv"));
    reader.setLineMapper(new DefaultLineMapper<Person>() {{
        setLineTokenizer(new DelimitedLineTokenizer() {{
            setNames(new String[]{"firstName", "lastName", "email"});
        }});
        setFieldSetMapper(new BeanWrapperFieldSetMapper<Person>() {{
            setTargetType(Person.class);
        }});
    }});
    return reader;
}

@Bean
public FlatFileItemWriter<Person> writer() {
    FlatFileItemWriter<Person> writer = new FlatFileItemWriter<>();
    writer.setResource(new FileSystemResource("output.csv"));
    writer.setLineAggregator(new DelimitedLineAggregator<Person>() {{
        setDelimiter(",");
        setFieldExtractor(new BeanWrapperFieldExtractor<Person>() {{
            setNames(new String[]{"firstName", "lastName", "email"});
        }});
    }});
    return writer;
}

3. 配置Step
你需要创建一个Step实例来定义你的CSV文件导出任务。在这里，你需要指定ItemReader和ItemWriter。

@Bean
public Step step1() {
    return stepBuilderFactory.get("step1")
            .<Person, Person>chunk(10)
            .reader(reader())
            .writer(writer())
            .build();
}

4. 配置Job
最后，你需要创建一个Job实例来引用Step实例。

@Bean
public Job exportCsvJob() {
    return jobBuilderFactory.get("exportCsvJob")
            .incrementer(new RunIdIncrementer())
            .start(step1())
            .build();
}

完成上述步骤后，你就可以运行你的CSV文件导出任务了。在Spring Boot中，你可以使用CommandLineRunner来运行你的任务。

@SpringBootApplication
public class CsvExportApplication {

    public static void main(String[] args) {
        SpringApplication.run(CsvExportApplication.class, args);
    }

    @Autowired
    private JobLauncher jobLauncher;

    @Autowired
    private Job exportCsvJob;

    @Override
    public void run(String... args) throws Exception {
        JobParameters jobParameters = new JobParametersBuilder()
                .addString("jobName", "exportCsvJob")
                .toJobParameters();
        jobLauncher.run(exportCsvJob, jobParameters);
    }
}

现在你可以打开你的output.csv文件，检查导出的数据是否正确了。