Notice
Recent Posts
Recent Comments
Link
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | 6 | 7 |
8 | 9 | 10 | 11 | 12 | 13 | 14 |
15 | 16 | 17 | 18 | 19 | 20 | 21 |
22 | 23 | 24 | 25 | 26 | 27 | 28 |
29 | 30 | 31 |
Tags
- PAGING
- transactionaleventlistener
- Kubernetes
- entity graph
- Kotlin
- offsetdatetime
- producer
- cd
- Spring Data JPA
- QueryDSL
- spring
- spring kafka
- JPA
- mysql
- Entity
- consumer
- CodePipeline
- API
- git
- ECS
- K8s
- Streams
- mirror maker2
- topic생성
- AWS
- Spring JPA
- bean
- kafka
- CI
- centos7
Archives
- Today
- Total
Yebali
Spring Data JPA의 벌크성 수정 쿼리 본문
벌크성 쿼리란?
벌크성 쿼리란 DB에서 여러 개의 레코드를 한 번에 추가/수정/삭제하는 쿼리를 말한다.
예를 들어 나이가 10인 레코드들의 나이를 1살씩 추가하는 벌크성 쿼리는 아래와 같다.
UPDATE tbl_member SET age = 1 WHERE age = 10;
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;
}
createQuery 하여 update쿼리를 작성해주고 setParameter를 통해 age값을 매핑한다.
Spring Data JPA도 @Query, @Modifying 애너테이션을 통해 벌크성 쿼리를 지원한다.
@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 애너테이션을 반드시 사용해야 한다.
: 사용하지 않으면 Exception이 발생한다. - 벌크성 쿼리를 사용하고 나면 반드시 영속성 컨텍스트를 초기화해야 한다.
: 초기화하지 않으면 수정 전 값들이 영속성 컨텍스트에 남아서 문제가 될 수 있다.
자동으로 초기화하는 방법은 @Modifying의 'clearAutomatically'의 값을 true로 주면 된다.
(기본 값은 false)
@Modifying(clearAutomatically = true)
참고로 벌크 연산은 영속성 컨텍스트를 무시하고 실행하기 때문에,
영속성 컨텍스트에 있는 엔티티의 상태와 DB의 엔티티 상태가 달라 질 수 있다.
권장 방안
- 영속성 컨텍스트에 엔티티가 없는 상태에서 벌크 연산을 먼저 실행한다.
- 부득이하게 영속성 컨텍스트에 엔티티가 있으면 벌크 연산 직후 영속성 컨텍스트를 초기화한다.
'Spring' 카테고리의 다른 글
Spring Data JPA의 Auditing 기능 (0) | 2021.10.11 |
---|---|
Spring Data JPA의 사용자 정의 Repository (0) | 2021.10.11 |
Spring Data JPA의 반환 타입 (0) | 2021.10.11 |
Spring Data JPA의 @Query 애너에티션 (0) | 2021.10.11 |
Spring Data JPA의 Named Query (0) | 2021.10.11 |