JDBC 기본 사용법

DriverManager를 이용한 연결

DriverManager 클래스는 JDBC 드라이버를 관리하고 데이터베이스와의 연결을 설정하는 데 사용된다.

1. 드라이버 로드:
   • 먼저 JDBC 드라이버를 메모리에 로드한다.

try {
    Class.forName("com.mysql.cj.jdbc.Driver"); // MySQL 드라이버 로드
} catch (ClassNotFoundException e) {
    e.printStackTrace();
}

 

 

데이터베이스 연결

• DriverManager.getConnection() 메소드를 사용하여 데이터베이스와의 연결을 설정한다.

 

예제코드

String url = "jdbc:mysql://localhost:3306/mydatabase?serverTimezone=Asia/Seoul";
String user = "root";
String password = "mypassword";

try {
    Connection connection = DriverManager.getConnection(url, user, password);
    System.out.println("MySQL 데이터베이스에 성공적으로 연결되었습니다!");
} catch (SQLException e) {
    e.printStackTrace();
}

 

 

 

Connection 객체 사용법

Connection 객체는 데이터베이스와의 연결을 나타내며, SQL 쿼리를 실행하고 트랜잭션을 관리하는 데 사용된다.

 

1. SQL 쿼리 실행 준비

• Connection 객체를 사용하여 SQL 쿼리를 실행할 Statement, PreparedStatement 객체를 생성할 수 있다.

Statement statement = connection.createStatement();

 

 

2. 트랜잭션 관리

• Connection 객체를 사용하여 트랜잭션을 수동으로 관리할 수 있다.

connection.setAutoCommit(false); // 자동 커밋 비활성화

 

3. 연결 닫기

• 작업이 끝난 후에는 Connection 객체를 닫아야 한다.

connection.close();

 

 

 

SQL 쿼리 실행

1. Statement 객체 사용

Statement 객체는 SQL 쿼리를 실행하고 결과를 받아오는 데 사용된다.

 

SQL 쿼리 실행

• executeQuery() 메소드: SELECT 쿼리를 실행하고 결과를 반환한다.
• executeUpdate() 메소드: INSERT, UPDATE, DELETE 쿼리를 실행하고 영향을 받은 행의 수를 반환한다.

Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM users");

while (resultSet.next()) {
    System.out.println("User ID: " + resultSet.getInt("id"));
    System.out.println("User Name: " + resultSet.getString("name"));
}

int rowsAffected = statement.executeUpdate("INSERT INTO users (name) VALUES ('John Doe')");
System.out.println("Rows affected: " + rowsAffected);

 

 

 

2. PreparedStatement 객체 사용

PreparedStatement 객체는 미리 컴파일된 SQL 문을 실행하는 데 사용된다. 이는 성능을 향상시키고 SQL 인젝션 공격을 방지하는 데 도움이 된다.

 

SQL 쿼리 준비 및 실행

• setXXX() 메소드를 사용하여 파라미터를 설정한다.

String sql = "INSERT INTO users (name) VALUES (?)";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, "John Doe");
int rowsAffected = preparedStatement.executeUpdate();
System.out.println("Rows affected: " + rowsAffected);

sql = "SELECT * FROM users WHERE id = ?";
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setInt(1, 1);
ResultSet resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
    System.out.println("User ID: " + resultSet.getInt("id"));
    System.out.println("User Name: " + resultSet.getString("name"));
}