У меня есть весеннее пакетное задание для чтения CSV-файла.Я хочу спросить, как избежать обработки первой строки после ее чтения?Первая строка может быть прочитана, но не обрабатывайте ее / не сохраняйте.как мне это сделать?Ниже приведен код конфигурации пакетного задания....................................................................................................................................................................................................................................................................
.
.
@Configuration
public class ImportJobConfig<JobCompletionNotificationListener> {
@Autowired
private JobBuilderFactory jobBuilderFactory;
@Autowired
private StepBuilderFactory stepBuilderFactory;
@Autowired
private DataSource dataSource;
private JdbcTemplate jdbcTemplate;
@Bean
@Scope(value = "step", proxyMode = ScopedProxyMode.TARGET_CLASS)
public FlatFileItemReader<Customer> importReader1(@Value("#{jobParameters[fullPathFileName]}") String pathToFile) {
FlatFileItemReader<Customer> reader = new FlatFileItemReader<>();
reader.setResource(new FileSystemResource(pathToFile));
reader.setLineMapper(new DefaultLineMapper<Customer>() {{
System.out.println("#### importReader!!");
setLineTokenizer(new DelimitedLineTokenizer() {{
setNames(new String[]{"custCustomerName3", stMainPhone","custMainEmail"});
}});
setFieldSetMapper(new BeanWrapperFieldSetMapper<Customer>() {{
setTargetType(Customer.class);
}});
}});
return reader;
}
@Bean
public CustomerItemProcessor processor() {
System.out.println("#### CustomerItemProcessor processor!!");
return new CustomerItemProcessor();
}
@Bean
public JdbcBatchItemWriter<Customer> writer() {
System.out.println("#### writer !!");
JdbcBatchItemWriter<Customer> writer = new JdbcBatchItemWriter<>();
writer.setItemSqlParameterSourceProvider(
new BeanPropertyItemSqlParameterSourceProvider<Customer>());
writer.setSql("INSERT INTO customer (customer_name,customer_phone,comp_id,customer_email)"
+ " VALUES(:custCutomerName, :custMainPhone,:compId,:custMainEmail)");
writer.setDataSource(dataSource);
return writer;
}
@Bean
public Job importUserJob(ItemReader<Customer> importReader) {
System.out.println("#### importUserJob");
return jobBuilderFactory.get("importUserJob")
.incrementer(new RunIdIncrementer())
.flow(step1(importReader))
.end()
.build();
}
@Bean
public Step step1(ItemReader<Customer> importReader) {
System.out.println("#### public Step step1(ItemReader<Customer> importReader) TRIGGERED");
return stepBuilderFactory.get("step1")
.<Customer, Customer>chunk(10)
.reader(importReader)
.processor(processor())
.writer(writer())
.build();
}
}