springbatch-DemoBatchConfigure.java

DemoBatchConfigure.java

@Configuration
@EnableBatchProcessing
@AllArgsConstructor
public class DemoBatchConfigure {
    //:省略

    @Bean
    public MyBatisCursorItemReader<Article> reader() {
        return new MyBatisCursorItemReaderBuilder<Article>()
                .sqlSessionFactory(sqlSessionFactory)
                .queryId(ArticleMapper.class.getName() + ".findAll")
                .build();
    }
    
    // ：Writeの設定部分は省略
    
    // chunk(3)とし、３件単位でwriteの処理を行うように指定
    @Bean
    public Step step(ItemReader<Article> reader, ItemWriter<ArticleSummary> writer) {
        return steps.get("step")
                .<Article, ArticleSummary>chunk(3)
                .reader(reader)
                .processor(processor)
                .writer(writer)
                .build();
    }