[TIL] JDBC로 DB(MySQL) 연결해서 사용하기 - SELECT, INSERT 예제 / java.sql.SQLException: Column count doesn't match value count at row 숫자.

[210131]

오늘 저녁에는 어제에 이어서 JDBC로 MySQL DB 연결을 연습해 보았다!

(SELECT 와 INSERT)

TIL

JDBC를 이용한 DB(MySQL) 연결해 사용하기

- SELECT, INSERT문

*링크1, 링크2를 참조하며 연습한 예제입니다. 감사합니다🙇‍♂️
특히 링크1 중심으로 따라한 것이 많은 도움이 되었습니다.

(MySQL connector가 준비되어 있다는 전제 하에 실행가능한 예제입니다)

JDBC로 DB(MySQL) 연결해 사용하기

1. import java.sql.*;

2. 드라이버 가져오기 - MySQL Connector
   Class.forName("com.mysql.jdbc.Driver");

3. MySQL연결을 위한 Connection객체 생성
   String url = "jdbc:mysql://localhost/DB명";
connection = DriverManager.getConnection(url, "DB사용자ID", "DB사용자PW");

4. Statement / PreparedStatement 객체 생성

   (아래 connection은 Connection객체)

   • Statement statement = connection.createStatement();

     • 정적인 쿼리문, 즉 파라미터를 입력받지 않는 쿼리문일 때 사용

     주로 SELECT 쿼리에 사용함.

   • PreparedStatement preparedstatement = connection.prepareStatement();

     • 동적인 쿼리문, 즉 파라미터를 입력받아 사용하는 쿼리문일 때 사용

     주로 INSERT, UPDATE, DELETE 쿼리에 사용함.

     (*PreparedStatement : 쿼리를 준비하는 Statement라는 의미. 입력값을 필요로 하므로.)

5. SQL쿼리 수행 (execute)

   • executeQuery(SQL문) : SELECT 처럼 리턴값이 필요한 쿼리문일 때 사용
     • Statement.executeQuery()
     • PreparedStatement.executeQuery()
     • 리턴타입 : ResultSet 객체 - 쿼리 결과로 리턴된 DB 레코드들이 담겨 있다.
       ResultSet = statement.executeQuery(sql);와 같이 사용.
       resultSet.next() : boolean을 리턴함 - 다음 레코드가 존재하면 true 리턴.
   • executeUpdate() : INSERT, UPDATE, DELETE 처럼 리턴값이 필요 없는 쿼리문일 때 사용
     • Statement.executeUpdate()
     • PreparedStatement.executeUpdate
     • 리턴값 없음

6. 리소스 반납

   필요한 나머지 로직들을 수행한 후,
   finally블록에서 .close()로 JDBC 연결 과정에 필요했던 객체들을 반납함.
   (객체를 생성한 역순으로 반납함)

   • Connection.close()
   • Statement.close()
   • PreparedStatement.close()
   • ResultSet.close()

