ファイルアクセス

@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();
}

return new FlatFileItemReaderBuilder<SalesPlanDetail>()
  .name(ClassUtils.getShortName(FlatFileItemReader.class))

public FlatFileItemReader() {
  setName(ClassUtils.getShortName(FlatFileItemReader.class));
}

tokenizer.setDelimiter(DelimitedLineTokenizer.DELIMITER_TAB);

// 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();
}

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

tokenizer.setDelimiter(DelimitedLineTokenizer.DELIMITER_TAB);

@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();
}

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

@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();
}

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

@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;
}

// 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();
}

@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;
}

@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();
}

@Bean
@StepScope
public StaxEventItemReader<Customer> reader(
        @Value("#{jobParameters['inputFile']}") File inputFile, // (1)
        @Value("${fileaccess.schema-file-path}") String schemaFile, // (6)
        CustomerValidationEventHandler customerValidationEventHandler) throws Exception {
    Jaxb2Marshaller unmarshaller = new Jaxb2Marshaller(); // (5)
    unmarshaller.setSchema(new FileSystemResource(schemaFile)); // (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();
}

Jaxb2Marshaller marshaller = new Jaxb2Marshaller();
marshaller.setClassesToBeBound(CustomerToJaxb.class);
marshaller.setMarshallerProperties(Map.of("javax.xml.bind.Marshaller.JAXB_FORMATTED_OUTPUT", true));
marshaller.afterPropertiesSet();

@Bean
@StepScope
public StaxEventItemWriter<Customer> writer(
        @Value("#{jobParameters['outputFile']}") File outputFile) throws Exception {
    Jaxb2Marshaller marshaller = new Jaxb2Marshaller(); // (8)
    marshaller.setClassesToBeBound(CustomerToJaxb.class); // (9)
    marshaller.setMarshallerProperties(Map.of("javax.xml.bind.Marshaller.JAXB_FORMATTED_OUTPUT", true)); // (10)
    marshaller.afterPropertiesSet();
    return new StaxEventItemWriterBuilder<Customer>()
            .name(ClassUtils.getShortName(StaxEventItemWriter.class))
            .resource(new FileSystemResource(outputFile)) // (1)
            .encoding("MS932") // (2)
            .rootTagName("records") // (3)
            .overwriteOutput(true) // (4)
            .shouldDeleteIfEmpty(false) // (5)
            .transactional(true) // (6)
            .standalone(false) // (7)
            .marshaller(marshaller)
            .build();
}