单独使用 commons-dbcp 连接池详解编程语言

dbcp 是 apache 上的一个 java 连接池项目，也是 tomcat 使用的连接池组件。单独使用dbcp需要3个包：common-dbcp.jar ,common-pool.jar,common-collections.jar。

下面是个dbcp的实用类，通过它可以完成DBCP的使用：

 
import java.sql.Connection; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.sql.Statement; 
import java.util.HashMap; 
import java.util.Map; 
import javax.sql.DataSource; 
import org.apache.commons.dbcp.BasicDataSource; 
/** 
 * @author space 
 * @date Aug 12, 2008 3:25:49 PM 
 * 
 * dbcp 实用类，提供了dbcp连接，不允许继承； 
 *  
 * 该类需要有个地方来初始化 DS ，通过调用initDS 方法来完成， 
 * 可以在通过调用带参数的构造函数完成调用， 
 * 可以在其它类中调用，也可以在本类中加一个static{}来完成； 
 */ 
public final class DbcpBean { 
 /** 数据源，static */ 
 private static DataSource DS; 
 /** 从数据源获得一个连接 */ 
 public Connection getConn() { 
  Connection con = null; 
  if (Ds!= null) { 
   try { 
    con = Ds.getConnection(); 
   } catch (Exception e) { 
    e.printStackTrace(System.err); 
   } 
 
   try { 
    con.setAutoCommit(false); 
   } catch (SQLException e) { 
    e.printStackTrace(); 
   } 
   return con; 
  } 
  return con; 
 } 
 /** 默认的构造函数 */ 
 public DbcpBean() { 
 } 
 /** 构造函数，初始化了 DS ，指定 数据库 */ 
 public DbcpBean(String connectURI) { 
  initDS(connectURI); 
 } 
 /** 构造函数，初始化了 DS ，指定 所有参数 */ 
 public DbcpBean(String connectURI, String username, String pswd, String driverClass, int initialSize, 
   int maxActive, int maxIdle, int maxWait) { 
  initDS(connectURI, username, pswd, driverClass, initialSize, maxActive, maxIdle, maxWait); 
 } 
 /** 
  * 创建数据源，除了数据库外，都使用硬编码默认参数； 
  *  
  * @param connectURI 数据库 
  * @return 
  */ 
 public static void initDS(String connectURI) { 
  initDS(connectURI, "root", "password", "com.mysql.jdbc.Driver", 5, 100, 30, 10000); 
 } 
 /**  
  * 指定所有参数连接数据源 
  *  
  * @param connectURI 数据库 
  * @param username 用户名 
  * @param pswd 密码 
  * @param driverClass 数据库连接驱动名 
  * @param initialSize 初始连接池连接个数 
  * @param maxActive 最大激活连接数 
  * @param maxIdle 最大闲置连接数 
  * @param maxWait 获得连接的最大等待毫秒数 
  * @return 
  */ 
 public static void initDS(String connectURI, String username, String pswd,  
    String driverClass, int initialSize, 
    int maxActive, int maxIdle, int maxWait) { 
  BasicDataSource ds = new BasicDataSource(); 
  ds.setDriverClassName(driverClass); 
  ds.setUsername(username); 
  ds.setPassword(pswd); 
  ds.setUrl(connectURI); 
  ds.setInitialSize(initialSize); // 初始的连接数； 
  ds.setMaxActive(maxActive); 
  ds.setMaxIdle(maxIdle); 
  ds.setMaxWait(maxWait); 
  DS = ds; 
 } 
 /** 获得数据源连接状态 */ 
 public static Map<String, Integer> getDataSourceStats() throws SQLException { 
  BasicDataSource bds = (BasicDataSource) DS; 
  Map<String, Integer> map = new HashMap<String, Integer>(2); 
  map.put("active_number", bds.getNumActive()); 
  map.put("idle_number", bds.getNumIdle()); 
  return map; 
 } 
 /** 关闭数据源 */ 
 protected static void shutdownDataSource() throws SQLException { 
  BasicDataSource bds = (BasicDataSource) DS; 
  bds.close(); 
 } 
 public static void main(String[] args) { 
  DbcpBean db = new DbcpBean("jdbc:<a href="mysql://localhost:3306/testit">mysql://localhost:3306/testit"); 
  Connection conn = null; 
  Statement stmt = null; 
  ResultSet rs = null; 
  try { 
   conn = db.getConn(); 
   stmt = conn.createStatement(); 
   rs = stmt.executeQuery("select * from test limit 1 "); 
   System.out.println("Results:"); 
   int numcols = rs.getMetaData().getColumnCount(); 
   while (rs.next()) { 
    for (int i = 1; i <= numcols; i++) { 
     System.out.print("//t" + rs.getString(i) + "//t"); 
    } 
    System.out.println(""); 
   } 
   System.out.println(getDataSourceStats()); 
  } catch (SQLException e) { 
   e.printStackTrace(); 
  } finally { 
   try { 
    if (rs != null) 
     rs.close(); 
    if (stmt != null) 
     stmt.close(); 
    if (conn != null) 
     conn.close(); 
    if (db != null) 
     shutdownDataSource(); 
   } catch (Exception e) { 
    e.printStackTrace(); 
   } 
  } 
 } 
}