5주차 - 05. 스프링 데이터 JPA를 이용한 조회 기능

[DaehunGwak]

진도

5. 스프링 데이터 JPA를 이용한 조회 기능

일정

• 2022.01.15.(일) 19:00

[DaehunGwak]

5.1 시작에 앞서

• CQRS: 명령 조회 모델 분리 패턴
  • Command Query Responsibility Segregation
  • 도메인 모델은 명령으로
  • 조회 모델은 DTO 혹은 조회 전용 엔티티 로 가능

5.2 검색을 위한 스펙

• JpaRepository의 find 필드 조합은 너무 다양하게 파생될 수 있어 좋은 방법은 아님
• 검색 조건이 다양하게 필요할때는 스펙(Specification)을 이용하 수 있음
  • 애그리거트가 특정 조건을 충족하는지 검사할 때 사용하는 인터페이스

5.3 스프링 데이터 JPA를 이요한 스펙구현

• 하이버네이트 같은 JPA 프로바이더가 정적 메타 모델 클래스(*_ 형식) 를 제공해 Criteria를 문자열로 제공했을 때 휴먼에러가 발생하는 것을 방지할 수 있음

5.5 스펙 조합

• Specification<T> 는 and or not디폴트 팩토리 메서드를 제공해 스펙들을 연결할 수 있다
• 스펙의 where 메서드는 null 스펙으로 인자가 들어오면 아무 조건 없는 스펙을 만들어 주는 디폴트 팩토리 메서드

5.6 정렬 지정하기

• 리포지터리 쿼리 메서드의 OrderBy 기능 역시
• Sort 로 복잡한 정렬 지정을 할 수 있음
• and or 메서드 제공

5.7 페이징 처리하기

• 인자로 Pageable 사용, 리턴은 Page<T>
• 페이지 번호는 0 부터 시작
• 페이징 사용 시 주의점
  • 리턴 Page<T> 사용 시, count 쿼리 발생
  • 리턴이 Page가 아니더라도 Specification<T> + Pageable 인자 조합은 count 쿼리 발생

5.8 스펙 조합을 위한 스펙 빌더 클래스

• SpecBuilder 를 통해 ifHasText, ifTrue 와 같은 기능으로 선택적으로 스펙을 연결할 수 있다
  • 최종적 build는 and 로 엮임

5.9 동적 인스턴스 생성

• DTO 프로젝션 쿼리에 사용되는 클래스를 동적 인스턴스라고 부르는 구나~
• 장점: jpql 객체 기준 쿼리 작성 가능 + 지연/즉시 로딩 고민 없음

5.10 하이버네이트 @Subselect 사용

• @Subselect @Immutable @Synchronize 를 통해 조회 모델 엔티티를 만들 수 있음
  • @Subselect : jpql 쿼리 작성으로 해당 엔티티에 맵핑
  • @Immutable : 변경 쿼리 생략
  • @Synchronize : 엔티티 매니저에 지정된 테이블의 변경분이 플러쉬되지 않았다면 플러쉬

[progress0407]

원본 보러 가기

chapter 5. 스프링 데이터 JPA를 이용한 조회 기능

Intro

전반적으로 Criteria 라는 기술을 사용하고 있다.

그러나 이 기술은 실무에 적용하기엔 너무나 번잡하고 더 좋은 대안들이 있다. (by 김영한님)

QueryDSL을 사용하도록 하자.

[덧붙임 생각]

Repository의 메서드를 생략하기 위해서 Spec을 생성하는데... 이럴 바엔 차라리 Spec을 생성하는게 나을 것 같다.

5.1 시작에 앞서

5.2 검색을 위한 스펙

5.3 스프링 데이터 JPA를 이용한 스펙 구현

5.4 리포지터리/DAO에서 스펙 사용하기

5.5 스펙 조합

5.6 정렬 저장하기

Criteria

그나마 괜찮다고 생각한 기능이 있지만

Sort sort = Sort.by("number").ascending().and(Sort.by("orderDate").decending())

이것마저도 QueryDsl은 더 간단하게 기술할 수 있다.

QueryDSL

List<Member> result = queryFactory
 .selectFrom(member)
 .where(member.age.eq(100))
 .orderBy(member.age.desc(), member.username.asc().nullsLast())
 .fetch();

