処理の再実行

// (3)
@Bean
public MyBatisCursorItemReader<SalesPlanDetail> reader(
        @Qualifier("jobSqlSessionFactory") SqlSessionFactory jobSqlSessionFactory) {
    return new MyBatisCursorItemReaderBuilder<SalesPlanDetail>()
            .sqlSessionFactory(jobSqlSessionFactory)
            .queryId(
                    "org.terasoluna.batch.functionaltest.ch06.reprocessing.repository.RestartOnConditionRepository.findByZeroOrLessAmount")
            .build();
}

// (4)
@Bean
public MyBatisBatchItemWriter<SalesPlanDetail> dbWriter(
        @Qualifier("jobSqlSessionFactory") SqlSessionFactory jobSqlSessionFactory,
        SqlSessionTemplate batchModeSqlSessionTemplate) {
    return new MyBatisBatchItemWriterBuilder<SalesPlanDetail>()
            .sqlSessionFactory(jobSqlSessionFactory)
            .statementId(
                    "org.terasoluna.batch.functionaltest.ch06.reprocessing.repository.RestartOnConditionRepository.update")
            .sqlSessionTemplate(batchModeSqlSessionTemplate)
            .build();
}

@Bean
@StepScope
public FlatFileItemWriter<SalesPlanDetail> fileWriter(
        @Value("#{jobParameters['outputFile']}") File outputFile) {
    DelimitedLineAggregator<SalesPlanDetail> lineAggregator = new DelimitedLineAggregator<>();
    BeanWrapperFieldExtractor<SalesPlanDetail> fieldExtractor = new BeanWrapperFieldExtractor<>();
    fieldExtractor.setNames(new String[] {"branchId", "year", "month", "customerId", "amount"});
    lineAggregator.setFieldExtractor(fieldExtractor);
    return new FlatFileItemWriterBuilder<SalesPlanDetail>()
            .name(ClassUtils.getShortName(FlatFileItemWriter.class))
            .resource(new FileSystemResource(outputFile))
            .lineAggregator(lineAggregator)
            .append(true) // (5)
            .build();
}

// (6)
@Bean(destroyMethod="")
public CompositeItemWriter<SalesPlanDetail> compositeWriter(
        @Qualifier("fileWriter") FlatFileItemWriter<SalesPlanDetail> fileWriter,
        @Qualifier("dbWriter") MyBatisBatchItemWriter<SalesPlanDetail> dbWriter) throws Exception {

    List<ItemWriter<? super SalesPlanDetail>> list = new ArrayList<>();
    list.add(fileWriter);
    list.add(dbWriter);

    return new CompositeItemWriterBuilder<SalesPlanDetail>()
            .delegates(list)
            .build();
}

@Bean
public Step step01(JobRepository jobRepository,
                   @Qualifier("jobTransactionManager") PlatformTransactionManager transactionManager,
                   ItemReader<SalesPlanDetail> reader,
                   @Qualifier("amountUpdateItemProcessor") ItemProcessor<SalesPlanDetail, SalesPlanDetail> processor,
                   @Qualifier("compositeWriter") ItemWriter<SalesPlanDetail> compositeWriter,
                   LoggingItemReaderListener listener) {
    return new StepBuilder("restartOnConditionBasisJob.step01",
            jobRepository)
            .<SalesPlanDetail, SalesPlanDetail> chunk(10, transactionManager)
            .reader(reader)
            .processor(processor)
            .writer(compositeWriter)
            .listener(listener)
            .build();
}

@Bean
public Job restartOnConditionBasisJob(JobRepository jobRepository,
                                        Step step01,
                                        JobExecutionLoggingListener listener) {
    return new JobBuilder("restartOnConditionBasisJob",
            jobRepository)
            .preventRestart() // (7)
            .start(step01)
            .listener(listener)
            .build();
}

<!-- (3) -->
<bean id="reader" class="org.mybatis.spring.batch.MyBatisCursorItemReader"
      p:queryId="jp.co.ntt.fw.macchinetta.batch.functionaltest.ch06.reprocessing.repository.RestartOnConditionRepository.findByZeroOrLessAmount"
      p:sqlSessionFactory-ref="jobSqlSessionFactory"/>

<!-- (4) -->
<bean id="dbWriter" class="org.mybatis.spring.batch.MyBatisBatchItemWriter"
      p:statementId="jp.co.ntt.fw.macchinetta.batch.functionaltest.ch06.reprocessing.repository.RestartOnConditionRepository.update"
      p:sqlSessionTemplate-ref="batchModeSqlSessionTemplate"/>

<bean id="fileWriter"
      class="org.springframework.batch.item.file.FlatFileItemWriter" scope="step"
      p:resource="file:#{jobParameters['outputFile']}"
      p:appendAllowed="true"> <!-- (5) -->
    <property name="lineAggregator">
        <bean class="org.springframework.batch.item.file.transform.DelimitedLineAggregator">
            <property name="fieldExtractor">
                <bean class="org.springframework.batch.item.file.transform.BeanWrapperFieldExtractor"
                      p:names="branchId,year,month,customerId,amount"/>
            </property>
        </bean>
    </property>
</bean>
<!-- (6) -->
<bean id="compositeWriter" class="org.springframework.batch.item.support.CompositeItemWriter">
    <property name="delegates">
        <list>
            <ref bean="fileWriter"/>
            <ref bean="dbWriter"/>
        </list>
    </property>
</bean>

<batch:job id="restartOnConditionBasisJob"
           job-repository="jobRepository" restartable="false"> <!-- (7) -->

    <batch:step id="restartOnConditionBasisJob.step01">
        <batch:tasklet transaction-manager="jobTransactionManager">
            <batch:chunk reader="reader" processor="amountUpdateItemProcessor"
                         writer="compositeWriter" commit-interval="10" />
        </batch:tasklet>
    </batch:step>

</batch:job>