SpringBatch에서 파일을 읽어서 DB에 등록할 때 특정 단어로 시작하는 줄은 처리되지 않게 하는 방법 없을까요?

Question

txt파일의 H로 시작하는 라인과 T로 시작하는 라인은 DB에 넣지않게 처리를 해야되는데요.아래 소스(질문용으로 정리한 거라서 job/step/변수 이름이 틀릴 수 도 있습니다.)에서 밑줄처진 부분의 소스를 넣으면등록처리가 아예 안됩니다.H로 시작하는 라인과 T로 시작하는 라인은 data길이도 틀려서DEFAULT_FIELD_LENGTH_ARRAY 맞춰 자르는 소스를 실행하면 안되서 해당 부분에 넣은 건데...어떻게 해야할까요??@Configuration@EnableTransactionManagementpublic class TELMSG001 { private static final Logger logger = LoggerFactory.getLogger(TELMSG001.class); private static final String PREFIX_NAME = "TELMSG001"; private static final String JOB_NAME = PREFIX_NAME + "Job"; private static final String STEP1_NAME = JOB_NAME + "Step1"; private static final String DEFAULT_FILENAME_PREFIX = "MAST_"; private static final int[] DEFAULT_FIELD_LENGTH_ARRAY = { 1, 8, 10, 30, 300 }; @Autowired @Qualifier("transactionManager") private PlatformTransactionManager transactionManager; @Autowired private JobBuilderFactory jobBuilderFactory; @Autowired private StepBuilderFactory stepBuilderFactory; @Autowired private SqlSessionFactory sqlSessionFactory; @Bean(JOB_NAME) public Job telmsg001Job(@Qualifier(STEP1_NAME) Step telmsg001Step1) { return jobBuilderFactory.get(JOB_NAME) .incrementer(new RunIdIncrementer()) .start(telmsg001Step1) .build(); } @Bean(STEP1_NAME) public Step telmsg001Step1( @Qualifier("telmsg001Step1Reader") FlatFileItemReader telmsg001Step1Reader, @Qualifier("telmsg001Step1Writer") MyBatisBatchItemWriter telmsg001Step1Writer ) { return stepBuilderFactory.get(STEP2_NAME) .transactionManager(transactionManager) .chunk(1000) .reader(telmsg001Step1Reader) .writer(telmsg001Step1Writer) .build(); } // 파일내용을 VO에 담기 @Bean @StepScope public FlatFileItemReader telmsg001Step1Reader() { DefaultLineMapper lineMapper = new DefaultLineMapper<>(); lineMapper.setLineTokenizer((String line) -> { FieldSet fieldSet = new DefaultFieldSet(StringUtils.splitStringByByteSizes(line, DEFAULT_FIELD_LENGTH_ARRAY)); return fieldSet; }); lineMapper.setFieldSetMapper((FieldSet fieldSet) -> { // 문제구간 시작 if ("H".equals(fieldSet.readString(0)) || fieldSet.readString(0).startsWith("T")) { return null; } // 문제구간 종료 // 조건에 맞는 항목은 VO 객체를 생성하여 반환합니다. TelmsgGVo vo = new TelmsgGVo(); vo.setSaveYmd(fieldSet.readString(1)); vo.setCustNo(fieldSet.readString(2)); vo.setCustNM(fieldSet.readString(3)); vo.setAddr(fieldSet.readString(4)); return vo; }); FlatFileItemReader reader = new FlatFileItemReader<>(); reader.setResource(new FileSystemResource(dir + filename)); reader.setEncoding(commonProperties.getFtpServers().get(DEFAULT_FTP_SERVER_NAME).getEncoding()); reader.setLineMapper(lineMapper); return reader; } // DB에 저장 @Bean @StepScope public MyBatisBatchItemWriter telmsg001Step1Writer() { return new MyBatisBatchItemWriterBuilder().sqlSessionFactory(sqlSessionFactory) // MyBatis sqlSessionFactory 설정 .statementId("co.batch.dao.TELMSG001Dao.saveTelmsg") // MyBatis 쿼리 namesapce 설정 .build(); }}

kenu,전독시 · Answer

아래는 FieldSetMapper에서 조건에 맞지 않는 항목을 처리하는 방법입니다:lineMapper.setFieldSetMapper((FieldSet fieldSet) -> { if (fieldSet.readString(0).startsWith(&#34;H&#34;) || fieldSet.readString(0).startsWith(&#34;T&#34;)) { // 조건에 맞지 않는 항목은 빈 VO 객체를 반환합니다. return new TelmsgGVo(); } else { // 조건에 맞는 항목은 VO 객체를 생성하여 반환합니다. TelmsgGVo vo &#61; new TelmsgGVo(); vo.setSaveYmd(fieldSet.readString(1)); vo.setCustNo(fieldSet.readString(2)); vo.setCustNM(fieldSet.readString(3)); vo.setAddr(fieldSet.readString(4)); return vo; } }); 위 코드는 FieldSetMapper에서 readString(0) 메소드를 사용하여 첫 번째 필드의 값을 확인하고, &#34;H&#34; 또는 &#34;T&#34;로 시작하는 경우 빈 TelmsgGVo 객체를 반환합니다. 이렇게 하면, 해당 조건에 맞지 않는 항목은 데이터베이스에 저장되지 않게 됩니다.또한, MyBatisBatchItemWriter의 설정이나 FlatFileItemReader의 다른 설정에는 변화가 없습니다. 이 방법을 사용하면, 파일에서 특정 조건에 맞지 않는 줄을 처리하지 않고, 나머지 항목만 데이터베이스에 저장할 수 있습니다.from: https://www.phind.com/search?cache&#61;f6qsznr67htezkzuy3sjng98

SpringBatch에서 파일을 읽어서 DB에 등록할 때 특정 단어로 시작하는 줄은 처리되지 않게 하는 방법 없을까요?

1개의 답변

Q&A 목록