ファイルアクセス

@Bean
@StepScope
public FlatFileItemReader<SalesPlanDetail> reader(
        @Value("#{jobParameters['inputFile']}") File inputFile) {
    final DelimitedLineTokenizer tokenizer = new DelimitedLineTokenizer(); // (5)
    tokenizer.setNames("branchId", "year", "month", "customerId", "amount"); // (6)
    tokenizer.setDelimiter(","); // (7)
    tokenizer.setQuoteCharacter('"'); // (8)
    final BeanWrapperFieldSetMapper<SalesPlanDetail> fieldSetMapper = new BeanWrapperFieldSetMapper<>(); // (9)
    fieldSetMapper.setTargetType(SalesPlanDetail.class);
    final DefaultLineMapper<SalesPlanDetail> lineMapper = new DefaultLineMapper<>(); // (4)
    lineMapper.setLineTokenizer(tokenizer);
    lineMapper.setFieldSetMapper(fieldSetMapper);
    return new FlatFileItemReaderBuilder<SalesPlanDetail>()
            .name(ClassUtils.getShortName(FlatFileItemReader.class))
            .resource(new FileSystemResource(inputFile)) // (1)
            .lineMapper(lineMapper)
            .encoding("MS932") // (2)
            .strict(true) // (3)
            .build();
}

<!-- (1) (2) (3) -->
<bean id="reader"
      class="org.springframework.batch.item.file.FlatFileItemReader" scope="step"
      p:resource="file:#{jobParameters['inputFile']}"
      p:encoding="MS932"
      p:strict="true">
  <property name="lineMapper">  <!-- (4) -->
    <bean class="org.springframework.batch.item.file.mapping.DefaultLineMapper">
      <property name="lineTokenizer">  <!-- (5) -->
        <!-- (6) (7) (8) -->
        <bean class="org.springframework.batch.item.file.transform.DelimitedLineTokenizer"
              p:names="branchId,year,month,customerId,amount"
              p:delimiter=","
              p:quoteCharacter='"'/>
      </property>
      <property name="fieldSetMapper">  <!-- (9) -->
        <bean class="org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper"
              p:targetType="jp.co.ntt.fw.macchinetta.batch.functionaltest.app.model.plan.SalesPlanDetail"/>
      </property>
    </bean>
  </property>
</bean>

// Writer
@Bean
@StepScope
public FlatFileItemWriter<Customer> writer(
        @Value("#{jobParameters['outputFile']}") File outputFile) {
    final BeanWrapperFieldExtractor<Customer> fieldExtractor = new BeanWrapperFieldExtractor<>(); // (10)
    fieldExtractor.setNames(
            new String[] { "customerId", "customerName", "customerAddress",
                    "customerTel", "chargeBranchId" }); // (11)
    final DelimitedLineAggregator<Customer> lineAggregator = new DelimitedLineAggregator<>(); // (8)
    lineAggregator.setDelimiter(","); // (9)
    lineAggregator.setFieldExtractor(fieldExtractor);
    return new FlatFileItemWriterBuilder<Customer>()
            .name(ClassUtils.getShortName(FlatFileItemWriter.class))
            .resource(new FileSystemResource(outputFile)) // (1)
            .encoding("MS932") // (2)
            .lineSeparator("\n") // (3)
            .append(true) // (4)
            .shouldDeleteIfExists(false) // (5)
            .shouldDeleteIfEmpty(false) // (6)
            .transactional(true) // (7)
            .lineAggregator(lineAggregator)
            .build();
}

