[ 스프링 DB 접근 기술 ] H2 데이터베이스 설치 / 순수JDBC

 

 

H2 데이터베이스 설치

 

 

➡️ H2 데이터베이스 : 개발이나 테스트 용도로 가볍고 편리한 DB, 웹 화면 제공
   🔸 https://www.h2database.com/html/main.html

H2 Database Engine

 

➡️ h2 폴더 > bin 폴더 > mac의 경우 h2.sh를 / window의 경우 h2.bat을 실행

 

 

➡️ Mac의 경우 chmod 755 h2.sh로 권한을 준 후 h2.sh실행

 

➡️ Window의 경우 바로 h2.bat 실행 >> 연결 유지

 

 

➡️ 최초의 데이터베이스 파일을 만들기 위한 화면

  🔸접속 안되면 주소의 IP부분을 localhost로 변경해서 접속

  🔸 (http://localhost:8082/login.jsp?jsessionid=8774610c3175514f13954188c7a9b51a)

 

 

➡️연결 후 해당 창 뜨면 Home에 (나의 경우 kangs) test.mv.db 파일 생겼는지 확인

 

 

➡️db파일 확인 후부터는 파일로 접근시 충돌 오류의 위험이 있기 때문에 소켓 통해 접근

  🔸 jdbc:h2:tcp://localhost/~/test

 

 

➡️ CREATE문으로 테이블 생성

  🔸id를 bigint타입으로(생략시 default값 생성) , name을 varchar타입으로, PK는 id로 생성

 

 

➡️ INSERT문으로 데이터 삽입

 

 

➡️ SQL 명령어를 디렉토리 따로 생성해서 보관하면 명령 이력 알 수 있어 개발에 편리성 더해줌 (필수x)

 

➡️ 데이터를 DB에 저장하면 스프링 서버가 꺼졌다 켜져도 데이터가 안전하게 저장

 

 

 

 

순수 JDBC

 

➡️ JDBC API를 JDBC 리포지토리 생성하고, DB 연결해보기

 

➡️ 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();  //이 때 DB에 쿼리가 날아감
            rs = pstmt.getGeneratedKeys();  //Statement.RETURN_GENERATED_KEYS 부분과 매칭돼서 키 가져옴 (id)

            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);
    }
}

 

 

➡️ 기존의 Memory리파지토리에서 새로 생성한 Jdbc 리파지토리로 갈아끼운 후 datasource 생성해서 매개변수 받기

➡️ OCP(Oepn-Closed Principle) : 개방 폐쇄 원칙

  🔸확장에는 열려있고, 수정, 변경에는 닫혀있다

  🔸스프링의 DI(의존성 주입)을 사용하면 기존 코드를 전혀 손대지 않고 설정만으로 구현클래스 변경 가능

  🔸인터페이스를 하나 두고 이를 implements 하는 클래스들을 만들면 갈아 끼우면서 실행 가능(ex : DB)

 

➡️ h2 DB와 연결된 모습 확인 가능