import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Before
public void setUp() {
    p = new Product();
    p.setId("211");
    p.setName("BlackBerry");
    products = Arrays.asList(p);
    writer = mock(FlatFileItemWriter.class);
}
 

import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Bean
public FlatFileItemWriter<Product> productItemWriter() {
	FlatFileItemWriter<Product> writer = new FlatFileItemWriter<Product>();
	writer.setResource(new FileSystemResource(OUTPUT_FILE));

	DelimitedLineAggregator<Product> aggregator = new DelimitedLineAggregator<Product>();
	aggregator.setFieldExtractor(new ProductFieldExtractor());

	writer.setLineAggregator(aggregator);

	return writer;
}
 

import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Bean
public FlatFileItemWriter<Product> productItemWriter() {
	FlatFileItemWriter<Product> writer = new FlatFileItemWriter<Product>();
	writer.setResource(new FileSystemResource(OUTPUT_FILE));
	writer.setHeaderCallback(headerCallback());
	writer.setFooterCallback(footerCallback());
	writer.setLineAggregator(lineAggregator());

	return writer;
}
 

import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Bean
public FlatFileItemWriter<Product> productItemWriter() {
	FlatFileItemWriter<Product> writer = new FlatFileItemWriter<Product>();
	writer.setResource(new FileSystemResource(OUTPUT_FILE));
	writer.setLineAggregator(lineAggregator());

	return writer;
}
 

import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Bean
public FlatFileItemWriter<Product> productItemWriter() {
	FlatFileItemWriter<Product> writer = new FlatFileItemWriter<Product>();
	writer.setResource(new FileSystemResource(OUTPUT_FILE));

	DelimitedLineAggregator<Product> aggregator = new DelimitedLineAggregator<Product>();
	aggregator.setDelimiter("|");

	BeanWrapperFieldExtractor extractor = new BeanWrapperFieldExtractor();
	extractor.setNames(new String[] { "id", "price", "name" });
	aggregator.setFieldExtractor(extractor);

	writer.setLineAggregator(aggregator);

	return writer;
}
 

import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Bean
public ItemWriter<PostDTO> demoJobWriter() {
    FlatFileItemWriter<PostDTO> writer = new FlatFileItemWriter<>();
    writer.setResource(new FileSystemResource("/home/daveburke/web/nixmashspring/posts.csv"));
    DelimitedLineAggregator<PostDTO> delLineAgg = new DelimitedLineAggregator<>();
    delLineAgg.setDelimiter(";");
    BeanWrapperFieldExtractor<PostDTO> fieldExtractor = new BeanWrapperFieldExtractor<>();
    fieldExtractor.setNames(new String[]{"postTitle"});
    delLineAgg.setFieldExtractor(fieldExtractor);
    writer.setLineAggregator(delLineAgg);
    return writer;
}
 

import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Bean
public Step readWriteStep(JpaPagingItemReader<Product> reader, FlatFileItemWriter<Product> writer) {
	return stepBuilders.get("readWrite")
	                   .<Product, Product>chunk(2)
	                   .reader(reader)
	                   .writer(writer)
	                   .build();
}
 

import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Bean
@StepScope
public FlatFileItemWriter<Product> productItemWriter() {
	FlatFileItemWriter<Product> writer = new FlatFileItemWriter<Product>();
	writer.setResource(new FileSystemResource(OUTPUT_FILE));
	writer.setLineAggregator(new PassThroughLineAggregator<Product>());

	return writer;
}
 

import org.springframework.batch.item.file.FlatFileItemWriter; //导入依赖的package包/类
@Bean
public FlatFileItemWriter<Product> productItemWriter() {
	FlatFileItemWriter<Product> writer = new FlatFileItemWriter<Product>();
	writer.setResource(new FileSystemResource(OUTPUT_FILE));

	DelimitedLineAggregator<Product> aggregator = new DelimitedLineAggregator<Product>();
	aggregator.setFieldExtractor(new PassThroughFieldExtractor<Product>());

	writer.setLineAggregator(aggregator);

	return writer;
}