<!-- Writer -->
<!-- (1) (2) (3) (4) (5) (6) (7) -->
<bean id="writer"
      class="org.springframework.batch.item.file.FlatFileItemWriter" scope="step"
      p:resource="file:#{jobParameters['outputFile']}"
      p:encoding="MS932"
      p:lineSeparator="&#x0A;"
      p:appendAllowed="true"
      p:shouldDeleteIfExists="false"
      p:shouldDeleteIfEmpty="false"
      p:transactional="true">
  <property name="lineAggregator">  <!-- (8) -->
    <bean class="org.springframework.batch.item.file.transform.DelimitedLineAggregator"
          p:delimiter=",">  <!-- (9) -->
      <property name="fieldExtractor">  <!-- (10) -->
        <!-- (11) -->
        <bean class="org.springframework.batch.item.file.transform.BeanWrapperFieldExtractor"
              p:names="customerId,customerName,customerAddress,customerTel,chargeBranchId"/>
      </property>
    </bean>
  </property>
</bean>

final EnclosableDelimitedLineAggregator<SalesPlanDetail> lineAggregator = new EnclosableDelimitedLineAggregator<>(); // (1)
lineAggregator.setDelimiter(','); // (2)
lineAggregator.setEnclosure('"'); // (3)
lineAggregator.setAllEnclosing(true); // (4)
lineAggregator.setFieldExtractor(fieldExtractor);

<property name="lineAggregator">  <!-- (1) -->
  <!-- (2) (3) (4) -->
  <bean class="org.terasoluna.batch.item.file.transform.EnclosableDelimitedLineAggregator"
        p:delimiter=","
        p:enclosure='"'
        p:allEnclosing="true">
      <property name="fieldExtractor">
        <!-- omitted settings -->
      </property>
  </bean>
</property>

@Bean
@StepScope
public FlatFileItemReader<SalesPlanDetail> reader(
        @Value("#{jobParameters['inputFile']}") Resource inputFile) {
    BufferedReaderFactory  bufferedReaderFactory = new DefaultBufferedReaderFactory(); // (4)
    Range[] ranges = new Range[] {new Range(1, 6), new Range(7, 10), new Range(11, 12), new Range(13, 22), new Range(23, 32)}; // (8)
    final FixedByteLengthLineTokenizer tokenizer = new FixedByteLengthLineTokenizer(Charset.forName("MS932"), ranges); // (6)(9)
    tokenizer.setNames("branchId", "year", "month", "customerId", "amount"); // (7)
    final BeanWrapperFieldSetMapper<SalesPlanDetail> fieldSetMapper = new BeanWrapperFieldSetMapper<>(); // (10)
    fieldSetMapper.setTargetType(SalesPlanDetail.class);
    final DefaultLineMapper<SalesPlanDetail> lineMapper = new DefaultLineMapper<>(); // (5)
    lineMapper.setLineTokenizer(tokenizer); // (6)
    lineMapper.setFieldSetMapper(fieldSetMapper);
    FileSystemResourceLoader loader = new FileSystemResourceLoader();
    return new FlatFileItemReaderBuilder<SalesPlanDetail>()
            .name(ClassUtils.getShortName(FlatFileItemReader.class))
            .resource(inputFile) // (1)
            .encoding("MS932") // (2)
            .strict(true) // (3)
            .bufferedReaderFactory(bufferedReaderFactory) // (4)
            .lineMapper(lineMapper) // (5)
            .build();
}

<!-- (1) (2) (3) -->
<bean id="reader"
      class="org.springframework.batch.item.file.FlatFileItemReader" scope="step"
      p:resource="file:#{jobParameters['inputFile']}"
      p:encoding="MS932"
      p:strict="true">
    <property name="bufferedReaderFactory">  <!-- (4) -->
        <bean class="org.springframework.batch.item.file.DefaultBufferedReaderFactory"/>
    </property>
    <property name="lineMapper">  <!-- (5) -->
        <bean class="org.springframework.batch.item.file.mapping.DefaultLineMapper">
            <property name="lineTokenizer">  <!-- (6) -->
                <!-- (7) -->
                <!-- (8) -->
                <!-- (9) -->
                <bean class="org.terasoluna.batch.item.file.transform.FixedByteLengthLineTokenizer"
                      p:names="branchId,year,month,customerId,amount"
                      c:ranges="1-6, 7-10, 11-12, 13-22, 23-32"
                      c:charset="MS932" />
            </property>
            <property name="fieldSetMapper">  <!-- (10) -->
              <bean class="org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper"
                    p:targetType="jp.co.ntt.fw.macchinetta.batch.functionaltest.app.model.plan.SalesPlanDetail"/>
            </property>
        </bean>
    </property>
