快捷導(dǎo)航

java配置dbcp連接池(數(shù)據(jù)庫(kù)連接池)示例分享

更新時(shí)間：2013年12月30日 11:06:56 作者：

java配置dbcp連接池示例分享,大家參考使用吧

使用jar包：commons-dbcp-1.4.jar、commons-pool-1.6.jar、commons-logging-1.1.3.jar，另外還有數(shù)據(jù)庫(kù)的jdbc驅(qū)動(dòng)，適用java6及以上平臺(tái)

連接池管理類

復(fù)制代碼代碼如下:

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數(shù)據(jù)庫(kù)連接池管理類<br>
* 使用為tomcat部署環(huán)境<br>
* 需要在類路徑下準(zhǔn)備數(shù)據(jù)庫(kù)連接配置文件dbcp.properties
*
* @author 宋信強(qiáng)
* @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() {
}

/**
* 獲取鏈接，用完后記得關(guān)閉
*
* @see {@link DBManager#closeConn(Connection)}
* @return
*/
public static final Connection getConn() {
  Connection conn = null;
  try {
   conn = dataSource.getConnection();
  } catch (SQLException e) {
   log.error("獲取數(shù)據(jù)庫(kù)連接失敗：" + e);
  }
  return conn;
}

/**
* 關(guān)閉連接
*
* @param conn
*            需要關(guān)閉的連接
*/
public static void closeConn(Connection conn) {
  try {
   if (conn != null && !conn.isClosed()) {
    conn.setAutoCommit(true);
    conn.close();
   }
  } catch (SQLException e) {
   log.error("關(guān)閉數(shù)據(jù)庫(kù)連接失?。? + e);
  }
}

}

連接配置文件

復(fù)制代碼代碼如下:

#數(shù)據(jù)庫(kù)驅(qū)動(dòng)
driverClassName=com.mysql.jdbc.Driver
#數(shù)據(jù)庫(kù)連接地址
url=jdbc:mysql://localhost/ctg
#用戶名
username=root
#密碼
password=123456

#連接池的最大數(shù)據(jù)庫(kù)連接數(shù)。設(shè)為0表示無(wú)限制
maxActive=30
#最大空閑數(shù)，數(shù)據(jù)庫(kù)連接的最大空閑時(shí)間。超過(guò)空閑時(shí)間，數(shù)據(jù)庫(kù)連
#接將被標(biāo)記為不可用，然后被釋放。設(shè)為0表示無(wú)限制
maxIdle=10
#最大建立連接等待時(shí)間。如果超過(guò)此時(shí)間將接到異常。設(shè)為-1表示無(wú)限制
maxWait=1000

#超過(guò)removeAbandonedTimeout時(shí)間后，是否進(jìn) 行沒(méi)用連接（廢棄）的回收（默認(rèn)為false，調(diào)整為true)
removeAbandoned=true
#超過(guò)時(shí)間限制，回收沒(méi)有用(廢棄)的連接（默認(rèn)為 300秒，調(diào)整為180）
removeAbandonedTimeout=180

測(cè)試連接池工作效率，同時(shí)演示怎樣獲取連接和關(guān)閉連接

復(fù)制代碼代碼如下:

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("用時(shí)："+(end-begin));
 }
}

您可能感興趣的文章: