1. JDBC 이해
애플리케이션 서버와 DB: 일반적인 사용법
- 커넥션 연결: 주로 TCP/IP 사용해서 커넥션을 연결한다.
- SQL 전달: 애플리케이션 서버는 DB가 이해할 수 있는 SQL을 연결된 커넥션을 통해 DB에 전달한다.
- 결과 응답: DB는 전달된 SQL을 수행하고 그 결과를 응답한다. 애플리케이션 서버는 응답 결과를 활용한다.
문제는, 각 위의 1,2,3의 과정, 커넥션 연결과 SQL 전달, 결과 응답의 방법이 데이터베이스 마다 모두 다르다는 점이다.
이로 인해 두가지 문제가 야기되는데,
1. 다른 종류의 DB로 변경 시, 애플리케이션 서버에 개발된 DB 사용 코드도 함께 변경되어야 한다.
2. 개발자가 각 DB마다 다른 연결절차를 모두 새로 학습해야 한다.
JDBC 표준 인터페이스
JDBC(Java Database Connectivity)는 자바에서 데이터베이스에 접속할 수 있도록 하는 자바 API이다. JDBC는 데이터베이스에서 자료를 쿼리하거나 업데이트하는 방법을 제공한다. -위키 백과
3가지 표준 인터페이스
java.sql.Connection연결java.sql.StatementSQL을 담은 내용java.sql.ResultSetSQL 요청 응답
자바에서 이와 같은 표준 인터페이스를 정의해두었고, 각각의 DB 벤더(회사)들이 자신의 DB에 맞게 구현하여 라이버리로 제공하는데, 이것을 JDBC 드라이버라고 한다.
JDBC 개발로 2가지 문제를 해결할 수 있다.
- 다른 종류의 DB로 변경 시, 애플리케이션 서버에 개발된 DB 사용 코드도 함께 변경되어야 한다.
- 애플리케이션 로직이 JDBC 표준 인터페이스에 의존한다. 다른 DB를 사용하더라도 JDBC 구현 라이브러리만 변경하고 애플리케이션 서버 사용 코드를 유지할 수 있다.
- 개발자가 각 DB마다 다른 연결절차를 모두 새로 학습해야 한다.
- 개발자는 JDBC 표준 인터페이스만 학습함으로써 모든 DB에 동일하게 적용할 수 있다.
표준화의 한계
그러나 여전히 SQL, 데이터 타입등의 사용법이 달라 이 부분은 DB에 맞게 반경해야 한다. JPA를 사용하면 이같은 문제도 많은 부분 해결 가능하다.
2. JDBC와 최신 데이터 접근 기술
최근에는 JDBC를 직접 사용하기 보다는 편리하게 사용하는 다양한 기술이 존재한다. 대표적으로 SQL Mapper, ORM 기술로 나눌 수 있다.
SQL Mapper
- 장점: JDBC를 편리하게 사용하도록 도와준다.
- SQL 응답 결과를 객체로 편리하게 변환해준다.
- JDBC의 반복 코드를 제거해준다.
- 단점: 개발자가 SQL을 직접 작성해야 한다.
- 대표 기술: 스프링 JdbcTemplate, MyBatis
ORM 기술
- ORM은 객체를 관계형 DBMS 테이블과 매핑해주는 기술이다. 이 기술 덕분에 개발자는 반복적으로 SQL을 직접 작성하지 않고, ORM기술이 대신 SQL을 동적으로 만들어 실행해준다. 추가로, 각각의 DB마다 다른 SQL을 사용하는 문제도 중간에서 해결해준다.
오.. - 대표기술: JPA, 하이버네이트, 이클립스링크
- JPA는 자바 진영의 ORM 표준 인터페이스고, 이것을 구현한것으로 하이버네이트, 이클립스 링크 등의 구현 기술이 있다.
SQL Mapper vs ORM 기술
SQL Mapper: SQL만 작성할 줄 알면 금방 배워서 사용 가능.
ORM: SQL자체를 작성하지 않아도 돼서 개발 생산성이 매우 높아짐. 다만 쉬운 기술이 아니기에 깊이있는 학습이 필요하다.
중요
내부에는 모두 JDBC를 사용하므로, 작동의 기본 원리는 꼭 알아두어야 한다!
3. 데이터베이스 연결
JDBC 커넥션 인터페이스와 구현
- JDBC는
java.sql.Connection표준 커넥션 인터페이스를 정의한다. - H2 데이터베이스 드라이버는 JDBC Connection 인터페이스를 구현한
org.h2.jdbc.JdbcConnection구현체를 제공한다.
DriverManager 커넥션 요청 흐름
JDBC가 제공하는 DriverManager는 라이브러리에 등록된 DB 드라이버들을 관리하고, 커넥션을 획득하는 기능을 한다.
- 애플리케이션 로직에서 커넥션이 필요하면
DriverManager.getConnection()을 호출한다. - DriverManager는 라이브러리에 등록된 드라이버 목록을 자동으로 인식하고, 이 드라이버들에게 순서대로 정보를 넘겨가며 커넥션을 획득할 수 있는지 확인한다.
- URL: 예)
jdbc:h2:tcp://localhost/~/test - 이름, 비밀번호 등 접속에 필요한 추가 정보
- 각각의 드라이버는 URL 정보를 체크하여 본인이 처리할 수 있는 요청인지 확인한다. 본인이 처리할 수 있으면 실제 DB에 연결해 커넥션을 획득하고 이 커넥션을 클라이언트에게 반환한다. 반면 본인이 처리할 수 없다면 다음 드라버브에게 순서가 넘어간다.
- URL: 예)
- 이렇게 찾은 커넥션 구현체가 클라이언트에게 반환된다.
4. JDBC 개발 - 등록
JDBC를 이용해 회원(Member)데이터를 DB에 관리하는 기능을 개발해보자.
주의! 미리
member테이블을 생성해두어야 한다.
schema.sql
drop table member if exists cascade;
create table member (
member_id varchar(10),
money integer not null default 0,
primary key (member_id)
);Member
package hello.jdbc.domain;
import lombok.Data;
@Data
public class Member {
private String memberId;
private int money;
public Member() {
}
public Member(String memberId, int money) {
this.memberId = memberId;
this.money = money;
}
}MemberRepositoryV0 - 회원 등록
package hello.jdbc.repository;
import hello.jdbc.connection.DBConnectionUtil;
import hello.jdbc.domain.Member;
import lombok.extern.slf4j.Slf4j;
import java.sql.*;
/**
* JDBC - DriverManager 사용
*/
@Slf4j
public class MemberRepositoryV0 {
public Member save(Member member) throws SQLException {
String sql = "insert into member(member_id, money) values(?, ?)";
Connection con = null;
PreparedStatement pstmt = null;
try {
con
= getConnection();
pstmt
= con.prepareStatement(sql);
pstmt.setString(1, member.getMemberId());
pstmt.setInt(2, member.getMoney());
pstmt.executeUpdate();
return member;
} catch (SQLException e) {
log.error("db error", e);
throw e;
} finally {
close(con, pstmt, null);
}
}
private void close(Connection con, Statement stmt, ResultSet rs) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
log.info("error", e);
}
}
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
log.info("error", e);
}
}
if (con != null) {
try {
con.close();
} catch (SQLException e) {
log.info("error", e);
}
}
}
private Connection getConnection() {
return DBConnectionUtil.getConnection();
}
}커넥션 획득
getConnection() 이전에 만들어둔 DBConnectionUtil 를 통해서 데이터베이스 커넥션을 획득한다.
save() - SQL 전달
sql: 데이터베이스에 전달할 SQL을 정의한다. 여기서는 데이터를 등록해야 하므로 insert sql을 준비했다.con.prepareStatement(sql): 데이터베이스에 전달할 SQL과 파라미터로 전달할 데이터들을 준비한다.insert into member(member_id, money) values(?, ?)pstmt.setString(1, member.getMemberId()): SQL의 첫번째 ? 에 값을 지정한다. 문자이므로 setString 을 사용한다.pstmt.setInt(2, member.getMoney()): SQL의 두번째 ? 에 값을 지정한다. Int형 숫자이므로 setInt 를 지정한다.
pstmt.executeUpdate():Statement를 통해 준비된 SQL을 커넥션을 통해 실제 데이터베이스에 전달한다. 참고로executeUpdate()은 int를 반환하는데 영향받은 DB row 수를 반환한다. 여기서는 하나의 row를 등록했으므로 1을 반환한다.
executeUpdate
int executeUpdate() throws SQLException;리소스 정리
- 쿼리 실행후에는 꼭! 리소스를 정리해야 한다.
- 예외가 발생하든, 하지 않든 항상 수행되어야 하므로
finally구
문에 주의해서 작성해야한다
-정리가 제대로 이루어지지 않으면 커넥션이 끊어지지 않고 계속 유지되는 문제가 발생할 수 있다. 이런 것을 리소스 누수라고 하는데, 결과적으로 커넥션 부족으로 장애가 발생할 수 있다.
- 예외가 발생하든, 하지 않든 항상 수행되어야 하므로
- 리소스 정리 시, 항상 역순으로 시행한다.
- 여기서는 Connection을 먼저 획득하고 Connection을 통해 PreparedStatement 를 만들었기 때문에 리소스를 반환할 때는 PreparedStatement를 먼저 종료하고, 그 다음에 Connection을 종료하면 된다.
PreparedStatement
Statement의 자식 타입- ?를 통한 파라미터 바인딩을 시행해준다.
- SQL Injection 공격을 예방하려면
PreparedStatement를 통한 파라미터 바인딩 방식을 사용해야 한다. (String으로 취급하여 그곳에 SQL문이 삽입되는 것을 방어할 수 있다.)
MemberRepositoryV0Test - 회원 등록
package hello.jdbc.repository;
import hello.jdbc.domain.Member;
import org.junit.jupiter.api.Test;
import java.sql.SQLException;
class MemberRepositoryV0Test {
MemberRepositoryV0 repository = new MemberRepositoryV0();
@Test
void crud() throws SQLException {
//save
Member member = new Member("memberV0", 10000);
repository.save(member);
}
}5. JDBC 개발 - 조회
6. JDBC 개발 - 수정, 삭제
Good Luck!