BoneCP による JDBC コネクション・プーリングの利用

import java.sql.Connection;
import java.sql.SQLException;

import com.jolbox.bonecp.BoneCP;
import com.jolbox.bonecp.BoneCPConfig;

public class MyBoneCPApp {


  private BoneCP bcp = null;
  private String driverClassName = "com.mysql.jdbc.Driver";
  private String username = "root";
  private String password = "";
  private String url = "jdbc:mysql://localhost/test";
  
  public void init() throws ClassNotFoundException, SQLException {
    Class.forName(driverClassName);
     BoneCPConfig config = new BoneCPConfig();
     config.setJdbcUrl(url);
    config.setUsername(username);
    config.setPassword(password);
    config.setMinConnectionsPerPartition(5);
    config.setMaxConnectionsPerPartition(10);
    config.setPartitionCount(1);
    config.setDefaultAutoCommit(false);
    config.setDefaultReadOnly(false);
    config.setDefaultTransactionIsolation("READ_COMMITTED");
    
    bcp = new BoneCP(config);    
  }
  
  public Connection getConnection() throws SQLException {
    Connection conn = null;
    if (bcp != null) {
      conn = bcp.getConnection();
      System.out.println("Created("+bcp.getTotalCreatedConnections() + "), " 
            + "Free(" + bcp.getTotalFree() + "), "
            + "Leased(" + bcp.getTotalLeased()+")");
    }
    
    return conn;
  }
  
  public void shutdown() {
    if (bcp != null) {
      bcp.shutdown();
    }
  }
  
  /**
   * 
   * @param args
   */
  public static void main(String[] args) {
    MyBoneCPApp app =  new MyBoneCPApp();
    try {
      app.init();
      long start = System.currentTimeMillis();
      for (int i=0; i<100; i++) {
        Connection conn = app.getConnection();        
        conn.close();
      }
      long end = System.currentTimeMillis();      
      System.out.println((end - start) + " millis");
    } catch (SQLException e) {
      e.printStackTrace();
    } catch (ClassNotFoundException e) {
      e.printStackTrace();
    } finally {
      app.shutdown();
    }
  }

}

ただし、ベンチマーク結果を見ると複数パーティションによる大きなメリットは見受けられないようで、基本的に１パーティションで利用すれば問題無いようです。

最後に BoneCPConfig オブジェクトをコンストラクタに渡して BoneCP インスタンスを生成すれば準備完了。

getConnection() メソッドでは後述する DBCP との違いを比較出来るようプーリングのステータスを標準出力しています。

DBCP による JDBC コネクション・プーリングの利用

DBCP は Apache Commons プロジェクトで再利用可能な Java コンポーネントとして開発されているコネクション・プーリング用ライブラリ。

DBCP - Overview

詳しい説明は割愛しますが、数多くのアプリケーションで利用されていますよね。

commons-dbcp-1.4.jar, commons-pool-1.6.jar の他に JDBC ドライバ を要すればＯＫ。

今回 BoneCP と比較する DBCP コードはこちら。

import java.sql.Connection;
import java.sql.SQLException;

import org.apache.commons.dbcp.BasicDataSource;

public class MyDbcpApp {

  private BasicDataSource db = null;
  private String driverClassName = "com.mysql.jdbc.Driver";
  private String username = "root";
  private String password = "";
  private String url = "jdbc:mysql://localhost/test";
  
  public void init() {
    db = new BasicDataSource();
    db.setDriverClassName(driverClassName);
    db.setUsername(username);
    db.setPassword(password);
    db.setUrl(url);
    db.setMaxActive(10);
    db.setMaxIdle(10);
    db.setMinIdle(5);
    db.setDefaultAutoCommit(false);
    db.setDefaultReadOnly(false);
    db.setDefaultTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
  }
  
  public Connection getConnection() throws SQLException {
    Connection conn = null;
    if (db != null) {
      conn = db.getConnection();
      System.out.println(
          "Active(" + db.getNumActive() + "), Idle(" + db.getNumIdle() + ")");
    }
    
    return conn;
  }
  
  public void shutdown() {
    if (db != null && db.getNumIdle() > 0) {
      try {
        db.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }
  
  /**
   * @param args
   */
  public static void main(String[] args) {
    MyDbcpApp app = new MyDbcpApp();
    app.init();
    try {
      long start = System.currentTimeMillis();
      for (int i=0; i<100; i++) {
        Connection conn = app.getConnection();
        conn.close();
      }
      long end = System.currentTimeMillis();      
      System.out.println((end - start) + " millis");
    } catch (SQLException e) {
      e.printStackTrace();
    } finally {
      app.shutdown();
    }
  }

}

BoneCP と同様 init() メソッドを用意、この中で BasicDataSource オブジェクトを生成、初期化しています。

getConnection() メソッドでは Active, Idle 数を標準出力。

これで BoneCP と DBCP を比較する準備が出来ました。

BoneCP vs. DBCP - DBコネクション生成とその性能比較

・・・
Active(1), Idle(0)
Active(1), Idle(0)
Active(1), Idle(0)
375 millis

・・・
Created(5), Free(4), Leased(1)
Created(5), Free(4), Leased(1)
Created(5), Free(4), Leased(1)
7 millis

Active(1), Idle(0)
Active(1), Idle(0)
Active(1), Idle(0)

Created(5), Free(4), Leased(1)
Created(5), Free(4), Leased(1)
Created(5), Free(3), Leased(2)
Created(5), Free(4), Leased(1)
Created(5), Free(3), Leased(2)