DBCP、DBUtils使用

一、使用DBCP创建连接池，需要两个jar包。
commons-pool.jar 

commons-dbcp-1.2.2.jar

#连接设置
        driverClassName=com.mysql.jdbc.Driver
        url=jdbc:mysql://localhost:3306/xxx
        username=root
        password=sjjhong
        #<!-- 初始化连接 -->
        initialSize=10  
        #最大连接数量
        maxActive=50
         #<!-- 最大空闲连接 -->
        maxIdle=20
       #<!-- 最小空闲连接 -->
        minIdle=5
         #<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
        maxWait=60000
        #JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;] 
        #注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
        connectionProperties=useUnicode=true;characterEncoding=UTF8
       #指定由连接池所创建的连接的自动提交（auto-commit）状态。
        defaultAutoCommit=true
       #driver default 指定由连接池所创建的连接的只读（read-only）状态。
        #如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
        defaultReadOnly=
       #driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
        #可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
        defaultTransactionIsolation=READ_UNCOMMITTED

三、测试：

    1.工具类：

package cn.edu.chd.utils;import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;import org.apache.commons.dbcp.BasicDataSourceFactory;
/*** @author Rowand jj*jdbc工具类:*采用dbcp连接池作为数据源*    */
public class JDBCUitls
{private static DataSource ds = null;static{
//        导入配置信息Properties prop = new Properties();try{           prop.load(JDBCUitls.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"));
//            DBCP核心类ds = BasicDataSourceFactory.createDataSource(prop);} catch (Exception e){throw new RuntimeException(e);}}/*** 使用dbcp获取一个数据源* * @return 返回DataSource实例（数据源）*/public static DataSource getDataSource(){return ds;}/*** 获取一个连接* @return* @throws SQLException*/public static Connection getConnection() throws SQLException{return ds.getConnection();}}

2.测试：package cn.edu.chd.utils;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class Test
{public static void main(String[] args) throws Exception{Connection conn = JDBCUitls.getConnection();String sql = "select * from user";PreparedStatement ps = conn.prepareStatement(sql);ResultSet rs = ps.executeQuery();while(rs.next()){System.out.println(rs.getString("password"));System.out.println(rs.getString("id"));System.out.println(rs.getString("username"));}}}

DBCP经常会结合DBUtils框架使用，下面介绍DBUtils框架：

一、结构介绍：

二、功能介绍

commons.dbutils是一个对JDBC操作进行封装的类集，其有如下几个优点：

（1）没有可能的资源泄漏，避免了繁锁的JDBC代码

（2）代码更整洁

（3）从ResultSet自动生成JavaBeans属性

（4）无其他依赖包

三、使用：

基本用到的类有：QueryRunner、ResultSetHandler及其子类等

QueryRunner -- 执行查询的类，可以执行SELECT、INSERT、UPDATE、DELETE等语句，QueryRunner用ResultSetHandler的子类来处理ResultSet并返回结果；而包提供的ResultSetHandler子类使用RowProcessor的子类来处理ResultSet中的每一行；RowProcessor的默认实现为BasicRowProcessor；BeanProcessor不是RowProcessor，可以看作一个工具类。

QueryRunner类被创建的时候，可以传入一个DataSource数据源，故可以使用DBCP作为数据源。另外如果创建的时候不传入任何参数，则QueryRunner在调用query、update方法时必须传入一个Connection对象

 四、DBUtils框架结合DBCP连接池使用：

package cn.edu.chd.dao;import java.util.List;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;import cn.edu.chd.domain.Role;
import cn.edu.chd.domain.User;
import cn.edu.chd.utils.DaoException;
import cn.edu.chd.utils.JDBCUitls;public class UserDao
{public User find(int id){try{String sql = "select * from user where id = ?";QueryRunner runner = new QueryRunner(JDBCUitls.getDataSource());return runner.query(sql,id,new BeanHandler<User>(User.class));} catch (Exception e){throw new DaoException();}}public void add(User user){try{String sql = "insert into user(username,password) values(?,?)";QueryRunner runner = new QueryRunner(JDBCUitls.getDataSource());runner.update(sql,new Object[]{user.getUsername(),user.getPassword()});} catch (Exception e){throw new DaoException();}}public User find(String name,String pwd){try{String sql = "select * from user where username = ? and password = ?";QueryRunner runner = new QueryRunner(JDBCUitls.getDataSource());return runner.query(sql,new Object[]{name,pwd},new BeanHandler<User>(User.class));} catch (Exception e){throw new DaoException();}}public List<User> getAll(){try{String sql = "select * from user";QueryRunner runner = new QueryRunner(JDBCUitls.getDataSource());return runner.query(sql,new BeanListHandler<User>(User.class));} catch (Exception e){throw new DaoException();}}}