5.7 페이징 처리하기

Spring Data JPA - PageRequest

PageRequest pageReq = PageRequest.of(1, 10);
List<Xxx> Xxxs = XxxDao.findBy("사용자", pageReq);

QueryDSL

List<Member> result = queryFactory
 .selectFrom(member)
 .orderBy(member.username.desc())
 .offset(1) //0부터 시작(zero index)
 .limit(2) //최대 2건 조회
 .fetch();

5.8 스펙 조합을 위한 스펙 빌더 클래스

QueryDSL - BooleanBuilder

@Test
public void XxxService_BooleanBuilder() throws Exception {
    String usernameParam = "member1";
    Integer ageParam = 10;
    List<Member> result = searchMember1(usernameParam, ageParam);
 }

    private List<Member> searchMember1(String usernameCond, Integer ageCond) {
    BooleanBuilder builder = new BooleanBuilder();
    if (usernameCond != null) {
        builder.and(member.username.eq(usernameCond));
    }
    if (ageCond != null) {
        builder.and(member.age.eq(ageCond));
    }
    return queryFactory
    .selectFrom(member)
    .where(builder)
    .fetch();
}

QueryDSL - WhereParam

public void XxxService_WhereParam() throws Exception {
    String usernameParam = "member1";
    Integer ageParam = 10;
    List<Member> result = searchMember2(usernameParam, ageParam);
}

private List<Member> searchMember2(String usernameCond, Integer ageCond) {
    return queryFactory
    .selectFrom(member)
    .where(usernameEq(usernameCond), ageEq(ageCond))
    .fetch();
}
private BooleanExpression usernameEq(String usernameCond) { 
    return usernameCond != null ? member.username.eq(usernameCond) : null;
}
private BooleanExpression ageEq(Integer ageCond) {
    return ageCond != null ? member.age.eq(ageCond) : null;
}

5.9 동적 인스턴스 생성

• Spring Data JPA의 JPQL 일반 조인 + DTO 반환

QueryDsl Version

List<MemberDto> result = queryFactory
 .select(new QMemberDto(member.username, member.age))
 .from(member)
 .fetch();

5.10 하이버네이트 @Subselect 사용

RDBMS의 View 기능을 JPA에서 구현한 것으로 보인다.

그러나 나라면

일반 Join + DTO + @Tx ReadOnly

를 사용할 것 같다.

엄마 vs 아빠 싸움

헛소리 주의

엄마 - 김영한님

• 학원 교습생 때 우연히 마주친 JPA
  • 이 학원이 별나기로 소문남...
  • 그때부터 연구를 함
• 29살 2년간 JPA 책만 작성
• JPA를 먼저 사용한 것은 아니지만 국내에 실질적 보편화를 함
• 인프런 1타 강사
• 책: 350 Page
• 강의: 16 + 7 + 6 + 7 + 6 = 42시간 (분 버림 계산)
• 영한님 책, 추천의 글에 범균님이 있음
  • 즉 의존방향(Dependency Direction)이 범균님 -> 영한님

아빠 - 최범균님

• JPA뿐만 아니라 이것저것 관심이 많음...
• 강의: 대략 21강 * 15분 = 315 = 5시간 15분

결론

제가 영한님을 좋아하는 것은 사실입니다만

아무래도 JPA만큼은 영한님 말씀을 ...

[kdg0209]

CQRS 패턴

• 명령 모델과 조회 모델을 분리하는 패턴

---

Pageable

• findBy 프로퍼티 형식의 메서드는 Pageable 타입을 사용하더라도 반환 타입이 List이면 COUNT 쿼리를 실행하지 않습니다.
• 페이징 처리와 관련된 정보가 필요없다면 반환 타입이 Page가 아닌 List를 사용하여 불필요한 COUNT 쿼리가 실행되지 않도록 할 수 있습니다.
• 다만 스펙을 사용하는 findAll 메서드에 Pageable을 사용하면 반환 타입이 Page가 아니더라도 COUNT 쿼리가 발생하게 됩니다. 이때 스펙을 사용하면서 페이징 처리를 하면서 COUNT 쿼리가 발생하지 않도록 하기 위해서는 스프링 데이터 JPA가 제공하는 커스텀 리포지터리를 사용해서 직접 구현해야 한다고 합니다.

