JDBC (Java Database Connectivity) 란?
- JDBC는 DB에 접근할 수 있도록 Java에서 제공하는 API이다.
- 모든 Java의 Data Access 기술의 근간
- 즉, 모든 Persistence Framework는 내부적으로 JDBC API를 이용한다.
- 자바는 DBMS(Oracle, MySQL, MongoDB 등)의 종류에 상관 없이 하나의 JDBC API를 이용해서 데이터베이스 작업을 처리합니다.
- JDBC는 데이터베이스에서 자료를 쿼리하거나 업데이트하는 방법을 제공한다.
- JDBC는 DB에 접근해서 CRUD를 쉽고 효율적이게 할 수 있게 하고, 고성능에서의 세련된 메소드를 제공하며 쉽게 프로그래밍 할 수 있게 도와줍니다.
- JDBC 의 역할은 아래와 같이 정리할 수 있다.
- Java 코드에서 DB서버에 접속
- SQL문을 구성하고 DB서버에서 실행
- DB서버에서 처리한 결과를 가져오기
- DB의 정보를 가져오기
java.sql. 패키지
- java.sql.Connection**
- DB와의 연결 정보를 가지는 Interface.
- java.sql.Statement
- query를 DB에 전송하는 방법을 정의한 Interface
- java.sql.ResultSet
- SELECT문을 통해 결과를 조회하는 방법을 정의한 Interface
- 이외에도 다양한 패키지가 존재한다.
JDBC 개발단계
- JDBC Driver loading
- 데이터베이스 벤더에 맞는 드라이버를 호출한다.
- 데이터베이스와의 연결을 위해 드라이버를 로딩한다.
- Connection
- DB와 연결을 위해 URL과 계정정보가 필요하다.
- DriverManager.getConnection(url, id, pwd)
- Statement/PreparedStatement
- SQL 구문을 정의하고 변경 될 값을 치환문자를 이용해서 쿼리 전송 전에 값을 setting한다.
- executeUpdate() or executeQuery()
- executeUpdate() : SQL Query문이 INSERT, DELETE, UPDATE의 경우에 사용한다.
- executeQuery() : SQL Query문이 SELECT의 경우에 사용합니다. 반환값의 타입은 ResultSet 다.
- ResultSet (SELECT 의 경우)
- 데이터베이스 조회 결과집합에 대한 표준이다.
- next()를 통해 DB의 table안의 row한 줄을 불러옵니다.
- getString(), getInt() 를 통해 한 행의 특정 Column 값을 가져 옵니다.
- close()
- Connection, Statement, ResultSet에 대해 close 를 해줍니다.
JDBC 코드 예시
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);
}
}
- 위의 코드만 봐도 현재 내가 얼마나 편하게 개발을 하고 있는지 알 수 있다.
- 여하튼 위의 코드가 예전 순수하게 JDBC를 사용해서 개발했을 당시 코드이다.
References