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

https://docs.spring.io/spring-data/jpa/docs/current/reference/html/#repositories.limit-query-result

Spring Data JPA - Reference Documentation

 

JPA에는 변경감지(Dirty Checking)하여 업데이트 쿼리를 날리지만, 한번에 모든  row의 데이터를 업데이트 할 경우. 

 

예제) 회원의 나이를 한번에 변경 

 

순수 JPA 벌크성 쿼리 

//순수 JPA 벌크성 수정 업데이트 쿼리
public int bulkAgeQueryPlus(int age) {

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

@Test
public void bulkUdpate() {

    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.bulkAgeQueryPlus(20);

    //then
    assertThat(resultCount).isEqualTo(3);


}

스프링 데이터 JPA 벌크성 업데이트 쿼리

//스프링 데이터 JPA 벌크성 업데이트 쿼리
@Modifying  
@Query("update Member m set m.age = m.age + 1 where m.age >= :age")
int bulkAgeQueryPlus(@Param("age") int age);

    update
        member 
    set
        age=age+1 
    where
        age>=?

 

 

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

벌크성 쿼리를 실행하고 나서 영속성 콘텍스트 초기화: @Modifying(clearAutomatically = true) 
(이 옵션의 기본값은 false) 
이 옵션 없이 회원을 findById로 다시 조회하면 영속성 콘텍스트에 과거값이 남아서 문제가 될 수 있다. 만약 다시 조회해 야하면 꼭 영속성콘텍스트를 초기화하자. 

참고: 벌크연산은 영속성콘텍스트를 무시하고 실행하기 때문에, 영속성콘텍스트에 있는 엔티티의 상태와 DB에 엔티티상태가 달라질 수 있다. 

권장하는 방안 
1. 영속성콘 텍스트에 엔티티가 없는 상태에서 벌크연산을 먼저 실행한다. 
2. 부득이하게 영속성콘텍스트에 엔티티가 있으면 벌크 연산 직후 영속성 콘텍스트를 초기화한다.

 

@Test
public void bulkUdpate() {

    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.bulkAgeQueryPlus(20);

    //영속성 컨텍스트 바로 초기화
    em.flush();//변경된 부분 DB에 반영
    em.clear();

    List<Member> result  = memberRepository.findByUsername("member5");
    Member member5 = result.get(0);
    System.out.println("member5 =  "  + member5);

    //결과 member5 =  Member(id=5, username=member5, age=41)
    
  }

또는 @Modifying(clearAutomatically = true)  어노테이션 사용하여 영속성 콘텍스트 초기화 진행 

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