[Spring][혼공] 6. 스프링 DB 접근 기술 - (2) 순수 JDBC

스프링 DB 접근 기술

2. 순수 JDBC

이번 글은 `아주 오래전에는 이렇게 JDBC API를 직접 코딩했구나` 정도로만 참고로 알아두자

 

1) 환경 설정

• build.gradle 파일에 jdbc, h2 데이터베이스 관련 라이브러리 추가

build.gradle

• 스프링 부트에 데이터베이스 연결 설정 추가
  • url은 이전 글에 설치한 h2의 url을 입력하면 된다.
  • 만약 driver class name 입력 시 빨간 글씨로 노출된다면, build.gradle를 다시 로드하면 된다.

resources/application.properties

 

2) Jdbc 리포지토리 구현

package hello.hello.spring.repository;

import hello.hello.spring.domain.Member;
import org.springframework.jdbc.datasource.DataSourceUtils;

import javax.sql.DataSource;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;

public class JdbcMemberRepository implements MemberRepository {

    // DB에 접근하기 위해 필요하다.
    private final DataSource dataSource;

    // application.properties에서 DataSource 설정하면
    // 스프링이 관련 DataSource를 생성하고 주입해준다.
    public JdbcMemberRepository(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    @Override
    public Member save(Member member) {
        String sql = "insert into member(name) values(?)";

        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null; // 결과를 저장한다.

        try {
            // getConnection(): DB의 Connection을 가져온다.
            conn = getConnection();
            // RETURN_GENERATED_KEYS: DB의 id 값을 얻어올 떄 사용한다.
            pstmt = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);

            // 인덱스 1이 (?)와 매칭이 되면서 member.getName()을 (?)에 넣는다.
            pstmt.setString(1, member.getName());

            // executeUpdate(): DB에 쿼리를 넘긴다.
            pstmt.executeUpdate();
            // getGeneratedKeys(): DB의 id 값을 반환한다.
            rs = pstmt.getGeneratedKeys();

            if (rs.next()) { // DB의 id 값이 있다면
                member.setId(rs.getLong(1));
            } else {
                throw new SQLException("id 조회 실패");
            }
            return member;
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            // 사용한 자원들 바로 release 해야 한다.
            close(conn, pstmt, rs);
        }
    }

    @Override
    public Optional<Member> findById(Long id) {
        String sql = "select * from member where id = ?";

        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;

        try {
            conn = getConnection();
            pstmt = conn.prepareStatement(sql);

            pstmt.setLong(1, id);

            // executeQuery(): DB에 쿼리를 넘긴다. (조회)
            rs = pstmt.executeQuery();

            if (rs.next()) {
                Member member = new Member();
                member.setId(rs.getLong("id"));
                member.setName(rs.getString("name"));
                return Optional.of(member);
            } else {
                return Optional.empty();
            }
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            close(conn, pstmt, rs);
        }
    }

    @Override
    public List<Member> findAll() {
        String sql = "select * from member";

        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;

        try {
            conn = getConnection();
            pstmt = conn.prepareStatement(sql);

            rs = pstmt.executeQuery();

            List<Member> members = new ArrayList<>();
            while (rs.next()) {
                Member member = new Member();
                member.setId(rs.getLong("id"));
                member.setName(rs.getString("name"));
                members.add(member);
            }
            return members;
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            close(conn, pstmt, rs);
        }
    }

    @Override
    public Optional<Member> findByName(String name) {
        String sql = "select * from member where name = ?";

        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;

        try {
            conn = getConnection();
            pstmt = conn.prepareStatement(sql);

            pstmt.setString(1, name);

            rs = pstmt.executeQuery();

            if (rs.next()) {
                Member member = new Member();
                member.setId(rs.getLong("id"));
                member.setName(rs.getString("name"));
                return Optional.of(member);
            }
            return Optional.empty();
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            close(conn, pstmt, rs);
        }
    }

    private Connection getConnection() {
        // dataSource를 통해 직접 getConnection()를 할수도 있지만,
        // 그렇게 사용한다면 새로운 Connection을 계속해서 생성하게 된다.
        return DataSourceUtils.getConnection(dataSource);
    }

    private void close(Connection conn, PreparedStatement pstmt, ResultSet rs) {
        try {
            if (rs != null) {
                rs.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            if (pstmt != null) {
                pstmt.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            if (conn != null) {
                close(conn);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private void close(Connection conn) throws SQLException {
        DataSourceUtils.releaseConnection(conn, dataSource);
    }
}

 

3) 새로운 리포지토리 연결

• MemberRepository 인터페이스의 새로운 구현체를 생성한다.
• 데이터를 DB에 저장하므로 스프링 서버를 다시 실행해도 데이터가 안전하게 저장된다.

리포지토리 클래스

• 객체 지향의 다형성 특성
• 개방-폐쇄 원칙(OCP, Open-Closed Principle): 확장에는 열려있고 수정, 변경에는 닫혀있다.
• 스프링 DI을 사용하면 기존 코드를 전혀 손대지 않고 설정만으로 구현 클래스를 변경할 수 있다.

스프링 컨테이너

• DataSource는 데이터베이스 커넥션을 획득할 때 사용하는 객체다.
• 스프링 부트는 데이터베이스 커넥션 정보를 바탕으로 DataSource를 생성하고 스프링 빈으로 만들어둔다.
• 그래서 DataSource도 DI를 받을 수 있다.

package hello.hello.spring;

import hello.hello.spring.repository.JdbcMemberRepository;
import hello.hello.spring.repository.MemberRepository;
import hello.hello.spring.repository.MemoryMemberRepository;
import hello.hello.spring.service.MemberService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;

@Configuration
public class SpringConfig {

    private DataSource dataSource;

    @Autowired
    public SpringConfig(DataSource dataSource){
        this.dataSource = dataSource;
    }

    @Bean
    public MemberService memberService() {
        return new MemberService(memberRepository());
    }

    @Bean
    public MemberRepository memberRepository() {
        //return new MemoryMemberRepository();
        return new JdbcMemberRepository(dataSource);
    }
}

 

4) 결과

• 웹 페이지를 통해 가입한다.

http://localhost:8080/members/new

• DB 데이터를 확인하면 같은 이름을 가진 member가 조회된다.

H2 콘솔