</bean>

FixedByteLengthBufferedReaderFactory bufferedReaderFactory = new FixedByteLengthBufferedReaderFactory(32); // (1)

<property name="bufferedReaderFactory">
    <bean class="org.terasoluna.batch.item.file.FixedByteLengthBufferedReaderFactory"
        c:byteLength="32"/>  <!-- (1) -->
</property>

@Bean
@StepScope
public FlatFileItemWriter<SalesPlanDetail> writer(
        @Value("#{jobParameters['outputFile']}") File outputFile) {
    final BeanWrapperFieldExtractor<SalesPlanDetail> fieldExtractor = new BeanWrapperFieldExtractor<>(); // (10)
    fieldExtractor.setNames(
            new String[] { "branchId", "year", "month", "customerId", "amount" });
    final FormatterLineAggregator<SalesPlanDetail> lineAggregator = new FormatterLineAggregator<>(); // (8)
    lineAggregator.setFormat("%6s%4s%2s%10s%10s"); // (9)
    lineAggregator.setFieldExtractor(fieldExtractor);
    return new FlatFileItemWriterBuilder<SalesPlanDetail>()
            .name(ClassUtils.getShortName(FlatFileItemWriter.class))
            .resource(new FileSystemResource(outputFile)) // (1)
            .encoding("MS932") // (2)
            .lineSeparator("\n") // (3)
            .append(true) // (4)
            .shouldDeleteIfExists(false) // (5)
            .shouldDeleteIfEmpty(false) // (6)
            .transactional(true) // (7)
            .lineAggregator(lineAggregator)
            .build();
}

<!-- Writer -->
<!-- (1) (2) (3) (4) (5) (6) (7) -->
<bean id="writer"
      class="org.springframework.batch.item.file.FlatFileItemWriter" scope="step"
      p:resource="file:#{jobParameters['outputFile']}"
      p:encoding="MS932"
      p:lineSeparator="&#x0A;"
      p:appendAllowed="true"
      p:shouldDeleteIfExists="false"
      p:shouldDeleteIfEmpty="false"
      p:transactional="true">
    <property name="lineAggregator">  <!-- (8) -->
        <bean class="org.springframework.batch.item.file.transform.FormatterLineAggregator"
              p:format="%6s%4s%2s%10s%10s">  <!-- (9) -->
            <property name="fieldExtractor">  <!-- (10) -->
              <bean class="org.springframework.batch.item.file.transform.BeanWrapperFieldExtractor"
                    p:names="branchId,year,month,customerId,amount"/>  <!-- (11) -->
            </property>
        </bean>
    </property>
</bean>

final FormatterLineAggregator<SalesPlanDetail> lineAggregator = new FormatterLineAggregator<>(); // (1)
lineAggregator.setFormat("%s%4s%2s%s%10s"); // (2)
final SalesPlanFixedLengthFieldExtractor fieldExtractor = new SalesPlanFixedLengthFieldExtractor(); // (3)
lineAggregator.setFieldExtractor(fieldExtractor);

<property name="lineAggregator">  <!-- (1) -->
    <bean class="org.springframework.batch.item.file.transform.FormatterLineAggregator"
          p:format="%s%4s%2s%s%10s">  <!-- (2) -->
        <property name="fieldExtractor">  <!-- (3) -->
            <bean class="jp.co.ntt.fw.macchinetta.batch.functionaltest.ch05.fileaccess.plan.SalesPlanFixedLengthFieldExtractor"/>
        </property>
    </bean>
</property>