SELECT문 예제

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class SelectMySQL {
    public static void main(String[] args) {
        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;

        try {
            // 1. connector (드라이버) 로딩
            // ClassNotFoundException 발생 가능 - try-catch 로 예외처리 필요.
            Class.forName("com.mysql.jdbc.Driver");

            // 2. DB(MySQL)와 연결
            // SQLException 발생 가능 - try-catch 로 예외처리 필요.
            String url = "jdbc:mysql://localhost/DB명";
            connection = DriverManager.getConnection(url, "DB사용자ID", "DB사용자PW");

            // 3. 쿼리 수행을 위한 Statement 객체 생성
            // (Statement 객체 : 쿼리를 실행할 수 있는 객체)
            // *정적인 쿼리문은 Statement statement = conn.createStatement();
            // *동적인 쿼리문은 PreparedStatement preparedstatement = conn.prepareStatement();
            // (동적인 쿼리문 = 파라미터를 입력받는 쿼리문)
            statement = connection.createStatement();

            // 4. SQL 쿼리 작성
            // 주의 1. JDBC에서 쿼리 작성시 ;를 빼고 작성함.
            // 주의 2. SELECT 할 때 *로 가져오는 것보다, 가져올 컬럼을 지정하는 것이 좋음.
            // 주의 3. 쿼리로 결과값만 가져오고, java코드로 후작업하는 것은 좋지 않음.
            // 주의 4. 쿼리는 가급적 한 줄로 작성. 줄을 나눌 시, 띄어쓰기에 유의.
            String sql = "SELECT nickname, money FROM user_log";

            // 5. SQL 쿼리 수행
            // 작성한 SQL 쿼리를 Statement.executeQuery()의 인자로 전달해 호출하면 쿼리가 실행됨.
            // 리턴타입 : ResultSet 객체 - 쿼리 결과의 레코드들이 담겨 있다.
            // DB의 레코드들은 ResultSet 객체에 추가된다.
            resultSet = statement.executeQuery(sql);

            // 6. 실행 결과 출력
            // (일반적으로 결과 조회를 위해서는 VO객체를 사용함(키워드 - DAO, VO)
            while (resultSet.next()) {
                // 주의 - DB 레코드들의 칼럼은 0이 아닌 1부터 시작한다.
                // resultSet.next()는 boolean을 리턴함 - 다음 레코드가 존재하면 true 리턴

                String nickname = resultSet.getString(1);
                int money = resultSet.getInt(2);
                // DB에서 가져오는 데이터 타입에 맞게 getString() 또는 getInt() 등을 호출한다.

                System.out.println(nickname + " : " + money);
            }
            // 결과 : MySQL의 user 데이터베이스, user_log 테이블에서 nickname(String)과 money(int)를 가져와 출력함.
        } catch (ClassNotFoundException e) {
            System.out.println("드라이버 로딩 실패");
        } catch (SQLException e) {
            System.out.println("에러 " + e);
        }
        finally {
            // Connection, Statement, ResultSet 객체를 닫는 코드.
            // isClosed(), close()는 SQLException 발생 가능 - try-catch로 예외처리.
            try {
                if (connection != null && !connection.isClosed()) {
                    // Connection이 존재하고, 닫혀있지 않다면
                    connection.close();
                }
                if (statement != null && !statement.isClosed()) {
                    statement.close();
                }
                if (resultSet != null && !resultSet.isClosed()) {
                    resultSet.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

INSERT문 예제

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class InsertMySQL {
    public static void main(String[] args) {
        insert(13 ,"robbins", 3100, "2021-01-31 00:00:00");
    }

    public static void insert(int id, String nickname, int money, String last_visit) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;

        try {
            // 1. connector(드라이버) 로딩.
            // ClassNotFoundException 발생 가능 - 예외처리 필요.
            Class.forName("com.mysql.jdbc.Driver");

            // 2. DB와 연결하기 -  connection = DriverManager.getConnection()
            // SQLException 발생 가능 - 예외처리 필요.
            String url = "jdbc:mysql://localhost/DB명";
            connection = DriverManager.getConnection(url, "DB사용자ID", "DB사용자PW");

            // 3. 쿼리 수행을 위한 PreparedStatement 객체 생성
            // INSERT로 추가하는 데이터 값은 보통 파라미터를 통해 동적 할당되는 값이므로,
            // Statement.createStatement()가 아닌 PreparedStatement.prepareStatement()를 사용함.
            // (쿼리를 준비하는 statement라는 의미)
            // prepareStatement()는 PreparedStatement 객체를 반환하며,
            // 이 객체에는 PreparedStatement.setString()으로 동적으로 값을 할당할 수 있음.
            // PreparedStatement 메소드들은 SQLException 발생 가능 - 예외처리 필요.
            String sql = "INSERT INTO user_log VALUES (?,?,?,?)";
            preparedStatement = connection.prepareStatement(sql);

            // 4. 데이터 binding - sql문의 각 요소에 파라미터 값을 할당해줌
            preparedStatement.setInt(1, id);
            preparedStatement.setString(2, nickname);
            preparedStatement.setInt(3, money);
            preparedStatement.setString(4, last_visit);

            // 5. 쿼리 실행 및 결과 처리
            // SELECT와 달리 INSERT는 반환 데이터가 없으므로 ResultSet 객체가 필요 없음.
            // 따라서 바로 PreparedStatement.executeUpdate()메서드를 호출함.
            // INSERT, UPDATE, DELETE 쿼리 : PreparedStatement.executeUpdate()를 사용하며,
            //   (쿼리의 결과, 즉 리턴값이 없는 경우)
            // SELECT 쿼리 : Statement.executeQuery()를 사용함.
            //   (쿼리의 결과, 즉 리턴값이 있는 경우)
            // 리턴타입 : int (몇 개의 row에 영향을 미쳤는지를 반환함)
            int count = preparedStatement.executeUpdate();
            if (count == 0) {
                System.out.println("데이터 입력 실패");
            } else {
                System.out.println("데이터 입력 성공");
            }
        } catch (ClassNotFoundException e) {
            System.out.println("드라이버 로딩 실패");
        } catch (SQLException e) {
            System.out.println("에러 " + e);
        }
        finally {
            // Connection, PreparedStatement 객체를 닫는 코드.
            // isClosed(), close()는 SQLException 발생 가능 - try-catch로 예외처리.
            try {
                if (connection != null && !connection.isClosed()) {
                    // Connection이 존재하고, 닫혀있지 않다면
                    connection.close();
                }
                if (preparedStatement != null && !preparedStatement.isClosed()) {
                    preparedStatement.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

---

java.sql.SQLException: Column count doesn't match value count at row 숫자

위의 INSERT문 예제를 하다가 발생한 에러.

MySQL 테이블의 컬럼과 INSERT한 데이터의 수가 맞지 않을 때 발생하는 에러라고 한다.

해결 ) MySQL내에서 AUTO-INCREMENT 로 설정한 컬럼에 대해서도 INSERT 값을 지정해 주어야 했다.