[Java] JDBC(Java Database Connectivity)란? 예시 코드로 작동 방법 보기

 JDBC: 자바 프로그램에서 관계형 데이터베이스와 연결하여 데이터를 조회, 삽입, 수정, 삭제 등의 작업을 수행할 수 있게 해주는 자바 API

JDBC를 사용하면 다양한 데이터베이스 시스템과 상호작용할 수 있으며, 데이터베이스에 대한 SQL 쿼리를 실행하고 결과를 처리할 수 있다.

 

JDBC 주요 요소

- JDBC 드라이버: JDBC API와 데이터베이스 간의 통신을 담당하며, 데이터베이스 연결, 쿼리 실행 및 결과 처리 등을 수행
- JDBC API: 데이터베이스 연결, 쿼리 실행, 결과 처리, 트랜잭션 관리 등 다양한 작업을 수행할 수 있는 메서드를 제공하는 API(Connection, Statement, ResultSet 등)

 

JDBC 작동 순서

1. JDBC 드라이버 로드
2. 데이터베이스에 연결 (데이터베이스 url, 사용자 이름, 암호 등의 연결 정보 이용) 하기 위해 Connection 객체 생성
3. Connection 객체를 사용해서 Statement 객체 생성
4. Statement 객체를 사용해서 SQL 쿼리문을 실행 -> 결과를 ResultSet 객체에 받음
5. ResultSet 객체를 반복문을 사용해서 결과를 처리
6. 작업이 완료되면 ResultSet, Statement, Connection 등의 리소스를 닫음 (메모리 누수 방지, 데이터베이스 연결 종료)

 

이제 사용되는 과정을 코드로 직접 살펴보자.

밑은 전체 예시 코드이다.

package com.test.jdbc;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

import com.test.member.Member;

public class JDBCConnection {

    public static void main(String[] args) throws ClassNotFoundException, SQLException {

        String uri = "jdbc:mysql://localhost:3306/webdev";
        String userid = "webmaster";
        String userpw = "12345";
        String query = "select userid, username, age from tbl_test order by userid"; //order 안적으면 그냥 오름차순으로 됨
        
        Connection con; //Statement 객체 생성 및 JDBC 연결 종료
        Statement stmt; //ResultSet 객체를 생성
        ResultSet rs; //SQL문 실행 결과를 얻어오는 객체로 현재 데이터의 행(레코드 위치)의 위치를 나타내는 쿼리

        Class.forName("org.mariadb.jdbc.Driver"); //JDBC 드리이버 로딩
        con = DriverManager.getConnection(uri, userid, userpw);
        stmt = con.createStatement();
        rs = stmt.executeQuery(query);
        
        List<Member> list = new ArrayList<>(); //DTO
        
        while(rs.next()) {
            list.add(new Member(rs.getString("userid"), 
                                rs.getString("username"), 
                                rs.getInt("age")));
                
        }

        if(rs != null) rs.close();
        if(stmt != null) stmt.close();
        if(con != null) con.close();
        
        for(Member member: list)
            System.out.println("ID: " + member.getUserid() + 
                              "\nNAME:" + member.getUsername() +
                              "\nAGE: " + member.getAge());
        
    }
    
}

 

코드를 하나하나 살펴보자.

먼저 연결 정보들을 설정해주고, Connection, Statement, ResultSet을 변수로 선언해 준다.

        String uri = "jdbc:mysql://localhost:3306/webdev"; //데이터베이스 url
        String userid = "webmaster"; //사용자 이름
        String userpw = "12345"; //암호
        String query = "select userid, username, age from tbl_test order by userid"; //쿼리문
        
        Connection con; //Connection 변수 선언
        Statement stmt; //Statement 변수 선언
        ResultSet rs; //ResultSet 변수 선언

그럼 이제 JDBC 드라이버가 로드해야 한다. JDBC 드라이버는
MariaDB면 Class.forName("org.mariadb.jdbc.Driver");
MySQL이면 Class.forName("com.mysql.jdbc.Driver");
Oracle이면 Class.forName("oracle.jdbc.driver.OracleDriver");
를 사용하면 된다.

        Class.forName("org.mariadb.jdbc.Driver"); //JDBC 드라이버 로딩

JDBC 드라이버를 로드했으면 데이터베이스에 연결하기 위해 아까 설정한 연결 정보들을 전달한다. 전달할 때는 Connection 객체를 생성해야 한다. DriverManager.getConnection(데이터베이스 링크, 사용자이름, 암호)로 Connection 객체를 생성할 수 있다.

        con = DriverManager.getConnection(uri, userid, userpw);

이렇게 하면 해당 데이터베이스에 보낸 정보들로 접속이 된다.

데이터베이스에 연결된 후에는 Statement 객체를 생성해야 한다. 이때, Connection 객체를 사용해서 .createStatement() 메서드를 통해 생성할 수 있다.

        stmt = con.createStatement();

그럼 이제 Statement 객체를 통해 SQL문을 실행할 수 있다. SQL문과 원하는 결과값에 따라 실행해야 하는 메서드가 다르다.
제일 많이 쓰이는 메서드만 몇 개 소개하자면,
-SELECT 문을 실행한 결과를 가져올 때는 executeQuery()
-INSERT, UPDATE, DELETE문(DML문)을 실행하고 변경된 행의 수를 반환하는 executeUpdate() -> 반환은 int값
-SELECT문이나 DML, DDL문을 실행할 땐 execute() -> SELECT문이면 true 반환, DML, DDL문이면 false 반환

위 예시에서는 select문이고 select한 결과값을 반환하고 싶기 때문에 executeQuery()를 사용했다.

        rs = stmt.executeQuery(query);

그럼 이제 ResultSet 객체에서 반복문으로 데이터를 읽어와야 한다.

우선 이 데이터를 받을 list를 하나 선언해 준다. (Member 객체에 있는 정보들을 받아오므로 List 타입을 Member 객체로 해준다)

        List<Member> list = new ArrayList<>(); //DTO

이제 그 list에 rs의 값을 반복문으로 넣어준다. Member 객체로 받아야 하므로 넣을 때마다 Member 객체를 생성해서 생성된 객체를 list에 추가한다.

        while(rs.next()) {
            list.add(new Member(rs.getString("userid"), 
                                rs.getString("username"), 
                                rs.getInt("age")));
        }

next() 메서드는 다음 행으로 이동해서 다음 행이 존재하면 true, 없으면 false를 반환한다.

데이터를 list에 다 받았으면, 메모리 누수를 막기 위해 ResultSet, Statement, Connection 객체를 닫아준다.

        if(rs != null) rs.close();
        if(stmt != null) stmt.close();
        if(con != null) con.close();

객체가 null이면 닫을 필요가 없기 때문에 null이 아닌 경우에만 close() 메서드로 리소스를 해제해 준다.

이제 list에 잘 담겼는지 확인을 해보면

        for(Member member: list)
            System.out.println("ID: " + member.getUserid() + 
                              "\nNAME:" + member.getUsername() +
                              "\nAGE: " + member.getAge());

이렇게 list에 정보가 잘 담긴 것을 확인할 수 있다.