zl程序教程

您现在的位置是:首页 >  后端

当前栏目

java配置dbcp连接池(数据库连接池)示例分享

JAVA数据库配置 示例 分享 连接池 dbcp
2023-06-13 09:15:14 时间

使用jar包:commons-dbcp-1.4.jar、commons-pool-1.6.jar、commons-logging-1.1.3.jar,另外还有数据库的jdbc驱动,适用java6及以上平台

连接池管理类

复制代码代码如下:

packagecn.songxinqiang.samples.commonsdbcp.util;

importjava.sql.Connection;
importjava.sql.DatabaseMetaData;
importjava.sql.SQLException;
importjava.util.Properties;

importjavax.sql.DataSource;

importorg.apache.commons.logging.Log;
importorg.apache.commons.logging.LogFactory;
importorg.apache.tomcat.dbcp.dbcp.BasicDataSourceFactory;

/**
 *tomcat数据库连接池管理类<br>
 *使用为tomcat部署环境<br>
 *需要在类路径下准备数据库连接配置文件dbcp.properties
 *
 *@author宋信强
 *@mailsongxinqiang123@gmail.com
 *
 *@time2013-12-27
 *
 */
publicclassDBManager{
 privatestaticfinalLoglog=LogFactory.getLog(DBManager.class);
 privatestaticfinalStringconfigFile="dbcp.properties";

 privatestaticDataSourcedataSource;

 static{
  PropertiesdbProperties=newProperties();
  try{
   dbProperties.load(DBManager.class.getClassLoader()
     .getResourceAsStream(configFile));
   dataSource=BasicDataSourceFactory.createDataSource(dbProperties);

   Connectionconn=getConn();
   DatabaseMetaDatamdm=conn.getMetaData();
   log.info("Connectedto"+mdm.getDatabaseProductName()+""
     +mdm.getDatabaseProductVersion());
   if(conn!=null){
    conn.close();
   }
  }catch(Exceptione){
   log.error("初始化连接池失败:"+e);
  }
 }

 privateDBManager(){
 }

 /**
 *获取链接,用完后记得关闭
 *
 *@see{@linkDBManager#closeConn(Connection)}
 *@return
 */
 publicstaticfinalConnectiongetConn(){
  Connectionconn=null;
  try{
   conn=dataSource.getConnection();
  }catch(SQLExceptione){
   log.error("获取数据库连接失败:"+e);
  }
  returnconn;
 }

 /**
 *关闭连接
 *
 *@paramconn
 *           需要关闭的连接
 */
 publicstaticvoidcloseConn(Connectionconn){
  try{
   if(conn!=null&&!conn.isClosed()){
    conn.setAutoCommit(true);
    conn.close();
   }
  }catch(SQLExceptione){
   log.error("关闭数据库连接失败:"+e);
  }
 }

}

连接配置文件

复制代码代码如下:


#数据库驱动
driverClassName=com.mysql.jdbc.Driver
#数据库连接地址
url=jdbc:mysql://localhost/ctg
#用户名
username=root
#密码
password=123456

#连接池的最大数据库连接数。设为0表示无限制
maxActive=30
#最大空闲数,数据库连接的最大空闲时间。超过空闲时间,数据库连
#接将被标记为不可用,然后被释放。设为0表示无限制
maxIdle=10
#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制
maxWait=1000

#超过removeAbandonedTimeout时间后,是否进行没用连接(废弃)的回收(默认为false,调整为true)
removeAbandoned=true
#超过时间限制,回收没有用(废弃)的连接(默认为300秒,调整为180)
removeAbandonedTimeout=180

测试连接池工作效率,同时演示怎样获取连接和关闭连接

复制代码代码如下:
publicclassConnectionSource{
 publicstaticvoidmain(String[]args){
  longbegin=System.currentTimeMillis();
  for(inti=0;i<10000;i++){
   Connectionconn=DBManager.getConn();
   System.out.print(i+"  ");
   DBManager.closeConn(conn);
  }
  longend=System.currentTimeMillis();
  System.out.println("用时:"+(end-begin));
 }
}