ABOUT ME

-

Today
-
Yesterday
-
Total
-
  • [김영한 스프링] 25. 자바 예외 이해 - JDBC 반복 문제 해결(JdbcTemplate)
    Spring/스프링 DB 1편 - 데이터 접근 핵심 원리 2024. 1. 3. 04:39

    JDBC 반복 문제 해결 - JdbcTemplate

     

    지금까지 서비스 계층의 순수함을 유지하기 위해 수많은 노력을 했고, 덕분에 서비스 계층의 순수함을 유지하게 되었다. 이번에는 리포지토리에서 JDBC를 사용하기 때문에 발생하는 반복 문제를 해결해 보자.

     

     

    JDBC 반복 문제

    • 커넥션 조회, 커넥션 동기화
    • PreparedStatement 생성 및 파라미터 바인딩
    • 쿼리 실행
    • 결과 바인딩
    • 예외 발생 시 스프링 예외 변환기 실행
    • 리소스 종료

     

    리포지토리의 각각의 메서드를 살펴보면 상당히 많은 부분이 반복된다. 이런 반복을 효과적으로 처리하는 방법이 바로 템플릿 콜백 패턴이다.

    스프링은 JDBC의 반복 문제를 해결하기 위해 JdbcTemplate이라는 템플릿을 제공한다.

    JdbcTemplate에 대한 자세한 사용법은 뒤에서 설명하겠다. 지금은 전체 구조와, 이 기능을 사용해서 반복 코드를 제거할 수 있다는 것에 초점을 맞추자.

     

     

    MemberRepositoryV5

    package hello.jdbc.repository;
    
    import hello.jdbc.domain.Member;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.jdbc.core.RowMapper;
    
    import javax.sql.DataSource;
    
    /**
     * JdbcTemplate 사용
     */
    @Slf4j
    public class MemberRepositoryV5 implements MemberRepository {
    
        private final JdbcTemplate template;
    
        public MemberRepositoryV5(DataSource dataSource) {
            this.template = new JdbcTemplate(dataSource);
        }
    
        @Override
        public void delete (String memberId) {
    
            String sql = "delete from member where member_id = ?";
    
            template.update(sql, memberId);
        }
    
        @Override
        public void update (String memberId, int money) {
            String sql = "update member set money = ? where member_id = ?";
    
            template.update(sql, money, memberId);
        }
    
        @Override
        public Member findById(String memberId) {
            String sql = "select * from member where member_id = ?";
    
            return template.queryForObject(sql, memberRowMapper(), memberId);
        }
    
        private RowMapper<Member> memberRowMapper() {
            return (rs, rowNum) -> {
                Member member = new Member();
                member.setMemberId(rs.getString("member_id"));
                member.setMoney(rs.getInt("money"));
                return member;
            };
        }
    
        @Override
        public Member save(Member member) {
            String sql = "insert into member(member_id, money) values (?, ?)";
    
            template.update(sql, member.getMemberId(), member.getMoney());
    
            return member;
        }
    }

     

     

    MemberServiceV4Test - 수정

    package hello.jdbc.service;
    
    import hello.jdbc.domain.Member;
    import hello.jdbc.repository.MemberRepository;
    import hello.jdbc.repository.MemberRepositoryV4_2;
    import hello.jdbc.repository.MemberRepositoryV5;
    import lombok.extern.slf4j.Slf4j;
    import org.junit.jupiter.api.AfterEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.springframework.aop.support.AopUtils;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.boot.test.context.TestConfiguration;
    import org.springframework.context.annotation.Bean;
    
    import javax.sql.DataSource;
    import java.sql.SQLException;
    
    import static org.assertj.core.api.Assertions.assertThat;
    import static org.assertj.core.api.Assertions.assertThatThrownBy;
    
    /**
     * 예외 누수 문제 해결
     * SQLException 제거
     * MemberRepository 인터페이스 의존
     */
    @Slf4j
    @SpringBootTest
    class MemberServiceV4Test {
    
        public static final String MEMBER_A = "memberA";
        public static final String MEMBER_B = "memberB";
        public static final String MEMBER_EX = "ex";
    
        @Autowired
        private MemberRepository memberRepository;
        @Autowired
        private MemberServiceV4 memberService;
    
        @TestConfiguration
        static class TestConfig {
            private final DataSource dataSource;
    
            public TestConfig(DataSource dataSource) {
                this.dataSource = dataSource;
            }
    
            @Bean
            MemberRepository memberRepository() {
    //            return new MemberRepositoryV4_1(dataSource);
    //            return new MemberRepositoryV4_2(dataSource);
                return new MemberRepositoryV5(dataSource);
            }
    
            @Bean
            MemberServiceV4 memberServiceV4() {
                return new MemberServiceV4(memberRepository());
            }
        }
    
        @AfterEach
        void after() {
            memberRepository.delete(MEMBER_A);
            memberRepository.delete(MEMBER_B);
            memberRepository.delete(MEMBER_EX);
        }
    
        @Test
        void AopCheck() {
            log.info("memberService class={}", memberService.getClass());
            log.info("memberRepository class={}", memberRepository.getClass());
            assertThat(AopUtils.isAopProxy(memberService)).isTrue();
            assertThat(AopUtils.isAopProxy(memberRepository)).isFalse();
        }
    
        @Test
        @DisplayName("정상 이체")
        void accountTransfer() {
            // given
            Member memberA = new Member(MEMBER_A, 10000);
            Member memberB = new Member(MEMBER_B, 10000);
            memberRepository.save(memberA);
            memberRepository.save(memberB);
    
            // when
            memberService.accountTransfer(memberA.getMemberId(), memberB.getMemberId(), 2000);
    
            // then
            Member findMemberA = memberRepository.findById(memberA.getMemberId());
            Member findMemberB = memberRepository.findById(memberB.getMemberId());
            assertThat(findMemberA.getMoney()).isEqualTo(8000);
            assertThat(findMemberB.getMoney()).isEqualTo(12000);
        }
    
        @Test
        @DisplayName("이체중 예외 발생")
        void accountTransferEx() {
            // given
            Member memberA = new Member(MEMBER_A, 10000);
            Member memberEx = new Member(MEMBER_EX, 10000);
            memberRepository.save(memberA);
            memberRepository.save(memberEx);
    
            // when
            assertThatThrownBy(() -> memberService.accountTransfer(memberA.getMemberId(), memberEx.getMemberId(), 2000))
                    .isInstanceOf(IllegalStateException.class);
    
            // then
            Member findMemberA = memberRepository.findById(memberA.getMemberId());
            Member findMemberB = memberRepository.findById(memberEx.getMemberId());
            assertThat(findMemberA.getMoney()).isEqualTo(10000);
            assertThat(findMemberB.getMoney()).isEqualTo(10000);
        }
    }

    MemberRepository 인터페이스가 제공되므로 등록하는 빈만 MemberRepositoryV5로 변경해서 등록하면 된다.

     

     

    실행

     

    JdbcTemplate은 JDBC로 개발할 때 발생하는 반복을 대부분 해결해 준다. 그뿐만 아니라 지금까지 학습했던, 트랜잭션을 위한 커넥션 동기화는 물론이고, 예외 발생 시 스프링 예외 변환기도 자동으로 실행해 준다.

     

    참고
    템플릿 콜백 패턴에 대해서 지금은 자세히 이해하지 못해도 괜찮다. 스프링이 JdbcTemplate이라는 편리한 기능을 제공하는구나 정도로 이해해도 된다. 템플릿 콜백 패턴에 대한 자세한 내용은 스프링 핵심 원리 - 고급편 강의를 참고하자.

     

     

    정리

    완성된 코드를 확인해 보자.

    • 서비스 계층의 순수성
      • 트랜잭션 추상화 + 트랜잭션 AOP 덕분에 서비스 계층의 순수성을 최대한 유지하면서 서비스 계층에서 트랜잭션을 사용할 수 있다.
      • 스프링이 제공하는 예외 추상화와 예외 변환기 덕분에, 데이터 접근 기술이 변경되어도 서비스 계층의 순수성을 유지하면서 예외도 사용할 수 있다.
      • 서비스 계층이 리포지토리 인터페이스에 의존한 덕분에 향후 리포지토리가 다른 구현 기술로 변경되어도 서비스 계층을 순수하게 유지할 수 있다.
    • 리포지토리에서 JDBC를 사용하는 반복 코드가 JdbcTemplate으로 대부분 제거되었다

     

     

    출처 :  https://www.inflearn.com/course/%EC%8A%A4%ED%94%84%EB%A7%81-db-1

     

    스프링 DB 1편 - 데이터 접근 핵심 원리 강의 - 인프런

    백엔드 개발에 필요한 DB 데이터 접근 기술을 기초부터 이해하고, 완성할 수 있습니다. 스프링 DB 접근 기술의 원리와 구조를 이해하고, 더 깊이있는 백엔드 개발자로 성장할 수 있습니다., 백엔

    www.inflearn.com

Designed by Tistory.