Spring Batch 사용 중 빈 등록 질문..

Question

// 코드1. @Slf4j @RequiredArgsConstructor @Configuration public class WithdrawalJobConfiguration { private static final int CHUNK_SIZE = 20; private final JobBuilderFactory jobBuilderFactory; private final StepBuilderFactory stepBuilderFactory; private final WithdrawalReader withdrawalReader; private final DataSource dataSource; @Bean public Job withdrawalJob() { return jobBuilderFactory.get("withdrawalJob") .start(introductionDeleteStep()) .build(); } @Bean @Transactional public Step introductionDeleteStep() { return stepBuilderFactory.get("introductionDeleteStep") .chunk(CHUNK_SIZE) .reader(withdrawalReader.introductionItemReader()) .writer(introductionItemWriter()) .build(); } @Bean public JdbcBatchItemWriter introductionItemWriter() { return new JdbcBatchItemWriterBuilder() .dataSource(dataSource) .sql("DELETE FROM Introduction i WHERE i.introduction_id = :id") .itemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>()) .build(); } } // 코드2. @Slfj @RequiredArgsConstructor @Configuration public class WithdrawalJobConfiguration { private static final int CHUNK_SIZE = 20; private final JobBuilderFactory jobBuilderFactory; private final StepBuilderFactory stepBuilderFactory; private final WithdrawalReader withdrawalReader; private final WithdrawalWriter withdrawalWriter; private final DataSource dataSource; @Bean public Job withdrawalJob() { return jobBuilderFactory.get("withdrawalJob") .start(introductionDeleteStep()) .build(); } @Bean @Transactional public Step introductionDeleteStep() { return stepBuilderFactory.get("introductionDeleteStep") .chunk(CHUNK_SIZE) .reader(withdrawalReader.introductionItemReader()) .writer(withdrawalWriter.introductionItemWriter()) .build(); } } @Configuration @RequiredArgsConstructor public class WithdrawalWriter { private final DataSource dataSource; @Bean public JdbcBatchItemWriter introductionItemWriter() { return new JdbcBatchItemWriterBuilder() .dataSource(dataSource) .sql("DELETE FROM Introduction i WHERE i.introduction_id = :id") .itemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>()) .build(); } } 코드1과 2가 다른점은 introductionItemWriter bean을 다른 @Configuration 파일로 분리 했냐 안했냐인데, 분리한 상태(코드 2)에서 배치를 돌리면 "org.springframework.batch.item.database.ItemPreparedStatementSetter.setValues(Object, java.sql.PreparedStatement)" because "this.this$0.itemPreparedStatementSetter" is null 이라는 오류가 뜹니다.. Bean 등록 관련한 문제 같은데 왜 이럴까요?

Spring Batch 사용 중 빈 등록 질문..

0개의 답변

Q&A 목록