[스프링 DB 2편] #8. 데이터 접근 기술 - 활용 방안

[YONGHYNG]

스프링 데이터 JPA 예제와 트레이드 오프

클래스 의존 관계

• 중간에서 JpaItemRepositoryV2가 어댑터 역할을 해준 덕분에 ItemService가 사용하는 ItemRepository 인터페이스를 그대로 유지하고, 클라이언트인 ItemService의 코드를 변경하지 않아도 되는 장점이 있음

다른 선택

• ItemService 코드 일부 고쳐서 직접 스프링 데이터 JPA를 사용
• DI, OCP 원칙을 포기하는 대신, 복잡한 어댑터 제거, 구조를 단순하게 가져가는
  장점이 있음

• ItemService에서 스프링 데이터 JPA로 만든 리포지토리를 직접 참조, 물론 이 경우 ItemService 코드를 변경해야 함

런타임 객체 의존 관계

트레이드 오프

• 이것이 바로 트레이드 오프, DI, OCP를 지키기 위해 어댑터 도임, 더 많은 코드 유지
• 어댑터를 제거하고 구조를 단순하게 갖가지만, DI, OCP를 포기하고 ItemService 코드를 직접 변경함

복잡한 쿼리 분리

• ItemRepositoryV2는 스프링 데이터 JPA의 기능을 제공하는 리포지토리
• ItemQueryRepositoryV2는 QueryDSL을 사용해서 복잡한 쿼리 기능을 제공

ItemRepositoryV2

package hello.itemservice.repository.v2;
import hello.itemservice.domain.Item;
import org.springframework.data.jpa.repository.JpaRepository;

public interface ItemRepositoryV2 extends JpaRepository<Item, Long> {
}

• ItemRepositoryV2는 JpaRepository를 인터페이스 상속 받아서 스프링 데이터 JPA 기능을 제공하는 리포지토리가 됨
• 기본 CRUD 이 기능을 사용하면 됨

ItemQueryRepositoryV2

package hello.itemservice.repository.v2;

import com.querydsl.core.types.dsl.BooleanExpression;
import com.querydsl.jpa.impl.JPAQueryFactory;
import hello.itemservice.domain.Item;
import hello.itemservice.repository.ItemSearchCond;
import org.springframework.stereotype.Repository;
import org.springframework.util.StringUtils;

import javax.persistence.EntityManager;
import java.util.List;

import static hello.itemservice.domain.QItem.item;

/**
 * Spring Data JPA + QueryDSL을 활용, 상품 데이터를 동적으로 조회
 * 사용자가 입력한 검색 조건에 맞춰 조건부 검색을 수행하는 기능 담당
 * */

/**
 * @Repository : Spring의 리포지토리 빈으로 등록
 * QueryDSL 기반의 쿼리 전용 리포지토리 역할 수행
 * JPA의 EntityManager를 활용해 JPQL 대신 QueryDSL로 동적 쿼리 작성
 * */
@Repository
public class ItemQueryRepositoryV2 {

    //QueryDSL 사용 위한 JPAQueryFactory 선언
    private final JPAQueryFactory query;

    public ItemQueryRepositoryV2(EntityManager em){
        this.query = new JPAQueryFactory(em);
    }

    /**
     * query.select(item) : Item 엔티티를 조회
     * .fetch() : 쿼리 실행 후 결과를 리스트로 반환
     * ItemSearchCond 객체를 입력, 해당 조건에 맞는 모든 상품 Item 리스트로 반환
     * */
    public List<Item> findAll(ItemSearchCond cond){
        return query.select(item)
                .from(item)
                .where(
                        maxPrice(cond.getMaxPrice()),
                        likeItemName(cond.getItemName()))
                                .fetch();
    }

    /**
     * StringUtils.hasText(itemName) : 값이 비어 있거나 null 이면 null 반환 -> QueryDSL에서 null 무시
     * itemName이 비어 있지 않다면 해당 단어가 포함된 상품을 찾도록 조건 추가
     * */
    private BooleanExpression likeItemName(String itemName){
        if (StringUtils.hasText(itemName)) {
            return item.itemName.like("%" + itemName + "%");
        }
        return null;
    }

    /**
     * item.price.loe(maxPrice) : SQL의 where price <= maxPrice 동일
     * maxPrice == null 이면 null 반환 -> QueryDSL 에서 null 무시
     * 
     * */
    private BooleanExpression maxPrice(Integer maxPrice){
        if (maxPrice != null) {
            return item.price.loe(maxPrice);
        }
        return null;
    }
}

• ItemQueryRepositoryV2 는 QueryDSL 사용 복잡한 쿼리 문제 해결
• QueryDSL을 사용한 쿼리 문제에 집중
• 복잡한 쿼리는 이 부분만 유지보수 하면 되는 장점이 있음

ItemServiceV2

package hello.itemservice.service;

import hello.itemservice.domain.Item;
import hello.itemservice.repository.ItemSearchCond;
import hello.itemservice.repository.ItemUpdateDto;
import hello.itemservice.repository.v2.ItemQueryRepositoryV2;
import hello.itemservice.repository.v2.ItemRepositoryV2;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

import javax.transaction.Transactional;
import java.util.List;
import java.util.Optional;


/**
 * @Service
 * Spring의 서비스 컴포넌트로 등록, 비즈니스 로직을 담당하는 클래스 의미
 *
 * @RequiredArgsConstructor
 * final 필드에 대해 자동으로 생성자 주입 생성
 * ItemRepositoryV2와 ItemQUeryRepositoryV2를 주입
 *
 * @Transactional
 * 모든 메서드가 트랜잭션 범위 내에서 실행
 * 읽기/쓰기 작업 원자성 보장하도록 관리
 * */
