JDBC를 이용한 CRUD 실습

1) JDBC를 이용한 CRUD 실습

 

(1) 초기 설정

 

① 실습 환경

• MySQL 8.0
• JDK 11 (IDE : IntelliJ)
• Spring boot 2.7

 

② 실습 테이블 생성

// 테이블 생성
CREATE TABLE MEMBER (
ID INT not null auto_increment,
NAME VARCHAR(100) not null,
JOB VARCHAR(30) not null,
primary key (ID));

 // 초기 데이터 생성
INSERT INTO MEMBER VALUES (1, "userA", 'Student');
INSERT INTO MEMBER VALUES (2, "userB", 'Student');
INSERT INTO MEMBER VALUES (3, "userC", 'Student');

 

③ application.properties 설정

spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/example?serverTimezone=UTC&characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=root

 

④ dependency in build.gradle 설정

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-jdbc'
    compileOnly 'org.projectlombok:lombok'
    runtimeOnly 'com.mysql:mysql-connector-j'
    runtimeOnly 'com.oracle.database.jdbc:ojdbc8'
    annotationProcessor 'org.projectlombok:lombok'
    testImplementation 'org.springframework.boot:spring-boot-starter-test'
}

 

(2) Create [INSERT] 실습 in CRUD

 

실습 코드

public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // 1. JDBC 드라이버 로드
        Class.forName("com.mysql.cj.jdbc.Driver");

        // DB 접속 정보
        // url은 DBMS 제품마다 Format이 다를 수 있다.
        String url = "jdbc:mysql://localhost:3306/sesac?serverTimezone=Asia/Seoul&characterEncoding=UTF-8";
        String id = "root";
        String pwd = "root";

        // 2. Connection 객체 생성
        Connection conn = DriverManager.getConnection(url, id, pwd);
    conn.setAutoCommit(false);

        // 3. Statement 객체 생성
        Statement stmt = conn.createStatement();

        // 4. Query 실행
        // 5. ResultSet → Select를 통한 조회 쿼리가 아니기 때문에 ResultSet 객체를 이용하지 않는다.
        int result = stmt.executeUpdate("INSERT INTO MEMBER VALUES (4, \"userD\", 'Student');");

        // Query가 제대로 실행된 경우
        if (result == 1) {
            System.out.println("데이터 입력 완료!");
            conn.commit();
        } 

        // Query가 제대로 실행되지 않은 경우
        else {
            System.out.println("데이터 입력 실패!");
            conn.rollback();
        }

        // 6. ResultSet, Statement, Connection 객체 close()
        stmt.close();
        conn.close();
}

 

결과

MySQL [sesac]> select * from member;
+----+-------+---------+
| ID | NAME  | JOB     |
+----+-------+---------+
|  1 | userA | Student |
|  2 | userB | Student |
|  3 | userC | Student |
|  4 | userD | Student |
+----+-------+---------+
4 rows in set (0.000 sec)

 

(3) Read [SELECT] 실습 in CRUD

 

실습 코드

public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // 1. JDBC 드라이버 로드
        Class.forName("com.mysql.cj.jdbc.Driver");

        // DB 접속 정보
        // url은 DBMS 제품마다 Format이 다를 수 있다.
        String url = "jdbc:mysql://localhost:3306/sesac?serverTimezone=Asia/Seoul&characterEncoding=UTF-8";
        String id = "root";
        String pwd = "root";

        // 2. Connection 객체 생성
        Connection conn = DriverManager.getConnection(url, id, pwd);
    conn.setAutoCommit(false);

        // 3. PreparedStatement 객체 생성
        Statement stmt = conn.createStatement();

        // 4. Query 실행
        ResultSet resultSet = stmt.executeQuery("SELECT * FROM MEMBER;");

        // 5. ResultSet 객체로부터 데이터 조회
        while(resultSet.next()) {
            int num = resultSet.getInt("id");
            String name = resultSet.getString("name");
            String job = resultSet.getString("job");
            System.out.println(num + ", " + name + ", " + job);
        }

        // 6. ResultSet, Statement, Connection 객체 close()
        resultSet.close();
        stmt.close();
        conn.close();
}

 

