Source code and usage of custom Connection Pool 1. Store basic database connection bean package bsc.pool; import java.sql. *; Import java.io.serializable;
/ ** *
Title: *
Description: *
Copyright: Copyright (c) 2003 *
Company: * @ Author unascribed * @version 1.0 * /
Public class connbean implements java.io.serializable {
private Connection conn = null; private boolean inuse = false; public ConnBean () {} public ConnBean (Connection con) {if (con = null!) conn = con;} public void setConnection (Connection con) {conn = con;} public Connection getConnection () {return conn;} public void setInuse (boolean inuse) {this.inuse = inuse;} public boolean getInuse () {return inuse;} public void close () {try {conn.close ();} Catch (Sqlexception SQLE) {system.err.println (Sqle.getMessage ());}}} 2. Connection pool management bean
Package bsc.pool; import java.sql. *; import java.util. *; import java.lang.InterruptedException; import java.io.serializable;
Import bsc.pool.connbean; / ** *
Title: *
Description: *
Copyright: Copyright (c) 2003 *
Company : * @Author unascribed * @version 1.0 * /
Public Class PoolBean Implements Java.io.Serializable {
private String driver = null; private String url = null; private int size = 0; private String username = ""; private String password = ""; private ConnBean connBean = null; private Vector pool = null; private String dbType = "1 "; Public poolbean () {} public void setdriver (String D) DRIVER = D;} public string getDriver () {Return Driver;} public void seturl (String u) {ix (u! = NULL) URL = u;} public string geturl () {return url;} public void setsize (int S) {if (s> 1) size = s;} public int getSize () {Return size;} public void setUsername (String un) {if (un = null!) username = un;} public String getUsername () {return username;} public void setPassword (String pwd) {if (! pwd = null) password = pwd;} public String getPassword () {RETURN Password;} public void setConnbean (connbean cb) {IF (cb! = Null) connbean = cb;} public connbean getConnbean () throws exception {connection {Connecti On con = GetConnection (); connbean cb = new connbean (con); cb.setinuse (true); Return CB;
} Private Connection createConnection () throws Exception {Connection con = null; con = DriverManager.getConnection (url, username, password); return con;} public synchronized void initializePool () throws Exception {if (driver == null) throw new Exception ("No driver name!"); If (url == null) throw new exception ("No URL!"); If (size <1) throw new Exception ("Connection pool size cannot be less than one!") Try {// drivermanager.registerdriver (new com.ibm.db2.jdbc.app.db2driver ()); class.forname (driver) .newinstance (); for (int i = 0; i }}} Catch (Exception E) {system.err.println (E.getMessage ()); throw new exception (E.getMessage ());} } Private void addconnection (connbean cb) {if (pool == null) pool = new vector (size); pool.addelement (cb);} Public synchronized void releaseConnection (Connection Con) {for (int i = 0; i Public synchronized void EmptyPool () {for (int i = 0; i