@Bean
@StepScope
public FlatFileItemReader<String> reader(
        @Value("#{jobParameters['inputFile']}") File inputFile) {
    final FlatFileItemReader<String> reader = new FlatFileItemReader<>();
    final PassThroughLineMapper lineMapper = new PassThroughLineMapper(); // (4)
    reader.setResource(new FileSystemResource(inputFile)); // (1)
    reader.setEncoding("MS932"); // (2)
    reader.setStrict(true); // (3)
    reader.setLineMapper(lineMapper);
    return reader;
}

<!-- (1) (2) (3) -->
<bean id="reader"
      class="org.springframework.batch.item.file.FlatFileItemReader" scope="step"
      p:resource="file:#{jobParameters['inputFile']}"
      p:encoding="MS932"
      p:strict="true">
    <property name="lineMapper">  <!-- (4) -->
        <bean class="org.springframework.batch.item.file.mapping.PassThroughLineMapper"/>
    </property>
</bean>

// Writer
@Bean
@StepScope
public FlatFileItemWriter<SalesPlanDetail> writer(
        @Value("#{jobParameters['outputFile']}") File outputFile) {
    final PassThroughLineAggregator<SalesPlanDetail> lineAggregator = new PassThroughLineAggregator<>(); // (8)
    return new FlatFileItemWriterBuilder<SalesPlanDetail>()
            .name(ClassUtils.getShortName(FlatFileItemWriter.class))
            .resource(new FileSystemResource(outputFile)) // (1)
            .encoding("MS932") // (2)
            .lineSeparator("\n") // (3)
            .append(true) // (4)
            .shouldDeleteIfExists(false) // (5)
            .shouldDeleteIfEmpty(false) // (6)
            .transactional(false) // (7)
            .lineAggregator(lineAggregator)
            .build();
}

<!-- Writer -->
<!-- (1) (2) (3) (4) (5) (6) (7) -->
<bean id="writer"
      class="org.springframework.batch.item.file.FlatFileItemWriter" scope="step"
      p:resource="file:#{jobParameters['outputFile']}"
      p:encoding="MS932"
      p:lineSeparator="&#x0A;"
      p:appendAllowed="true"
      p:shouldDeleteIfExists="false"
      p:shouldDeleteIfEmpty="false"
      p:transactional="true">
    <property name="lineAggregator">  <!-- (8) -->
        <bean class="org.springframework.batch.item.file.transform.PassThroughLineAggregator"/>
    </property>
</bean>

@Bean
@StepScope
public MultiResourceItemReader<SalesPlanDetail> multiResourceReader(
        @Value("file:input/sales_plan_detail_*.csv") Resource[] resources,
        FlatFileItemReader<SalesPlanDetail> reader) {
    return new MultiResourceItemReaderBuilder<SalesPlanDetail>()
    .name(ClassUtils.getShortName(MultiResourceItemReader.class))
    .resources(resources) // (1)
    .delegate(reader) // (2)
    .build();
}

// (3)
@Bean
public FlatFileItemReader<SalesPlanDetail> reader() {
    final FlatFileItemReader<SalesPlanDetail> reader = new FlatFileItemReader<>();
    // omitted settings
    reader.setLineMapper(lineMapper);
    return reader;
}

<!-- (1) (2) -->
<bean id="multiResourceReader"
      class="org.springframework.batch.item.file.MultiResourceItemReader"
      scope="step"
      p:resources="file:input/sales_plan_detail_*.csv"
      p:delegate-ref="reader"/>

<!-- (3) -->
<bean id="reader"
      class="org.springframework.batch.item.file.FlatFileItemReader">
    <property name="lineMapper">
      <!-- omitted settings -->
    </property>
</bean>

