Spring Batch分区DBtoFile Java配置示例

@Configuration
@EnableBatchProcessing
public class BatchConfig {

    @Autowired
    private JobBuilderFactory jobBuilderFactory;

    @Autowired
    private StepBuilderFactory stepBuilderFactory;

    @Autowired
    private DataSource dataSource;

    @Bean
    public ItemReader<YourEntity> reader() {
        JdbcCursorItemReader<YourEntity> reader = new JdbcCursorItemReader<>();
        reader.setDataSource(dataSource);
        reader.setSql("SELECT * FROM your_table");
        reader.setRowMapper(new YourEntityRowMapper());
        return reader;
    }

    @Bean
    public ItemProcessor<YourEntity, YourEntity> processor() {
        return new YourEntityProcessor();
    }

    @Bean
    public ItemWriter<YourEntity> writer() {
        FlatFileItemWriter<YourEntity> writer = new FlatFileItemWriter<>();
        writer.setResource(new FileSystemResource("output.txt"));
        writer.setLineAggregator(new PassThroughLineAggregator<>());
        return writer;
    }

    @Bean
    public Step step1(ItemReader<YourEntity> reader, ItemProcessor<YourEntity, YourEntity> processor, ItemWriter<YourEntity> writer) {
        return stepBuilderFactory.get("step1")
                .<YourEntity, YourEntity>chunk(100)
                .reader(reader)
                .processor(processor)
                .writer(writer)
                .build();
    }

    @Bean
    public Job job(Step step1) {
        return jobBuilderFactory.get("job")
                .incrementer(new RunIdIncrementer())
                .flow(step1)
                .end()
                .build();
    }
}

@SpringBootApplication
public class Application {

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