스프링 데이터 JPA - 벌크성 수정 쿼리

벌크성 수정 쿼리

스프링 데이터 JPA는 데이터의 값을 한 번에 변경할 수 있는 벌크성 수정 쿼리도 지원한다.

JPA를 사용한 벌크성 수정 쿼리

public int bulkAgePlus(int age) {
    int resultCount = em.createQuery("update Member m set m.age = m.age + 1 where m.age >:age")
            .setParameter("age", age)
            .executeUpdate();
    return resultCount;
}

@Test
public void bulkUpdate() throws Exception {
    //given
    memberJpaRepository.save(new Member("member1", 10));
    memberJpaRepository.save(new Member("member2", 19));
    memberJpaRepository.save(new Member("member3", 20));
    memberJpaRepository.save(new Member("member4", 21));
    memberJpaRepository.save(new Member("member5", 40));
    //when
    int resultCount = memberJpaRepository.bulkAgePlus(20);
    //then
    assertThat(resultCount).isEqualTo(3);
}

스프링 데이터 JPA를 사용한 벌크성 수정 쿼리

@Modifying
@Query("update Member m set m.age = m.age+1 where m.age >= :age")
int bulkAgePlus(@Param("age") int age);

@Test
public void bulkUpdate() throws Exception {
    //given
    memberRepository.save(new Member("member1", 10));
    memberRepository.save(new Member("member2", 19));
    memberRepository.save(new Member("member3", 20));
    memberRepository.save(new Member("member4", 21));
    memberRepository.save(new Member("member5", 40));
    //when
    int resultCount = memberRepository.bulkAgePlus(20);
    //then
    assertThat(resultCount).isEqualTo(3);
}

벌크성 수정, 삭제 쿼리는 @Modifying 어노테이션을 사용한다.
사용하지 않으면 다음 예외가 발생하게 된다.
org.hibernate.hql.internal.QueryExecutionRequestException: Not supported for DML operations

벌크 연산은 영속성 컨텍스트를 무시하고 실행하기 때문에, 영속성 컨텍스트에 있는 엔티티의 상태와 DB에 엔티티 상태가 달라질 수 있다.
즉, 벌크성 쿼리를 실행하고 영속성 컨텍스트를 초기화 하지 않고, 수정된 데이터를 조회하면 영속성 컨텍스트에 과거 값이 남아서 문제가 될 수 있다.

• 권장하는 방안
  • 1 : 영속성 컨텍스트에 엔티티가 없는 상태에서 벌크 연산을 먼저 실행한다.
  • 2 : 부득이하게 영속성 컨텍스트에 엔티티가 있으면 벌크 연산 직후 영속성 컨텍스트를 초기화 한다.
    • @Modifying(clearAutomatically = true)을 통해 자동으로 초기화 할 수 있다.(기본 값은 false이다.)

인프런 김영한 지식공유자님 강의 : 실전! 스프링 데이터 JPA