クラス org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager

org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManagerに対する継承グラフ

[凡例]org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManagerのコラボレーション図

[凡例]すべてのメンバ一覧

---

説明

This connection manager uses a pool of persistent connections with the database. The allocation/release policy is implemented by the subclasses (abstract org.objectweb.cjdbc.controller.connection.AbstractConnectionManager#getConnection()/ org.objectweb.cjdbc.controller.connection.AbstractConnectionManager#releaseConnection(Connection) from org.objectweb.cjdbc.controller.connection.AbstractConnectionManager).

作者:

Emmanuel Cecchet

Mathieu Peltier

バージョン:

1.0

AbstractPoolConnectionManager.java の 48 行で定義されています。

Public メソッド
	AbstractPoolConnectionManager (String backendUrl, String backendName, String login, String password, String driverPath, String driverClassName, int poolSize)
synchronized void	initializeConnections () throws SQLException
synchronized void	initializeConnections (int initPoolSize) throws SQLException
synchronized void	finalizeConnections () throws SQLException
int	getCurrentNumberOfConnections ()
Protected 変数
transient Stack	freeConnections
transient Vector	activeConnections
int	poolSize

---

コンストラクタとデストラクタ

org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.AbstractPoolConnectionManager (  String  backendUrl, String  backendName, String  login, String  password, String  driverPath, String  driverClassName, int  poolSize )

Creates a new AbstractPoolConnectionManager instance. 引数: backendUrl  URL of the DatabaseBackend owning this connection manager. backendName  name of the DatabaseBackend owning this connection manager. login  backend connection login to be used by this connection manager. password  backend connection password to be used by this connection manager. driverPath  path for driver driverClassName  class name for driver poolSize  size of the connection pool. AbstractPoolConnectionManager.java の 88 行で定義されています。 参照先 org.objectweb.cjdbc.common.log.Trace.debug(), と org.objectweb.cjdbc.common.log.Trace.isDebugEnabled(). { super(backendUrl, backendName, login, password, driverPath, driverClassName); if (poolSize < 1) throw new IllegalArgumentException( "Illegal value for size of the pool connection manager: " + poolSize); this.poolSize = poolSize; this.freeConnections = new Stack(); this.activeConnections = new Vector(poolSize); this.initialized = false; if (logger.isDebugEnabled()) logger.debug(Translate.get("connection.backend.pool.created", new String[]{backendName, String.valueOf(poolSize)})); }

---

メソッド

synchronized void org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.finalizeConnections (   )  throws SQLException [virtual]

参照: org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.finalizeConnections() org.objectweb.cjdbc.controller.connection.AbstractConnectionManagerを実装しています. org.objectweb.cjdbc.controller.connection.VariablePoolConnectionManagerで再定義されています。 AbstractPoolConnectionManager.java の 185 行で定義されています。 { if (!initialized) { String msg = Translate.get("connection.pool.not.initialized"); logger.error(msg); throw new SQLException(msg); } Connection c; boolean error = false; // Close free connections initialized = false; int freed = 0; while (!freeConnections.isEmpty()) { c = (Connection) freeConnections.pop(); try { c.close(); } catch (SQLException e) { error = true; } freed++; } if (logger.isInfoEnabled()) logger.info(Translate.get("connection.freed.connection", new String[]{ String.valueOf(freed), backendUrl})); // Close active connections int size = activeConnections.size(); if (size > 0) { logger.warn(Translate.get("connection.connections.still.active", size)); for (int i = 0; i < size; i++) { c = (Connection) activeConnections.get(i); try { c.close(); } catch (SQLException e) { error = true; } } } // Clear connections to ensure that the eventually not closed connections // will be closed when the objects will be garbage collected freeConnections.clear(); activeConnections.clear(); if (error) { String msg = Translate.get("connection.free.connections.failed"); logger.error(msg); throw new SQLException(msg); } }

int org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.getCurrentNumberOfConnections (   )  [virtual]

参照: org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.getCurrentNumberOfConnections() org.objectweb.cjdbc.controller.connection.AbstractConnectionManagerを実装しています. AbstractPoolConnectionManager.java の 252 行で定義されています。 { return poolSize; }

synchronized void org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.initializeConnections (  int  initPoolSize  )  throws SQLException

Initialize initPoolSize connections in the pool. 引数: initPoolSize  number of connections to initialize 例外: SQLException  if an error occurs AbstractPoolConnectionManager.java の 126 行で定義されています。 { if (initialized) throw new SQLException("Connection pool for backend '" + backendUrl + "' already initialized"); if (initPoolSize > poolSize) { logger.warn(Translate.get("connection.max.poolsize.reached", new String[]{String.valueOf(initPoolSize), String.valueOf(poolSize), String.valueOf(poolSize)})); initPoolSize = poolSize; } Connection c = null; boolean connectionsAvailable = true; int i = 0; while ((i < initPoolSize) && connectionsAvailable) { c = getConnectionFromDriver(); if (c == null) connectionsAvailable = false; if (!connectionsAvailable) { if (i > 0) { logger.warn(Translate.get("connection.limit.poolsize", i)); } else { logger.warn(Translate.get("connection.initialize.pool.failed")); poolSize = 0; } } else { freeConnections.push(c); i++; } } poolSize = i; initialized = true; if (poolSize == 0) // Should never happen logger.error(Translate.get("connection.empty.pool")); if (logger.isDebugEnabled()) logger.debug(Translate.get("connection.pool.initialized", new String[]{ String.valueOf(initPoolSize), backendUrl})); }

synchronized void org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.initializeConnections (   )  throws SQLException [virtual]

参照: org.objectweb.cjdbc.controller.connection.AbstractConnectionManager.initializeConnections() org.objectweb.cjdbc.controller.connection.AbstractConnectionManagerを実装しています. org.objectweb.cjdbc.controller.connection.VariablePoolConnectionManagerで再定義されています。 AbstractPoolConnectionManager.java の 115 行で定義されています。 { initializeConnections(poolSize); }

---

変数

transient Vector org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.activeConnections [protected]

Pool of currently used connections (Vector type because synchronisation is needed). AbstractPoolConnectionManager.java の 64 行で定義されています。

transient Stack org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.freeConnections [protected]

Stack of available connections (pool). AbstractPoolConnectionManager.java の 58 行で定義されています。

int org.objectweb.cjdbc.controller.connection.AbstractPoolConnectionManager.poolSize [protected]

Size of the connection pool with the real database. AbstractPoolConnectionManager.java の 67 行で定義されています。

---

このクラスの説明は次のファイルから生成されました:

• src/org/objectweb/cjdbc/controller/connection/AbstractPoolConnectionManager.java

---