Spring Data JPA | 벌크성 수정 쿼리 (순수 JPA와 스프링 데이터 JPA 비교)

벌크 연산에 대한 설명은 지난 글에 있다.

참고: https://un-lazy-midnight.tistory.com/115

JPA | JPQL 중급 문법 뿌시기 - 다형성 쿼리, 엔티티 직접 사용, Named 쿼리, 벌크 연산

 

순수 JPA의 벌크성 쿼리 

예제)

특정 나이 이상인 Member들의 나이를 1씩 증가시킨다.

 

Repository 코드)

@Repository
public class MemberJpaRepository {
    public int bulkAgePlus(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 bulkUpdate(){
        //given
        memberJpaRepository.save(new Member("member1",10));
        memberJpaRepository.save(new Member("member2",19));
        memberJpaRepository.save(new Member("member3",20));
        memberJpaRepository.save(new Member("member4",22));
        memberJpaRepository.save(new Member("member5",40));
        
        //when
        int resultCount = memberJpaRepository.bulkAgePlus(20);
        
        //then
        assertThat(resultCount).isEqualTo(3);
    }

 

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

예제)

특정 나이 이상인 Member들의 나이를 1씩 증가시킨다.

 

Repository 코드)

@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(){
        //given
        memberRepository.save(new Member("member1",10));
        memberRepository.save(new Member("member2",19));
        memberRepository.save(new Member("member3",20));
        memberRepository.save(new Member("member4",22));
        memberRepository.save(new Member("member5",40));
        
        //when
        int resultCount = memberRepository.bulkAgePlus(20);
        
        //then
        assertThat(resultCount).isEqualTo(3);
    }

주의 사항

영속성 컨텍스트와 DB의 데이터가 일치하지 않을 수 있다.

그렇기 때문에 벌크 연산 후에는 영속성 컨텍스트를 다 지워줘야 한다.

@Test
    public void bulkUpdate(){
        //given
        memberRepository.save(new Member("member1",10));
        memberRepository.save(new Member("member2",19));
        memberRepository.save(new Member("member3",20));
        memberRepository.save(new Member("member4",22));
        memberRepository.save(new Member("member5",40));
        //when
        int resultCount = memberRepository.bulkAgePlus(20);
        
        //영속성 컨텍스트 안의 데이터들을 지워버린다.
        em.flush();
        em.clear();
        
        //then
        assertThat(resultCount).isEqualTo(3);
    }

 

영속성 컨텍스트와 flush()에 대한 설명은 이전 글을 참고하자.

https://un-lazy-midnight.tistory.com/87

JPA | 엔티티의 생명주기와 영속성 컨텍스트를 알아보자

https://un-lazy-midnight.tistory.com/88

JPA | 플러시와 준영속 상태를 알아보자