spring 批量 csv:Adding 多个 headers 到 csv
spring batch csv:Adding multiple headers to csv
如何在 csv 中写入多个 header 以便第二个 header 值应该来自数据库
//预期输出
personId,firstName,lastName,email,age
fullname,total // this is the second header which should come the database
kaa,karthi,sa,123@,34
//下面是spring批量写入csv
的代码片段
@Bean(destroyMethod="")
public JdbcCursorItemReader<Person> reader(){
JdbcCursorItemReader<Person> cursorItemReader = new JdbcCursorItemReader<>();
cursorItemReader.setDataSource(dataSource);
cursorItemReader.setSql("SELECT person_id,first_name,last_name,email,age FROM springbatchdb.person");
cursorItemReader.setRowMapper(new PersonRowMapper());
return cursorItemReader;
}
@Bean(destroyMethod="")
public PersonItenProcessor processor(){
return new PersonItenProcessor();
}
@Bean(destroyMethod="")
public FlatFileItemWriter<Person> writer(){
FlatFileItemWriter<Person> writer = new FlatFileItemWriter<Person>();
String exportFileHeader = "personId,firstName,lastName,email,age";
StringHeaderWriter headerWriter = new StringHeaderWriter(exportFileHeader);
writer.setHeaderCallback(headerWriter);
writer.setResource(new ClassPathResource("person.csv"));
DelimitedLineAggregator<Person> lineAggregator = new DelimitedLineAggregator<Person>();
lineAggregator.setDelimiter(",");
BeanWrapperFieldExtractor<Person> fieldExtractor = new BeanWrapperFieldExtractor<Person>();
fieldExtractor.setNames(new String[]{"personId","firstName","lastName","email","age"});
lineAggregator.setFieldExtractor(fieldExtractor);
writer.setLineAggregator(lineAggregator);
return writer;
}
您可以在 FlatFileHeaderCallback
中执行查询并将结果附加到 header 的第一行。
如何在 csv 中写入多个 header 以便第二个 header 值应该来自数据库
//预期输出
personId,firstName,lastName,email,age
fullname,total // this is the second header which should come the database
kaa,karthi,sa,123@,34
//下面是spring批量写入csv
的代码片段@Bean(destroyMethod="")
public JdbcCursorItemReader<Person> reader(){
JdbcCursorItemReader<Person> cursorItemReader = new JdbcCursorItemReader<>();
cursorItemReader.setDataSource(dataSource);
cursorItemReader.setSql("SELECT person_id,first_name,last_name,email,age FROM springbatchdb.person");
cursorItemReader.setRowMapper(new PersonRowMapper());
return cursorItemReader;
}
@Bean(destroyMethod="")
public PersonItenProcessor processor(){
return new PersonItenProcessor();
}
@Bean(destroyMethod="")
public FlatFileItemWriter<Person> writer(){
FlatFileItemWriter<Person> writer = new FlatFileItemWriter<Person>();
String exportFileHeader = "personId,firstName,lastName,email,age";
StringHeaderWriter headerWriter = new StringHeaderWriter(exportFileHeader);
writer.setHeaderCallback(headerWriter);
writer.setResource(new ClassPathResource("person.csv"));
DelimitedLineAggregator<Person> lineAggregator = new DelimitedLineAggregator<Person>();
lineAggregator.setDelimiter(",");
BeanWrapperFieldExtractor<Person> fieldExtractor = new BeanWrapperFieldExtractor<Person>();
fieldExtractor.setNames(new String[]{"personId","firstName","lastName","email","age"});
lineAggregator.setFieldExtractor(fieldExtractor);
writer.setLineAggregator(lineAggregator);
return writer;
}
您可以在 FlatFileHeaderCallback
中执行查询并将结果附加到 header 的第一行。