Log4J コネクションプーリング対応JDBCAppenderでパフォーマンスを向上する

# Logger定義  出力ログレベルと、Appender（=ログ追加先）を設定
log4j.logger.dataSourceLogger=DEBUG, appenderDB

# Appender定義 
log4j.appender.appenderDB=to.msn.wings.codezine.
logging.JDBCConnectionPoolAppender

### Appenderのプロパティ ###
#  JDBCAppenderクラスに存在する属性
log4j.appender.appenderDB.driver=org.hsqldb.jdbcDriver
log4j.appender.appenderDB.URL=jdbc:hsqldb:hsql://localhost
log4j.appender.appenderDB.user=sa
log4j.appender.appenderDB.password=
log4j.appender.appenderDB.sql=INSERT INTO 
    processlog(LOGTIME, LOGLEVEL, MESSAGE) VALUES ('%d', '%p', '%m')
log4j.appender.appenderDB.layout=org.apache.log4j.PatternLayout
log4j.appender.appenderDB.Threshold=DEBUG
log4j.appender.appenderDB.bufferSize=1

### JDBCConnectionPoolAppenderクラスで拡張された属性 ###
log4j.appender.appenderDB.maxActive=10
log4j.appender.appenderDB.maxIdle=2
log4j.appender.appenderDB.minIdle=1
log4j.appender.appenderDB.initialSize=5
log4j.appender.appenderDB.maxWait=1000

public class JDBCConnectionPoolAppender extends JDBCAppender {
    
    // JDBCドライバークラス名
    // JDBCAppenderクラスにはsetDriverメソッドが定義されているのみで
    // インスタンス変数がないので、ここで定義
    protected String driver = null;
        
    // 同時にプールから割り当てられる事ができるコネクションの最大数
    protected int maxActive = 0;
    
    // プールに残すコネクションの最大数
    protected int maxIdle = 0;
    
    // プールに残す最小コネクション数。
    protected int minIdle = 0;
    
    // プール内初期コネクション数。
    protected int initialSize = 0;
    
    // 使用可能なコネクションがプールから取得できない場合の、
    // 例外が投げられるまでの待機時間(ミリ秒)
    protected long maxWait = -1;

    // データソース(コネクションプール)
    // 唯一のインスタンス
    protected static DataSource dataSource = null;

    public void setDriver(String driver) {
        super.setDriver(driver);
        this.driver = driver;
    }

    public void setInitialSize(int initialSize) {
        this.initialSize = initialSize;
    }
        
    public void setMaxActive(int maxActive) {
        this.maxActive = maxActive;
    }
    
    public void setMaxIdle(int maxIdle) {
        this.maxIdle = maxIdle;
    }

    public void setMaxWait(long maxWait) {
        this.maxWait = maxWait;
    }

    public void setMinIdle(int minIdle) {
        this.minIdle = minIdle;
    }

// コネクション取得
protected Connection getConnection() throws SQLException {
    DataSource ds = createDataSource();
    return ds.getConnection();
}

// データソース取得
public DataSource createDataSource(){
    if ( dataSource != null ){
        return dataSource;
    }
    BasicDataSource ds = new BasicDataSource();
    ds.setDriverClassName( driver               );
    ds.setUsername       ( super.getUser()      );
    ds.setPassword       ( super.getPassword()  );
    ds.setUrl            ( super.getURL()       );
    ds.setMaxActive      ( maxActive            );
    ds.setMinIdle        ( minIdle              );
    ds.setMaxIdle        ( maxIdle              );
    ds.setMaxWait        ( maxWait              );
    ds.setInitialSize    ( initialSize          );
    dataSource = ds;     // シングルトンインスタンスに設定
    return ds;
}

    // コネクションクローズ処理
    protected void closeConnection(Connection con) {
        try {
            if ( con != null && !con.isClosed() ) con.close();
        } catch (Exception ex) {
            // do nothing
        }
    }

    // データソースクローズ処理
    public void close() {
        super.close();
        if ( dataSource != null ) {
        try {
            ((BasicDataSource)dataSource).close();

        } catch (Exception ex) {
            // do nothing
    }
}

public class SampleApp {

    static Logger dbLogger = Logger.getLogger( "dataSourceLogger" );
    
    public static void main(String[] args) throws Exception{
        dbLogger.debug( "DEBUG LEVEL" );
        dbLogger.info ( "INFO LEVEL"  );
        dbLogger.warn ( "WARN LEVEL"  );
        dbLogger.error( "ERROR LEVEL" );
        dbLogger.fatal( "FATAL LEVEL" );
    }
}

java -cp lib\hsqldb.jar org.hsqldb.Server -database data/mydb 
-port 9001

java -cp lib\hsqldb.jar org.hsqldb.util.DatabaseManager