@Service
@RequiredArgsConstructor
@Transactional
public class ItemServiceV2 implements ItemService{

    //JPA의 기본 CRUD 기능을 담당하는 Spring Data JPA Repository
    private final ItemRepositoryV2 itemRepositoryV2;

    //QueryDSL을 이용해 동적 검색 기능을 제공하는 쿼리 전용 리포지토리
    private final ItemQueryRepositoryV2 itemQueryRepositoryV2;

    @Override
    public Item save(Item item){//상품 저장
        return itemRepositoryV2.save(item);
    }

    @Override
    /**
     * findById(itemId)를 호출하여 DB에서 해당 상품 조회
     * 상품이 존재하지 않으면 orElseThrow() 통해 예외 발생
     * findItem은 영속성 컨텍스트가 관리하는 엔티티 객체
     * 해당 엔티티의 필드를 변경하면 트랜잭션이 종료될 때 JPA가 자동으로 update 쿼리 실행
     * */
    public void update(Long itemId, ItemUpdateDto updateParam){//상품 수정
        Item findItem = findById(itemId).orElseThrow();
        findItem.setItemName(updateParam.getItemName());
        findItem.setPrice(updateParam.getPrice());
        findItem.setQuantity(updateParam.getQuantity());
    }

    @Override
    public Optional<Item> findById(Long id){ //상품 ID로 조회
        return itemRepositoryV2.findById(id);
    }

    @Override
    public List<Item> findItems(ItemSearchCond cond){ //조건에 맞는 상품 검색
        return itemQueryRepositoryV2.findAll(cond);
    }
}

V2Config

package hello.itemservice.config;
import hello.itemservice.repository.ItemRepository;
import hello.itemservice.repository.jpa.JpaItemRepositoryV3;
import hello.itemservice.repository.v2.ItemQueryRepositoryV2;
import hello.itemservice.repository.v2.ItemRepositoryV2;
import hello.itemservice.service.ItemService;
import hello.itemservice.service.ItemServiceV2;
import lombok.RequiredArgsConstructor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.persistence.EntityManager;


/**
 * 이 클래스는 Spring의 설정 클래스
 * JPA 기반의 리포지토리와 서비스 객체를 Spring 빈으로 등록하는 역할
 * */

/**
 * @Congifuration
 * Spring이 설정 클래스임을 인식하도록 지정
 * @Bean 메서드 사용, 직접 객체를 생성하고 빈으로 등록 가능
 *
 * @RequiredArgsConstructor
 * final 필드에 대해 생성자 자동 생성
 * EntityManager와 ItemRepositoryV2 주입 받음
 * */


@Configuration
@RequiredArgsConstructor
public class V2Config {
    
    //JPA 엔티티 매니저
    private final EntityManager em;
    private final ItemRepositoryV2 itemRepositoryV2; //SpringDataJPA
    
    @Bean
    public ItemService itemService() {
        return new ItemServiceV2(itemRepositoryV2, itemQueryRepository());
    }
    
    @Bean
    public ItemQueryRepositoryV2 itemQueryRepository() {
        return new ItemQueryRepositoryV2(em);
    }
    
    @Bean
    public ItemRepository itemRepository() {
        return new JpaItemRepositoryV3(em);
    }
}

실행 흐름 정리

• Spring이 V2Config 클래스를 읽어 @configuration 설정 확인
• @bean 메서드들을 실행하여 빈을 생성 및 등록
• itemService() -> ItemServiceV2 등록
• itemQueryRepository() -> ItemQueryRepositoryV2 등록
• itemRepository() -> JpaItemRepositoryV3 등록
• Spring 컨테이너에서 서비스와 리포지토리를 주입, 애플리케이션 실행

JpaTransactionManager의 다양한 지원

• JpaTransactionManager는 놀랍게도 DataSourceTransactionManager 가 제공하는 기능도 대부분 제공, JPA라는 기술도 결국 내부에서는 DataSource와 JDBC 커넥션도 사용하기 떄문, 따라서 JdbcTemplate, myBatis 와 함께 사용할 수 있음
• 즉, JpaTransactionManager를 하나만 스프링 빈에 등록하면 JPA, JdbcTemplate,
  MyBatis 모두를 하나의 트랜잭션으로 묶어서 사용 가능

정리

• ItemServiceV2는 스프링 데이터 JPA를 제공, ItemRepositoryV2도 참조, QueryDSL과 관련된 ItemQueryRepositoryV2도 직접 참조
• 덕분에 ItemRepositoryV2를 통해서 스프링 데이터 JPA 기능 사용,
  ItemQueryRepositoryV2를 통해서 복잡한 쿼리를 QueryDSL로 해결 할 수 있음
• 이렇게 하면 구조와 복잡함 없이 단순하게 개발 가능

[6om1n]

오 !! 다시 빠르게 올려주시네용 감사합니당 ~~ 👍

[YONGHYNG]

맞습니다~ 짝짝짝 2025년 1월 7일 (화) 오후 11:15, 박보민 ***@***.***>님이 작성:

…

오 !! 다시 빠르게 올려주시네용 감사합니당 ~~ 👍 — Reply to this email directly, view it on GitHub <#600 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AZVBIAM6R4HSHCHAD5UQ5C32JPOQZAVCNFSM6AAAAABUTYXLIKVHI2DSMVQWIX3LMV43URDJONRXK43TNFXW4Q3PNVWWK3TUHMYTCNZWGE3TCNI> . You are receiving this because you authored the thread.Message ID: ***@***.*** com>