@Bean
@StepScope
public MultiResourceItemWriter<Customer> multiResourceItemWriter(
        @Value("#{jobParameters['outputDir']}") File outputDir,
        CustomerListResourceSuffixCreator customerListResourceSuffixCreator,
        FlatFileItemWriter<Customer> writer) {
    return new MultiResourceItemWriterBuilder<Customer>()
            .name(ClassUtils.getShortName(MultiResourceItemWriter.class))
            .resource(new FileSystemResource(outputDir)) // (1)
            .resourceSuffixCreator(customerListResourceSuffixCreator) // (2)
            .delegate(writer) // (3)
            .itemCountLimitPerResource(4) // (4)
            .build();
}

// (5)
@Bean
public FlatFileItemWriter<Customer> writer() {
    // omitted settings
    final DelimitedLineAggregator<Customer> lineAggregator = new DelimitedLineAggregator<>();
    lineAggregator.setFieldExtractor(fieldExtractor);
    return new FlatFileItemWriterBuilder<Customer>()
            .name(ClassUtils.getShortName(FlatFileItemWriter.class))
            .transactional(false)
            .lineAggregator(lineAggregator)
            .build();
}

// (6)
@Bean
public CustomerListResourceSuffixCreator customerListResourceSuffixCreator() {
    return new CustomerListResourceSuffixCreator();
}

<!-- (1) (2) (3) (4) -->
<bean id="multiResourceItemWriter"
      class="org.springframework.batch.item.file.MultiResourceItemWriter"
      scope="step"
      p:resource="file:#{jobParameters['outputDir']}"
      p:resourceSuffixCreator-ref="customerListResourceSuffixCreator"
      p:delegate-ref="writer"
      p:itemCountLimitPerResource="4"/>

<!-- (5) -->
<bean id="writer"
      class="org.springframework.batch.item.file.FlatFileItemWriter">
    <property name="lineAggregator">
        <!-- omitted settings -->
    </property>
</bean>

<bean id="customerListResourceSuffixCreator"
      class="jp.co.ntt.fw.macchinetta.batch.functionaltest.ch05.fileaccess.module.CustomerListResourceSuffixCreator"/>  <!-- (6) -->

@Bean
@StepScope
public StaxEventItemReader<Customer> reader(
        @Value("#{jobParameters['inputFile']}") File inputFile, // (1)
        @Value("file:/usr/local/macchinetta/functionaltest/files/test/input/ch05/fileaccess/customer.xsd") Resource schemaResoure, // (6)
        CustomerValidationEventHandler customerValidationEventHandler) throws Exception {
    Jaxb2Marshaller unmarshaller = new Jaxb2Marshaller(); // (5)
    unmarshaller.setSchema(schemaREsource)); // (6)
    unmarshaller.setValidationEventHandler(customerValidationEventHandler); // (7)
    unmarshaller.setClassesToBeBound(Customer.class); // (8)
    unmarshaller.afterPropertiesSet();
    return new StaxEventItemReaderBuilder<Customer>()
            .name(ClassUtils.getShortName(StaxEventItemReader.class))
            .unmarshaller(unmarshaller)
            .resource(new FileSystemResource(inputFile)) // (1)
            .encoding("UTF-8") // (2)
            .addFragmentRootElements("customer") // (3)
            .strict(true) // (4)
            .build();
}

<!-- (1) (2) (3) (4) -->
<bean id="reader" class="org.springframework.batch.item.xml.StaxEventItemReader" scope="step"
      p:resource="file:#{jobParameters['inputFile']}"
      p:encoding="UTF-8"
      p:fragmentRootElementName="customer"
      p:strict="true">
    <property name="unmarshaller">  <!-- (5) -->
        <!-- (6) (7) -->
        <bean class="org.springframework.oxm.jaxb.Jaxb2Marshaller"
              p:schema="file:/usr/local/macchinetta/test/input/ch05/fileaccess/customer.xsd"
              p:validationEventHandler-ref="customerValidationEventHandler">
            <property name="classesToBeBound">  <!-- (8) -->
                <list>
                    <value>jp.co.ntt.fw.macchinetta.batch.functionaltest.ch05.fileaccess.model.jaxb.Customer</value>
                </list>
            </property>
        </bean>
    </property>
</bean>