【郑州校区】第三阶段Mysql数据库之DBCP连接池（4） - 黑马程序员技术交流社区

今日内容介绍

实际开发中“获得连接”或“释放资源”是非常消耗系统资源的两个过程，为了解决此类性能问题，通常情况我们采用连接池技术，来共享连接Connection。这样我们就不需要每次都创建连接、释放连接了，这些操作都交给了连接池

用池来管理Connection，这样可以重复使用Connection。有了池，所以我们就不用自己来创建Connection，而是通过池来获取Connection对象。当使用完Connection后，调用Connection的close()方法也不会真的关闭Connection，而是把Connection“归还”给池。池就可以再利用这个Connection对象了。

Java为数据库连接池提供了公共的接口：javax.sql.DataSource，各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池！

常见的连接池：DBCP、C3P0。

接下来，我们就详细的学习一下DBCP连接池。C3P0连接池我们在就业班学习。

DBCP也是一个开源的连接池，是Apache Common成员之一，在企业开发中也比较常见，tomcat内置的连接池。

连接数据库表的工具类, 采用DBCP连接池的方式来完成，Java中提供了一个连接池的规则接口：

DataSource : 它是java中提供的连接池，作为 DriverManager 工具的替代项。在DBCP包中提供了DataSource接口的实现类，我们要用的具体的连接池 BasicDataSource类

[AppleScript] 纯文本查看 复制代码

public class JDBCUtils {

public static final String DRIVER = "com.mysql.jdbc.Driver";

public static final String URL = "jdbc:mysql://localhost:3306/daydb";

public static final String USERNAME = "root";

public static final String PASSWORD = "root";

/*

 * 创建连接池BasicDataSource

 */

public static BasicDataSource dataSource = new BasicDataSource();

//静态代码块

static {

//对连接池对象 进行基本的配置

dataSource.setDriverClassName(DRIVER); // 这是要连接的数据库的驱动

dataSource.setUrl(URL); //指定要连接的数据库地址

dataSource.setUsername(USERNAME); //指定要连接数据的用户名

dataSource.setPassword(PASSWORD); //指定要连接数据的密码

}

/*

 * 返回连接池对象

 */

public static DataSource getDataSource(){

return dataSource;

}

}

[AppleScript] 纯文本查看 复制代码

l 测试类

/*

 * 演示使用DBUtils工具  完成数据库表的增加操作

 */

public class Demo {

// 插入功能

@Test

public void insert(){

try {

//获取一个用来执行SQL语句的对象   QueryRunner

QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());

String sql = "INSERT INTO zhangwu(name,money,parent) VALUES(?,?,?)";

Object[] params = {"股票收入", 5500, "收入"};

     int line = qr.update(sql,params);

//结果集处理

System.out.println("line = " + line);

} catch (SQLException e) {

throw new RuntimeException(e);

}

}

//删除功能

@Test

public void delete(){

try {

//创建一个QueryRunner对象，用来完成SQL语句的执行

QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());

//执行SQL语句

String sql = "DELETE FROM zhangwu WHERE name = ?";

Object[] params = {"股票收入"};

int line = qr.update(sql, params);

//结果集的处理

System.out.println("line="+line);

} catch (SQLException e) {

throw new RuntimeException(e);

}

}

//更新功能

@Test

public void update(){

try {

//创建一个QueryRunner对象，用来完成SQL语句的执行

QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());

//执行SQL语句

String sql = "UPDATE zhangwu SET money = money+1000 WHERE name=?";

Object[] params = {"股票收入"};

int line = qr.update(sql, params);

//结果集的处理

System.out.println("line="+line);

} catch (SQLException e) {

throw new RuntimeException(e);

}

}

//查询功能,将结果集中第一条记录封装到一个指定的javaBean中。

@Test

public void search(){

try{

//获取QueryRunner

QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());

//执行SQL语句

String sql = "SELECT * FROM zhangwu";

Object[] params = {};

Product p = qr.query(sql, new BeanHandler<Product>(Product.class), params);

//结果集处理

System.out.println(p);

} catch(SQLException e){

throw new RuntimeException(e);

}

}

}

数据库驱动名称

基本项（扩展）

l 作用：自身维护了多个Connection连接对象维护

l BasicDataSource类是 DataSource接口的实现类

l DataSource接口，它是java与每种数据库连接池连接的规范标准

l DBCP连接池常见的配置

数据库驱动名称

连接池中初始化多少个Connection连接对象

超时等待时间以毫秒为单位 1000等于1秒

分类	属性	描述
必须项	driverClassName	数据库驱动名称
	url	数据库的地址
	username	用户名
	password	密码
基本项（扩展）	maxActive	最大连接数量
	minIdle	最小空闲连接
	maxIdle	最大空闲连接
	initialSize	初始化连接

必须项	driverClassName	数据库驱动名称
	url	数据库的地址
	username	用户名
	password	密码
基本项	maxActive	最大连接数量
基本项	initialSize	连接池中初始化多少个Connection连接对象
扩展项	maxWait	超时等待时间以毫秒为单位 1000等于1秒