인프런 커뮤니티 질문&답변

영한님 안녕하세요.

Spring Data JPA 로 리파지토리를 만들고 테스트하다가 나온 사항에 대해 궁금증이 있어 문의를 드립니다.

질문사항은 다음과 같습니다.

ㅇ 목적: 여러 개의 row를 한 번에 insert할 때의 성능을 최적화하려고 함 (여러 개의 row를 넣는 테이블의 pk는 직접 입력을 받아 넣는 id 형식입니다.)

ㅇ 구현 의도: multi-value insert (insert into table values(...), (...), ... , (...) )

ㅇ 시도

-  JpaRepository의 saveAll() 메서드를 사용 (MySQL의 경우 multi-value insert 시 jdbc 옵션으로 rewriteBatchedStatements=true를, PostgreSQL의 경우 reWriteBatchedInserts=true를 주면 되는 것으로 알고 있습니다. h2 DB는 그런 것이 있는지 모르겠네요. 일단 format_sql=true로 했을 때 남겨진 로그로는 해당 내역을 확인하기 힘들었습니다.) 

- saveAll() 시 isNew 필드를 통해 persist, merge 분기를 타기 때문에 성능에 이슈가 있을 것으로 보고, 부가적인 select문 실행을 막기 위해 isNew 필드값을 아래와 같이 true로 만들었습니다.

@Transient
private boolean isNew = true;

@Override
public ClassId getId() {
    return ClassId.builder()
            .pk1(pk1)
            .pk2(pk2)
            .pk3(pk3)
            .pk4(pk4)
            .pk5(pk5)
            .build();
}

@Override
public boolean isNew() {
    return true;
}

@PrePersist
@PostLoad
public void markNotNew(){
    isNew = false;
}

- bulk insert를 위한 batch_size 등의 옵션 추가 (추가한 옵션은 spring.jpa.properties 하위입니다.)

jdbc:
  batch_size: 1000
  batch_versioned_data: true
order_inserts: true
order_updates: true

ㅇ 의문점

1. 일단, 찍히는 sql이 insert into table values(...), (...), ... , (...)  과 같이 찍히지 않습니다. 과연 bulk로 모아서 실행이 되는 것인지가 궁금합니다. 물론 batch_size가 0일때보다 200일 때의 성능 개선이 있긴 한데 약간 미미하다는 생각이 들어서요...

2. em.persist를 n 번 수행한 뒤 flush한 결과보다 성능이 못한데, 이것이 무엇 때문에 나오는 결과인지 궁금합니다. (SimpleJpaRepository.class를 보니 saveAll 함수 내부 로직에서 save를 n 번 호출하고 save 함수 내에서 isNew를 체크하는데 여기서 오는 차이인지..)

3. 원래 100000 정도의 데이터를 insert 할 시에 이 정도의 성능이 나오는 것인지 궁금합니다. (테스트 결과는 아래에 있습니다.)

4. batch_size마다 saveAll()를 해 주고 리스트를 초기화 시켜주는 것이 성능상으로 의미가 있을 지 궁금합니다. (아래 성능 테스트에서는 리스트에 꽉 채운 뒤에 마지막에 saveAll을 호출했었습니다. 궁금하여 batch_size마다 saveAll을 호출하고 리스트를 초기화 시켰보았지만 시간 차이가 거의 나지 않았습니다. 제가 테스트를 잘못한 것인지...)
참고 링크: https://persistencelayer.wixsite.com/springboot-hibernate/post/the-best-way-to-batch-inserts-via-saveall-iterable-s-entities

성능 테스트

• data size = 100000
  • 1. batch_size = 0
    • em.persist 사용: 6807 ms
    • JpaRepository.saveAll() 사용: 7861 ms
  • 2. batch_size = 200
    • em.persist 사용: 5547 ms
    • JpaRepository.saveAll() 사용: 7187 ms
  • 3. batch_size = 500
    • em.persist 사용: 5452 ms
    • JpaRepository.saveAll() 사용: 6489 ms
  • 4. batch_size = 1000
    • em.persist 사용: 5684 ms (배치 사이즈가 증가했음에도 더 오래 걸림)
    • JpaRepository.saveAll() 사용: 6360 ms
  • 5. batch_size = 5000
    • em.persist 사용: 5815 ms (배치 사이즈가 증가했음에도 더 오래 걸림)
    • JpaRepository.saveAll() 사용: 6659 ms (배치 사이즈가 증가했음에도 더 오래 걸림)

보통 영한님은 여러 row를 한 번에 insert하려고 할 때 어떻게 구현을 하시는지 궁금합니다.

답변 부탁드리겠습니다. 긴 내용 읽어주셔서 감사합니다 :)