패스트캠퍼스 챌린지 24일차 - Spring Batch 6

📌 spring-batch 6

✔️ ItemWriter

• 이름은 writer 이지만 항상 쓰기만을 담당하지는 않는다.
• 처리 대상 데이터 삭제 및 갱신, 이벤트 전송 ...

✔️ 구현체

• FlatFileItemWriter (파일에 쓰기)
• JpaItemWriter (Jpa를 이용해서 DB에 쓰기)
• JdbcBatchItemWriter

✔️ FlatFileItemWriter

BeanWrapperFieldExtractor<T>

• setNames(new String[] {"id", "name", "age", ...});
  • 필드명 지정

DelimitedLineAggregator<T>

• 한 라인에 대한 구분자 설정
• setDelimiter(","); // csv의 경우 ','를 구분자로 함
• setFieldExtractor(fieldExtractor)

FlatFileItemWriterBuilder<T>()
    .name("")
    .encoding("UTF-8")
    .resource(new FileSystemResource("path/file.csv"))
    .lineAggregator(lineAggregator)
    .build();

 

✔️ 헤더필드 / 푸터필드 생성

FlatFileWriter
    .headerCallback(writer -> writer.write("id,이름,나이"))    
    .footerCallback(writer -> writer.write("==========\n"))

 

✔️ 기존 파일에 이어쓰기 (파일명이 같은 경우)

FlatFileWriter
    .append(true)

• 푸터에 개행문자 추가

 

✔️ JdbcBatchItemWriter

• DB bulk 연산에 대한 처리 (삽입,삭제,갱신)

ex) bulk insert

insert into person (name, age) values("a",1),("b",2),("c",3);

• values 여러 개 두어 한 번에 처리
• 단건 처리보다 비교적 높은 성능을 가진다.

JdbcBatchItemWriterBuilder
    .dataSource(dataSource)
    .itemSqlParameterSourceProvider(
        new BeanPropertyItemSqlParameterSourceProvider<>()
    )
    .sql("insert into person(name,age) values(:name, :age)")
    .build();

rewriteBatchedStatement=true    

 

✔️ JpaItemWriter

new JpaItemWriterBuild<T>()
    .entityManagerFactory(emf)
    .build();

✔️ 10개 데이터를 삽입시 20개의 쿼리가 나간다.
1개 row 삽입에 대해 select -> insert (2번의 쿼리)
✔️ why?

• 기본값으로 merge가 동작된다.
• 일단 해당 엔티티가 수정대상인지 select 쿼리를 날려본 후
  update or insert 쿼리를 날린다.

 

✔️ merge -> persist

JpaItemWriterBuilder<T>()
    .usePersist(true)

 

✔️ 에러발생 (GenerationType.IDENTITY)

• 현재는 엔티티 객체 생성시 ID(pk)를 생성자를 통해 직접 넣어주었음
• 기본값(merge)일 때는 직접 넣어준 id값을 조회 후에 쿼리를 날리기 때문에 문제가 되지 않았음
• persist의 경우 IDENTITY를 따를 수 있도록 해주어야 한다.
  객체 생성시 id값은 받으면 안 된다.

---

👍  수강인증

패스트캠퍼스 [직장인 실무교육]

본 포스팅은 패스트캠퍼스 환급 챌린지 참여를 위해 작성되었습니다