DBCP数据库连接池初探

时间:2024-01-21 21:54:33

1、 概述

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

所以需要数据库连接池,数据库连接池也被称为数据源即DataSourceJAVA中为了使用者更加规范的编写数据源类,定义了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();
}
}