一个通用的连接池Bean

王朝java/jsp·作者佚名  2006-01-09
窄屏简体版  字體: |||超大  

//连接Bean

ConnectionBean.java

package com.pool;

import java.io.Serializable;

import java.sql.*;

public class ConnectionBean implements java.io.Serializable

{

private Connection vConnection=null;

private boolean bUseState=false;

public ConnectionBean(){}

public ConnectionBean(Connection connection)

{

if(connection!=null)

{

vConnection=connection;

}

}

public Connection getConnection()

{

return vConnection;

}

public void setConnection(Connection connection)

{

vConnection=connection;

}

public void setUseState(boolean bUseState)

{

this.bUseState=bUseState;

}

public boolean getUseState()

{

return bUseState;

}

public void close()

{

try

{

vConnection.close();

}

catch(SQLException sqlException)

{

System.err.println(sqlException.getMessage());

}

}

}

//连接池

PoolBean.java

package com.pool;

import java.io.Serializable;

import java.sql.*;

import java.util.*;

import com.pool.ConnectionBean;

public class PoolBean implements java.io.Serializable

{

private String strDriver=null;

private String strURL=null;

private int iSize=0;

private String strUserName="";

private String strPassword="";

private ConnectionBean vConnectionBean=null;

private Vector vPool=null;

public PoolBean(){}

public void setDriver(String strDriver)

{

if(strDriver!=null)

{

this.strDriver=strDriver;

}

}

public String getDriver()

{

return strDriver;

}

public void setURL(String strURL)

{

if(strURL!=null)

{

this.strURL=strURL;

}

}

public String getURL()

{

return strURL;

}

public void setSize(int iSize)

{

if(iSize>1)

{

this.iSize=iSize;

}

}

public int getSize()

{

return iSize;

}

public String getUserName()

{

return strUserName;

}

public void setUserName(String strUserName)

{

if(strUserName!=null)

{

this.strUserName=strUserName;

}

}

public void setPassword(String strPassword)

{

if(strPassword!=null)

{

this.strPassword=strPassword;

}

}

public String getPassword()

{

return strPassword;

}

public void setConnectionBean(ConnectionBean vConnectionBean)

{

if(vConnectionBean!=null)

{

this.vConnectionBean=vConnectionBean;

}

}

public ConnectionBean getConnectionBean() throws Exception

{

Connection vConnection=getConnection();

ConnectionBean vConnectionBean=new ConnectionBean(vConnection);

vConnectionBean.setUseState(true);

return vConnectionBean;

}

private Connection createConnection() throws Exception

{

Connection vConnection=null;

vConnection=DriverManager.getConnection(strURL,strUserName,strPassword);

return vConnection;

}

public synchronized void initializePool() throws Exception

{

if(strDriver==null)

{

throw new Exception("没有提供驱动程序名称!");

}

if(strURL==null)

{

throw new Exception("没有提供URL!");

}

if(iSize<1)

{

throw new Exception("连接池大小小于1!");

}

try

{

Class.forName(strDriver);

for(int iIndex=0;iIndex<iSize;iIndex++)

{

Connection vConnection=createConnection();

if(vConnection!=null)

{

ConnectionBean vConnectionBean=new ConnectionBean(vConnection);

addConnection(vConnectionBean);

}

}

}

catch(Exception eException)

{

System.err.println(eException.getMessage());

throw new Exception(eException.getMessage());

}

}

private void addConnection(ConnectionBean vConnectionBean)

{

if(vPool==null)

{

vPool=new Vector(iSize);

}

vPool.addElement(vConnectionBean);

}

public synchronized void releaseConnection(Connection vConnection)

{

for(int iIndex=0;iIndex<vPool.size();iIndex++)

{

ConnectionBean vConnectionBean=(ConnectionBean)vPool.elementAt(iIndex);

if(vConnectionBean.getConnection()==vConnection)

{

System.err.println("释放第"+iIndex+"个连接!");

vConnectionBean.setUseState(false);

break;

}

}

}

public synchronized Connection getConnection() throws Exception

{

ConnectionBean vConnectionBean=null;

for(int iIndex=0;iIndex<vPool.size();iIndex++)

{

vConnectionBean=(ConnectionBean)vPool.elementAt(iIndex);

if(vConnectionBean.getUseState()==false)

{

vConnectionBean.setUseState(true);

Connection vConnection=vConnectionBean.getConnection();

return vConnection;

}

}

try

{

Connection vConnection=createConnection();

vConnectionBean=new ConnectionBean(vConnection);

vConnectionBean.setUseState(true);

vPool.addElement(vConnectionBean);

}

catch(Exception eException)

{

System.err.println(eException.getMessage());

throw new Exception(eException.getMessage());

}

return vConnectionBean.getConnection();

}

public synchronized void emptyPool()

{

for(int iIndex=0;iIndex<vPool.size();iIndex++)

{

System.err.println("关闭第"+iIndex+"JDBC连接!");

ConnectionBean vConnectionBean=(ConnectionBean)vPool.elementAt(iIndex);

if(vConnectionBean.getUseState()==false)

{

vConnectionBean.close();

}

else

{

try

{

java.lang.Thread.sleep(20000);

vConnectionBean.close();

}

catch(InterruptedException interruptedException)

{

System.err.println(interruptedException.getMessage());

}

}

}

}

}

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航