H2 데이터베이스 설치 / 순수 Jdbc

* 인프런 김영한님의 스프링 입문 - 코드로 배우는 스프링 부트, 웹 MVC, DB 접근 기술 강의를 듣고 작성한 내용입니다.

  (강의 링크)

 

이전까지의 방식 메모리에 저장을 했다가 서버가 내려가면 메모리에 있던 것이 모두 사라짐

실무에서는 모두 데이터베이스에 저장해서 관리

스프링 데이터 엑세스

• H2 데이터베이스 설치: 교육용으로 좋은 단순한 데이터베이스
• 순수 Jdbc: 데이터베이스 SQL 활용해서 애플리케이션 서버와 DB 연결할 때 필요한 기술 → Jdbc 
• 스프링 통합 테스트
• 스프링 JdbcTemplate: 순수 Jdbc로 개발이 어려워서 중복 제거한 JdbcTemplate 제공 SQL 편리하게 날릴 수 있음
• JPA: JPA라는 기술이 DB에 등록, 수정, 삭제, 조회 쿼리 모두 날려주는 것 객체를 바로 DB에 쿼리 없이 저장 가능
• 스프링 데이터 JPA: JPA 편리하게 쓸 수 있도록 감싼 기술

DB 실무에서는 MySQL, Oracle 사용

 

H2 데이터베이스 개발이나 테스트 용도로 가볍고 편리한 DB, 웹 화면 제공

최초에는 데이터베이스 파일을 만들어야 함

JDBC URL는 내 파일 경로를 말해준다. home에 있는 test 파일

연결하면 화면으로 이동하고 왼쪽 아이콘 누르면 다시 돌아갈 수 있음.

home에 test.mv.db 파일이 생성되어야 함.

 

데이터베이스 파일 생성 방법

• jdbc:h2:~/test (최초 한번)
• ~/test.mv.db 파일 생성 확인
• 이후부터는 jdbc:h2:tcp://localhost/~/test 이렇게 접속

테이블 생성하기

member 테이블 생성

id java에서는 long DB에서는 bigint, generated by default as identity 값 넣지 않으면 DB가 자동으로 값을 채워줌

MEMBER 누르면 자동으로 SELECT * FROM MEMBER 쿼리문 입력

sql - ddl.sql 파일로 쿼리 관리하는 것이 좋다.

순수 Jdbc

애플리케이션에서 DB에 연동해서 애플리케이션에서 저장하는게 기존처럼 메모리에 저장하는 것이 아니라 DB에서 insert, select 하도록 하는 것.

 

20년 전 방법이므로 필요할 때만 찾아보고 어떻게 데이터가 발전했는지만 정리해두는 것.

 

환경 설정

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

스프링 부트 데이터베이스 연결 설정 추가 resources/application.properties

스프링이 데이터베이스 연결하는 건 모두 끝난 것!

 

Jdbc 리포지토리 구현

주의! 이렇게 JDBC API로 직접 코딩하는 것은 20년 전 이야기이다. 따라서 고대 개발자들이 이렇게 고생하고 살았구나 생각하고, 정신건강을 위해 참고만 하고 넘어가자.

 

Jdbc 회원 리포지토리

package hello.hellospring.repository;
import hello.hellospring.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 {
    private final 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 {
            conn = getConnection();
            pstmt = conn.prepareStatement(sql,
                    Statement.RETURN_GENERATED_KEYS);
            pstmt.setString(1, member.getName());
            pstmt.executeUpdate();
            rs = pstmt.getGeneratedKeys();
            if (rs.next()) {
                member.setId(rs.getLong(1));
            } else {
                throw new SQLException("id 조회 실패");
            }
            return member;
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            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);
            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() {
        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);
    }
}

SpringConfig.java 에서 MemoryMemberRepository를 JdbcMemberRepository로 변경만 하면 DB를 쉽게 바꿀 수 있다.

h2 데이터베이스 켜두고 서버 다시 돌려서 올리면 회원 목록을 눌렀을 때 h2 데이터베이스로 연결되는 것 확인 가능!

객체지향성이 좋은 이유 → 다형성 활용

스프링은 스프링 컨테이너가 지원, DI 덕분에 더 편리하게 활용 가능!

 

스프링의 장점: 기존의 코드는 하나도 손대지 않고 애플리케이션 조립 코드만 변경하면 실제 애플리케이션 관련 코드는 손댈 필요가 없다!

MemberService는 MemvberRepository를 의존하고 있다.

MemberRepository는 구현체로 MemoryMemberRepositoy와 JdbcMemberRepository를 가지고 있다.

스프링 컨테이너에서 바꾼 설정: 기존에는 memory 버전의 memberRepository를 스프링 빈으로 등록했다면 이제는 JDBC 버전의 memberRepository 등록. 구현체만 바뀌어서 코드 돌아감.

 

• 개방-폐쇄 원칙(OCP, Open-Closed Principle): 확장에는 열려있고, 수정, 변경에는 닫혀있다.
  • JDBC 기반의 memberRepository로 변경하였지만 기존 코드는 전혀 손대지 않음
• 스프링의 DI (Dependencies Injection)을 사용하면 기존 코드를 전혀 손대지 않고, 설정만으로 구현 클래스를 변경할 수 있다.
• 회원을 등록하고 DB에 결과가 잘 입력되는지 확인하자.
• 데이터를 DB에 저장하므로 스프링 서버를 다시 실행해도 데이터가 안전하게 저장된다.