결과

1, userA, Student
2, userB, Student
3, userC, Student
4, userD, Student

 

(4) Update 실습 in CRUD

• 이번 실습부터는 Statement 객체가 아닌 PreparedStatement 객체를 이용한다!

 

실습 코드

public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // 1. JDBC 드라이버 로드
        Class.forName("com.mysql.cj.jdbc.Driver");

        // DB 접속 정보
        // url은 DBMS 제품마다 Format이 다를 수 있다.
        String url = "jdbc:mysql://localhost:3306/sesac?serverTimezone=Asia/Seoul&characterEncoding=UTF-8";
        String id = "root";
        String pwd = "root";

        // 2. Connection 객체 생성
        Connection conn = DriverManager.getConnection(url, id, pwd);
        conn.setAutoCommit(false);

        // 3. PreparedStatement 객체 생성
        String sql = "UPDATE MEMBER SET JOB = ? WHERE JOB = ?";
        PreparedStatement pstmt = conn.prepareStatement(sql);
        pstmt.setString(1, "SalesMan");
        pstmt.setString(2, "Student");

        // 4. Query 실행
        // 5. ResultSet → Select를 통한 조회 쿼리가 아니기 때문에 ResultSet 객체를 이용하지 않는다.
        int result = pstmt.executeUpdate();

        // Query가 제대로 실행된 경우
        if (result >= 1) {
            System.out.println("데이터 입력 완료");
            conn.commit();
        }

        // Query가 제대로 실행되지 않은 경우
        else {
            System.out.println("데이터 입력 실패");
            conn.rollback();
        }

        // 6. ResultSet, Statement, Connection 객체 close()
        pstmt.close();
        conn.close();
}

 

결과

MySQL [sesac]> select * from member;
+----+-------+----------+
| ID | NAME  | JOB      |
+----+-------+----------+
|  1 | userA | SalesMan |
|  2 | userB | SalesMan |
|  3 | userC | SalesMan |
|  4 | userD | SalesMan |
+----+-------+----------+
4 rows in set (0.001 sec)

 

(5) Delete 실습 in CRUD

 

실습 코드

public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // 1. JDBC 드라이버 로드
        Class.forName("com.mysql.cj.jdbc.Driver");

        // DB 접속 정보
        // url은 DBMS 제품마다 Format이 다를 수 있다.
        String url = "jdbc:mysql://localhost:3306/sesac?serverTimezone=Asia/Seoul&characterEncoding=UTF-8";
        String id = "root";
        String pwd = "root";

        // 2. Connection 객체 생성
        Connection conn = DriverManager.getConnection(url, id, pwd);
        conn.setAutoCommit(false);

        // 3. PreparedStatement 객체 생성
        String sql = "DELETE FROM MEMBER WHERE ID = ?";
        PreparedStatement pstmt = conn.prepareStatement(sql);
        pstmt.setInt(1, 4);

        // 4. Query 실행
        // 5. ResultSet → Select를 통한 조회 쿼리가 아니기 때문에 ResultSet 객체를 이용하지 않는다.
        int result = pstmt.executeUpdate();

        // Query가 제대로 실행된 경우
        if (result >= 1) {
            System.out.println("데이터 입력 완료");
            conn.commit();
        }

        // Query가 제대로 실행되지 않은 경우
        else {
            System.out.println("데이터 입력 실패");
            conn.rollback();
        }

        // 6. ResultSet, Statement, Connection 객체 close()
        pstmt.close();
        conn.close();
}

 

결과

MySQL [sesac]> select * from member;
+----+-------+---------+
| ID | NAME  | JOB     |
+----+-------+---------+
|  1 | userA | Student |
|  2 | userB | Student |
|  3 | userC | Student |
+----+-------+---------+
3 rows in set (0.000 sec)

 

[Reference]

• https://yoon990.tistory.com/58
• https://programmingyoon.tistory.com/53

JDBC ! JDBC에서 사용하는 객체 ( DriverManager, Connection, Statment, PrepareStatement, CallableStatement, ResultSet )

[JAVA] JDBC란? 자바에서 JDBC 사용하기 (JAVA + MYSQL)