DBCP数据库连接池初探

1、 概述

数据库连接是很“宝贵的”，如果每次获取Connection都去创建数据库连接，使用之后就断开，再次使用又重新创建，程序效率是很低的。因为Socket连接的建立很消耗资源。

所以需要数据库连接池，数据库连接池也被称为数据源即DataSource，JAVA中为了使用者更加规范的编写数据源类，定义了java.sql.DataSource接口，如果我们要编写自己的连接池，就要实现这个接口。

程序通过连接池预先同数据库建立一些连接，放在内存中，需要数据库连接时直接到连接池中取一个就行，用完后再放回去。

该接口声明了两个获取数据库连接的方法

public interface DataSource  extends CommonDataSource, Wrapper {

    Connection getConnection() throws SQLException;

    Connection getConnection(String username, String password) throws SQLException;
}

2、DBCP 数据源概述

DBCP（DataBase Connection Pool）由Apache开发，可以让程序自动管理数据库连接的释放和断开。

需要使用的jar包：commons-dbcp-1.4.jar、commons-pool-1.5.4.jar、commons-logging-1.0.4.jar、commons-collections-3.1.jar

重要的配置参数：

driverClassName	数据库驱动
url	数据库连接url
username	数据库连接用户名
password	数据库连接密码
initialSize	初始连接数量
maxActive	最大活跃连接数量
maxIdle	最大空闲连接数量
minIdle	最小空闲连接数量
maxWaitMillis	在抛出异常之前等待的最大毫秒数（当没有可用的连接时），默认-1无限期地等待
validationQuery	验证连接时使用的SQL
testOnCreate	连接创建时验证
testOnBorrow	连接获取时验证
testOnReturn	连接归还时验证
testWhileIdle	是否验证空闲连接，默认false不验证。 如果一个对象无法验证，将从池中删除
timeBetweenEvictionRunsMillis	运行空闲对象删除线程的时间间隔，单位为毫秒，默认为-1即不执行任务
numTestsPerEvictionRun	空闲对象删除线程每次运行时检查的对象数量（如果有的话），默认3个
minEvictableIdleTimeMillis	在空闲对象删除线程可以删除连接之前，连接可以在池中空闲的最少时间（如果有的话），默认1000 * 60 * 30
maxConnLifetimeMillis	连接的最长寿命（以毫秒为单位）。超过此时间后，连接将在下一次激活、钝化或验证测试时失败。0或更小意味着连接具有无限寿命
removeAbandonedTimeout	Timeout in seconds before an abandoned connection can be removed

3、 设计思路

1)    在jdbc.properties文件配置数据源实现类类型，以及该数据源的属性信息；

2)    在DBUtil工具类中解析配置文件，获取到使用的数据源类型，并通过反射实例化；

3)    使用beanutils框架给实例化的数据源对象注入属性，需要使用到commons-beanutils-1.9.3.jar框架；

4)    修改getConnection方法从数据源获取连接

之所以这样做，是为了程序代码和具体数据源实现类的解耦，当不再使用DBCP改用C3P0时，我们可以通过修改jdbc.properties配置文件而不再需要修改程序代码。

4、 配置 jdbc.properties

##### DBCP Configuration #####

dataSourceClassName=org.apache.commons.dbcp.BasicDataSource

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=false

username=system
password=123456

initialSize=1
maxActive=10
maxIdle=5
minIdle=2

maxWaitMillis=-1
validationQuery=select 1
testWhileIdle=true
timeBetweenEvictionRunsMillis=60000
numTestsPerEvictionRun=3
minEvictableIdleTimeMillis=60000
softMinEvictableIdleTimeMillis=60000
maxConnLifetimeMillis=300000
removeAbandonedTimeout=300

5、DBUtil 工具类

public class DBUtil {

    /**
     * 数据源对象
     */
    private static DataSource ds;

    private static Properties prop = new Properties();

    static {
        try {
            // 读取加载jdbc配置文件
            prop.load(DBUtil.class.getClassLoader().getResourceAsStream(
                    "jdbc.properties"));

            // 获取数据源实现类类型
            String dataSourceClassName = prop
                    .getProperty("dataSourceClassName");

            // 实例化数据源实现类
            Class<?> clazz = Class.forName(dataSourceClassName);
            ds = (DataSource) clazz.newInstance();

            prop.remove("dataSourceClassName");

            // 为数据源注入属性
            Map<String, Object> p = new HashMap<String, Object>();
            for (Object key : prop.keySet()) {
                p.put(key.toString(), prop.get(key));
            }
            BeanUtils.populate(ds, p);

        } catch (IOException e) {
            throw new RuntimeException("加载JDBC配置失败", e);
        } catch (ClassNotFoundException e) {
            throw new RuntimeException("数据源实现类未找到", e);
        } catch (InstantiationException e) {
            throw new RuntimeException("创建数据源实现类对象失败", e);
        } catch (IllegalAccessException e) {
            throw new RuntimeException("创建数据源实现类对象失败", e);
        } catch (InvocationTargetException e) {
            throw new RuntimeException("数据源属性注入时失败", e);
        }
    }

    /**
     * 从数据源中获取一个数据库连接
     * 
     * @return 数据库连接
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }
}