* {@link #prepareStatement} メソッドは毎回新たな {@link PreparedStatement}
* を生成せず、未使用のステートメントのプールから {@link PreparedStatement} を取り出します。
* 返された {@link PreparedStatement} の {@link PreparedStatement#close}
* メソッドは実際にはステートメントをクローズせず、プールに自身を戻します。({@link PoolablePreparedStatement} を参照)
* {@primary My {@link #prepareStatement} methods, rather than creating a new {@link PreparedStatement}
* each time, may actually pull the {@link PreparedStatement} from a pool of unused statements.
* The {@link PreparedStatement#close} method of the returned {@link PreparedStatement} doesn't
* actually close the statement, but rather returns it to my pool. (See {@link PoolablePreparedStatement}.)}
*
* @see PoolablePreparedStatement
* @author Rodney Waldhoff (rwaldhof@us.britannica.com)
* @translator 日置 聡
* @status firstdraft
* @update 2003/09/20
*/
public class PoolingConnection extends DelegatingConnection implements Connection, KeyedPoolableObjectFactory {
/** {@link PreparedStatement} のプールです。 {@primary My pool of {@link PreparedStatement}s.} */
protected KeyedObjectPool _pstmtPool = null;
/**
* コンストラクタ。 {@primary Constructor.}
* @param c 内部に保持する {@link Connection}.
* {@primary the underlying {@link Connection}.}
*/
public PoolingConnection(Connection c) {
super(c);
}
/**
* コンストラクタ。 {@primary Constructor.}
* @param c 内部に保持する {@link Connection}.
* {@primary the underlying {@link Connection}.}
* @param maxSleepingPerKey プール内にアイドル状態で保持される {@link PreparedStatement} の最大数 (タイプ毎)
* {@primary the maximum number of {@link PreparedStatement}s that may sit idle in my pool (per type)}
*/
public PoolingConnection(Connection c, KeyedObjectPool pool) {
super(c);
_pstmtPool = pool;
}
/**
* プール内の {@link PreparedStatement} をクローズ、開放し、内部に保持するコネクションをクローズします。
* {@primary Close and free all {@link PreparedStatement}s from my pool, and
* close my underlying connection.}
*/
public synchronized void close() throws SQLException {
if(null != _pstmtPool) {
KeyedObjectPool oldpool = _pstmtPool;
_pstmtPool = null;
try {
oldpool.close();
} catch(RuntimeException e) {
throw e;
} catch(SQLException e) {
throw e;
} catch(Exception e) {
throw new SQLException(e.toString());
}
}
getInnermostDelegate().close();
}
/**
* プールから {@link PreparedStatement} を生成、または取得します。
* {@primary Create or obtain a {@link PreparedStatement} from my pool.}
* @return {@link PoolablePreparedStatement}
* {@primary a {@link PoolablePreparedStatement}}
*/
public synchronized PreparedStatement prepareStatement(String sql) throws SQLException {
try {
return(PreparedStatement)(_pstmtPool.borrowObject(createKey(sql)));
} catch(RuntimeException e) {
throw e;
} catch(Exception e) {
throw new SQLException(e.toString());
}
}
/**
* プールから {@link PreparedStatement} を生成、または取得します。
* {@primary Create or obtain a {@link PreparedStatement} from my pool.}
* @return {@link PoolablePreparedStatement}
* {@primary a {@link PoolablePreparedStatement}}
*/
public synchronized PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
try {
return(PreparedStatement)(_pstmtPool.borrowObject(createKey(sql,resultSetType,resultSetConcurrency)));
} catch(RuntimeException e) {
throw e;
} catch(Exception e) {
throw new SQLException(e.toString());
}
}
/**
* 渡された引数から PoolingConnection.PStmtKey を生成します。
* {@primary Create a {@link PoolingConnection.PStmtKey} for the given arguments.}}
*/
protected Object createKey(String sql, int resultSetType, int resultSetConcurrency) {
return new PStmtKey(normalizeSQL(sql),resultSetType,resultSetConcurrency);
}
/**
* 渡された引数から PoolingConnection.PStmtKey を生成します。
* {@primary Create a {@link PoolingConnection.PStmtKey} for the given arguments.}}
*/
protected Object createKey(String sql) {
return new PStmtKey(normalizeSQL(sql));
}
/**
* 渡されたSQLステートメントを標準化し、元と同じ意味を持つ標準的なフォームを生成します。
* {@primary Normalize the given SQL statement, producing a
* cannonical form that is semantically equivalent to the original.}
*/
protected String normalizeSQL(String sql) {
return sql.trim();
}
/**
* {@link PreparedStatement} を生成するための {@link KeyedPoolableObjectFactory} インターフェイスのメソッドです。
* {@primary My {@link KeyedPoolableObjectFactory} method for creating
* {@link PreparedStatement}s.}
* @param obj {@link PreparedStatement} を生成するためのキー
* {@primary the key for the {@link PreparedStatement} to be created}
*/
public Object makeObject(Object obj) {
try {
if(null == obj || !(obj instanceof PStmtKey)) {
throw new IllegalArgumentException();
} else {
// _openPstmts++;
PStmtKey key = (PStmtKey)obj;
if(null == key._resultSetType && null == key._resultSetConcurrency) {
return new PoolablePreparedStatement(getDelegate().prepareStatement(key._sql),key,_pstmtPool,this);
} else {
return new PoolablePreparedStatement(getDelegate().prepareStatement(key._sql,key._resultSetType.intValue(),key._resultSetConcurrency.intValue()),key,_pstmtPool,this);
}
}
} catch(Exception e) {
throw new DbcpException(e);
}
}
/**
* {@link PreparedStatement} を破棄するための {@link KeyedPoolableObjectFactory} インターフェイスのメソッドです。
* {@primary My {@link KeyedPoolableObjectFactory} method for destroying
* {@link PreparedStatement}s.}
* @param key 無視されます
* {@primary ignored}
* @param obj 破棄する {@link PreparedStatement}
* {@primary the {@link PreparedStatement} to be destroyed.}
*/
public void destroyObject(Object key, Object obj) {
//_openPstmts--;
try {
((DelegatingPreparedStatement)obj).getInnermostDelegate().close();
} catch(SQLException e) {
// ignored
} catch(NullPointerException e) {
// ignored
} catch(ClassCastException e) {
try {
((PreparedStatement)obj).close();
} catch(SQLException e2) {
// ignored
} catch(ClassCastException e2) {
// ignored
}
}
}
/**
* {@link PreparedStatement} をチェックするための {@link KeyedPoolableObjectFactory} インターフェイスのメソッドです。
* {@primary My {@link KeyedPoolableObjectFactory} method for validating}
* {@link PreparedStatement}s.}
* @param key 無視されます
* {@primary ignored}
* @param obj 無視されます
* {@primary ignored}
* @return true
*/
public boolean validateObject(Object key, Object obj) {
return true;
}
/**
* {@link PreparedStatement} をアクティブにするための {@link KeyedPoolableObjectFactory} インターフェイスのメソッドです。
* 現状では何も行いません。
* {@primary My {@link KeyedPoolableObjectFactory} method for activating
* {@link PreparedStatement}s. (Currently a no-op.)}
* @param key 無視されます
* {@primary ignored}
* @param obj {@link PreparedStatement}
* {@primary ignored}
*/
public void activateObject(Object key, Object obj) {
((DelegatingPreparedStatement)obj).activate();
}
/**
* {@link PreparedStatement} を非活性化するための {@link KeyedPoolableObjectFactory} インターフェイスのメソッドです。
* 現状では {@link PreparedStatement#clearParameters} を行います。
* {@primary My {@link KeyedPoolableObjectFactory} method for passivating
* {@link PreparedStatement}s. Currently invokes {@link PreparedStatement#clearParameters}.}
* @param key 無視されます
* {@primary ignored}
* @param obj {@link PreparedStatement}
* {@primary a {@link PreparedStatement}}
*/
public void passivateObject(Object key, Object obj) {
try {
((PreparedStatement)obj).clearParameters();
((DelegatingPreparedStatement)obj).passivate();
} catch(SQLException e) {
// ignored
} catch(NullPointerException e) {
// ignored
} catch(ClassCastException e) {
// ignored
}
}
public String toString() {
return "PoolingConnection: " + _pstmtPool.toString();
}
/**
* 各特有の {@link PreparedStatement} を認識するためのキーです。
* {@primary A key uniquely identifiying {@link PreparedStatement}s.}
*/
class PStmtKey {
protected String _sql = null;
protected Integer _resultSetType = null;
protected Integer _resultSetConcurrency = null;
PStmtKey(String sql) {
_sql = sql;
}
PStmtKey(String sql, int resultSetType, int resultSetConcurrency) {
_sql = sql;
_resultSetType = new Integer(resultSetType);
_resultSetConcurrency = new Integer(resultSetConcurrency);
}
public boolean equals(Object that) {
try {
PStmtKey key = (PStmtKey)that;
return( ((null == _sql && null == key._sql) || _sql.equals(key._sql)) &&
((null == _resultSetType && null == key._resultSetType) || _resultSetType.equals(key._resultSetType)) &&
((null == _resultSetConcurrency && null == key._resultSetConcurrency) || _resultSetConcurrency.equals(key._resultSetConcurrency))
);
} catch(ClassCastException e) {
return false;
} catch(NullPointerException e) {
return false;
}
}
public int hashCode() {
return(null == _sql ? 0 : _sql.hashCode());
}
public String toString() {
StringBuffer buf = new StringBuffer();
buf.append("PStmtKey: sql=");
buf.append(_sql);
buf.append(", resultSetType=");
buf.append(_resultSetType);
buf.append(", resultSetConcurrency=");
buf.append(_resultSetConcurrency);
return buf.toString();
}
}
}