서론

서론

JDBC 를 사용한 계기가 있어 DataSource,Connection,Statement,Savepoint 에 대하여 잠깐 정리하고 넘어가려합니다.

JDBC를 이용한 쿼리 사용 예시

JDBC를 이용하여 쿼리를 사용하기 위해서는 아래와 같은 예시를 들어볼 수 있습니다.

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Savepoint;
import java.sql.Statement;

import javax.sql.DataSource;

public class TransactionExample {
  private DataSource dataSource;

  public TransactionExample(DataSource dataSource) {
    this.dataSource = dataSource;
  }

  public void executeTransaction() {
    try (Connection conn = dataSource.getConnection()) {
      // Set auto-commit to false
      conn.setAutoCommit(false);

      // Set savepoint 1
      Savepoint sp1 = conn.setSavepoint();

      // Execute statement 1
      try ( Statement stmt1 = conn.create Statement()) {
        String sql1 = "UPDATE table SET col1 = 2 WHERE col2 = 'a'";
        stmt1.executeUpdate(sql1);
      }

      // Set savepoint 2
      Savepoint sp2 = conn.setSavepoint();

      // Execute statement 2
      try ( Statement stmt2 = conn.createStatement()) {
        String sql2 = "INSERT INTO table (col1, col2) VALUES (3, 'b')";
        stmt2.executeUpdate(sql2);
      }

      // Rollback to savepoint 1
      conn.rollback(sp1);

      // Commit transaction
      conn.commit();
    } catch (SQLException se) {
      // Rollback on error
      conn.rollback();
      se.printStackTrace();
    }
  }
}

자 위 코드를 베이스로 몇가지 키워드에 대하여 알아보겠습니다.

DataSource

private DataSource dataSource;

DataSource 는 쉽개 말해 DB 연결을 하고자할 때 필요한 정보들을 갖고있는 구조체입니다. Db연결을 위한 URL 정보, 접속을 위한 계정정보, 커넥션 풀 사이즈 등등 메타정보를 갖고있습니다.

그리고 그 정보로 부터 Connection 객체를 얻을 수 있도록 도와주는 역할도 포함합니다. 만약 정보가 잘못된 정보 (URL 이 틀리리거나, 접속 정보가 다르거나) 할 경우에 예외도 여기서 발생해줍니다.

사용법

보통은 JavaBean으로 등록하고 사용합니다.

BasicDataSource dataSource = new BasicDataSource();
dataSource.setDriverClassName("org.postgresql.Driver");
dataSource.setUrl("jdbc:postgresql://localhost:5432/mydatabase");
dataSource.setUsername("user");
dataSource.setPassword("password");

위와 같이 등록하고 전역 객체를 활용하는 방식으로 사용됩니다.

Connection

try (Connection conn = dataSource.getConnection()) {
  //~~~
}

DB 연결 객체입니다.

dataSource 에 정의되어있는 DB 정보를 토대로 커넥션을 생성하여 Connection 객체를 얻는 방식이 보편적이며, 커넥션 타임아웃, 트랜잭션, 트랜잭션 커밋, 트랜잭션 롤백 등을 지원합니다.

보통 하나의 트랜잭션에 하나의 Connection 를 생성하고 동일한 트랙잭션 내에서는 Connection를 인자로 넘기면서 공통으로 사용하게 됩니다.

Statement

try ( Statement stmt1 = conn.create Statement()) {
  String sql1 = "UPDATE table SET col1 = 2 WHERE col2 = 'a'";
  stmt1.executeUpdate(sql1);
}

Statement 객체는 쿼리를 실행하고, 결과를 저장하고 확인할 수 있는 객체입니다.

보통 재활용되지 않고 쿼리 실행이 필요할 경우에 바로바로 생성하여 사용합니다. 그 이유는 쿼리 결과를 다중으로 저장하지 않고 직접 쿼리 결과만 저장하기 때문입니다.

Savepoint

트랙잭션 시점 저장을위한 객체입니다.

트랜잭션의 경우 rollback 진행 시 트랜잭션 시작 시점으로 복원되는데, Savepoint 를 이용하여 트랜잭션 시작 시점이 아닌, 트랜잭션 내부에서 원하는 시점으로 rollback을 시도할 수 있게 해줍니다.