当前位置: 移动技术网 > IT编程>开发语言>Java > java配置dbcp连接池(数据库连接池)示例分享

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

2019年07月22日  | 移动技术网IT编程  | 我要评论
使用jar包:commons-dbcp-1.4.jar、commons-pool-1.6.jar、commons-logging-1.1.3.jar,另外还有数据库的jdb

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

连接池管理类

复制代码 代码如下:

package cn.songxinqiang.samples.commonsdbcp.util;

import java.sql.connection;
import java.sql.databasemetadata;
import java.sql.sqlexception;
import java.util.properties;

import javax.sql.datasource;

import org.apache.commons.logging.log;
import org.apache.commons.logging.logfactory;
import org.apache.tomcat.dbcp.dbcp.basicdatasourcefactory;

/**
 * tomcat数据库连接池管理类<br>
 * 使用为tomcat部署环境<br>
 * 需要在类路径下准备数据库连接配置文件dbcp.properties
 *
 * @author 宋信强
 * @mail songxinqiang123@gmail.com
 *
 * @time 2013-12-27
 *
 */
public class dbmanager {
 private static final log log = logfactory.getlog(dbmanager.class);
 private static final string configfile = "dbcp.properties";

 private static datasource datasource;

 static {
  properties dbproperties = new properties();
  try {
   dbproperties.load(dbmanager.class.getclassloader()
     .getresourceasstream(configfile));
   datasource = basicdatasourcefactory.createdatasource(dbproperties);

   connection conn = getconn();
   databasemetadata mdm = conn.getmetadata();
   log.info("connected to " + mdm.getdatabaseproductname() + " "
     + mdm.getdatabaseproductversion());
   if (conn != null) {
    conn.close();
   }
  } catch (exception e) {
   log.error("初始化连接池失败:" + e);
  }
 }

 private dbmanager() {
 }

 /**
  * 获取链接,用完后记得关闭
  *
  * @see {@link dbmanager#closeconn(connection)}
  * @return
  */
 public static final connection getconn() {
  connection conn = null;
  try {
   conn = datasource.getconnection();
  } catch (sqlexception e) {
   log.error("获取数据库连接失败:" + e);
  }
  return conn;
 }

 /**
  * 关闭连接
  *
  * @param conn
  *            需要关闭的连接
  */
 public static void closeconn(connection conn) {
  try {
   if (conn != null && !conn.isclosed()) {
    conn.setautocommit(true);
    conn.close();
   }
  } catch (sqlexception e) {
   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

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

复制代码 代码如下:

public class connectionsource {
 public static void main(string[] args){
  long begin=system.currenttimemillis();
  for(int i=0;i<10000;i++){
   connection conn=dbmanager.getconn();
   system.out.print(i+"   ");
   dbmanager.closeconn(conn);
  }
  long end=system.currenttimemillis();
  system.out.println("用时:"+(end-begin));
 }
}

如您对本文有疑问或者有任何想说的,请 点击进行留言回复,万千网友为您解惑!

相关文章:

验证码:
移动技术网