Page<Member> findByUsed(Pageable pageable);
List<Member> findByUsed(Pageable pageable);
List<Member> findAll(Pageable pageable);

---

하이버네이트의 @Subselect

• @Immutable, @Subselect, @Synchronize, @Entity 어노테이션을 사용하여 뷰 용도로 사용할 수 있다고 합니다.
• @Synchronize 어노테이션은 엔티티를 로딩하기 전에 지정한 테이블과 관련된 변경이 발생하면 플러시를 먼저하고 조회하게 됩니다. 그렇기 때문에 최신 값을 가져올 수 있다고 합니다.

Order order = orderRepository.findById(1L);
order.changeShippingInfo(newInfo); // 상태 변경

// 변경 내역이 DB에 반영되지 않았는데 조회
List<OrderSummary> summaries = orderSummary.findByOrdererId(1L);

[developer-wonjin]

5장 리포지토리의 조회기능

5.1. 검색을 위한 스펙

SpringDataJPA를 사용하는 경우

public interface OrderRepository extends JpaRepository<Order, Long>, JpaSpecificationExecutor<Order>{
   //공백   
}

위 소스와 같이 JpaSpecificationExecutor을 상속하는 것만으로 Specification인자를 파라미터로 갖는 메소드를 갖게된다.

T findOne(Specification<T> spec);
List<T> findAll(Specification<T> spec);
Page<T> findAll(Specification<T> spec, Pageable pageable);
List<T> findAll(Specification<T> spec, Sort sort);
long count(Specification<T> spec);

스펙 정의코드

public class OrderSpec{
    public static Specification<Order> memberName(final String memberName){
        return new Specification<Order>(){
            pulbic Predicate toPredicate(Root<Order> root, CriteriaQuery<?> query, CriteriaBuilder builder){
                //Order엔티티에서 시작
                if(StringUtils.isEmpty(memberName))return null;

                Join<Order, Member> m = root.join("member", JoinType.INNER);//Member엔티티 조인
                return builder.equal(m.get("name"), memberName);//입력값 memberName을 갖는 엔티티만 필터링
            }
        };
    }

    public static Specification<Order> isOrderStatus(){
        return new Specification<Order>(){
            public Predicate toPredicate(Root<Order> root, CriteriaQuery<?> query, CriteriaBuilder builder){

                return builder.equal(root.get("status"), OrderStatus.ORDER);
            }
        }
    }
}

스펙을 사용하는 서비스코드

import static OrderSpec.*;

//OrderService
public List<Order> findOrders(String name){
    Specification<Order> spec = where(memberName(name)).and(isOrderStatus());
    List<Order> result = orderRepository.findAll(spec);
}

5.2. 정렬, 페이징

Criteria 에 의존하기 보다 QueryDSL 로 구현하는게 더 나을듯

5.3. 조회전용 기능 구현

• Repository는 애그리거트를 저장, 조회, 삭제하는 것에 초점을 둔 저장소이다.

  • 여러 애그리거트를 로딩해야 하는 경우 => Repository를 이용하는 것은 부적절

  • ID로 참조할 때 장점?이 사라짐

• 동적인스턴스

  Query query = em.createQuery("SELECT m.username, m.age FROM Member m");//두번쨰 인자로 명확한 지정 아닐때
  List<Object[]> resultList = query.getResultList();
  
  //방법1.
  List<UserDTO> userDTOs = new ArrayList<UserDTO>();
  for(Object[] row : resultList){
    UserDTO userDTO = new UserDTO((String)row[0], (Integer)row[1]);
    userDTOs.add(userDTO);
  }
  
  //방법2 (더 나은 방법)
  TypedQuery<UserDTO> query = em.createQuery(
    "SELECT new 패키지.UserDTO(m.username, m.age) FROM Member m", UserDTO.class);
  List<UserDTO> resultList = query.getResultList();

• 하이버네이트의 @SubSelect (DB의 View)

  • 테이블과 맵핑관계를 갖지 않음
  • 쿼리결과와 맵핑관계을 맺음