cpdspool.java

来自「Jodd是一个开源的公用Java基础类库」· Java 代码 · 共 51 行

package jodd.db.pool;

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

import javax.sql.ConnectionPoolDataSource;
import javax.sql.PooledConnection;

/**
 * Wrapper arroung ConnectionPoolDataSource implementation.
 */
public class CpdsPool implements ConnectionPool {

	// ---------------------------------------------------------------- properties

	private ConnectionPoolDataSource cpds;
	public void setPool(ConnectionPoolDataSource p) {
		cpds = p;
	}

	// ---------------------------------------------------------------- init/close

	public void init() throws SQLException {
		if (cpds == null) {
			throw new SQLException("ConnectionPoolDataSource not specified");
		}
	}

	public void close() {
		cpds = null;
	}

	// ---------------------------------------------------------------- get/free

	public Connection getConnection() throws SQLException {
		PooledConnection pconn = cpds.getPooledConnection();
        return pconn.getConnection();
	}

	public void freeConnection(Connection conn) {
		try {
			if (conn != null) {
				conn.close();
			}
		} catch (SQLException e) {
		}
	}

}