commons-dbcp.jar有什么作用

Answer 1

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

common-dbcp.jar,common-pool.jar,common-collections.jar。

下面是使用示例:

package 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: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();

   }

  }

 }

}