JDBC连接池

Java 为数据库连接池提供了公共的接口：javax.sql.DataSource，各个厂商需要让自

己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池！

常见的连接池：DBCP、 C3P0。

接下来，我们就详细的学习连接池。

c3p0 概述

C3P0 开源免费的连接池！目前使用它的开源项目有：Spring、 Hibernate 等。使用第

三方工具需要导入 jar 包，c3p0 使用时还需要添加配置文件 c3p0-config.xml

一引入c3p0相关的jar包

c3p0-0.9.2-pre5.jar

mchange-commons-java-0.2.3.jar

下面是通过手动来设置数据源：（后面讲解如何从配置文件 c3p0-config.xml文件中来设置数据源）

package com.igeek_01_c3p0;

import java.sql.Connection;

import org.junit.Test;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**

*

* @ClassName: C3P0Demo_01

* @Description: TODO(C3P0 的基本配置)

* @date 2018 年 1 月 30 日下午 1:44:42

* Company www.igeekhome.com

*

*/

public class C3P0Demo_01 {

@Test

public void demo01() throws Exception{

//1 获得连接池(数据源)

ComboPooledDataSource dataSource = new ComboPooledDataSource();

//1.1 设置基本项

dataSource.setDriverClass("com.mysql.jdbc.Driver");

dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/igeek");

dataSource.setUser("root");

dataSource.setPassword("root");

//1.2 其他项

// * 初始化连接池中连接的个数

dataSource.setInitialPoolSize(5);

// * 最小|最大连接池中连接的个数

dataSource.setMinPoolSize(2);

dataSource.setMaxPoolSize(10);

// * 最大空闲数

dataSource.setMaxIdleTime(60);

// * 每次增长个数

dataSource.setAcquireIncrement(2);

//2 获得连接

Connection conn = dataSource.getConnection();

System.out.println(conn);

}

}

c3p0 连接池--配置文件使用

1.3.1配置项说明

配置文件名称：c3p0-config.xml （格式固定）

配置文件位置：src （类路径）

配置文件内容：默认配置

<c3p0-config>



<default-config>

<property name="driverClass">com.mysql.jdbc.Driver</property>

<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/igeek</property>

<property name="user">root</property>

<property name="password">root</property>

<property name="checkoutTimeout">30000</property>

<property name="idleConnectionTestPeriod">30</property>

<property name="initialPoolSize">10</property>

<property name="maxIdleTime">30</property>

<property name="maxPoolSize">100</property>

<property name="minPoolSize">10</property>

<property name="maxStatements">200</property>

<user-overrides user="test-user">

<property name="maxPoolSize">10</property>

<property name="minPoolSize">1</property>

<property name="maxStatements">0</property>

</user-overrides>

</default-config>

</c3p0-config>

配置文件内容：命名配置

属于自定义，可以根据情况修改相应属性；基本项必须要与自己的相应属性一致

<c3p0-config>

<named-config name="igeekhome">



<property name="driverClass">com.mysql.jdbc.Driver</property>

<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/igeek</property>

<property name="user">root</property>

<property name="password">root</property>



<property name="acquireIncrement">5</property>



<property name="initialPoolSize">20</property>



<property name="minPoolSize">10</property>



<property name="maxPoolSize">40</property>



<property name="maxStatements">0</property>



<property name="maxStatementsPerConnection">5</property>

</named-config>

</c3p0-config>

代码展示如何从配置文件中设置数据源：

package com.igeek_01_c3p0;

import java.sql.Connection;

import org.junit.Test;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**

*

* @ClassName: C3P0Demo_02

* @Description: TODO(使用 c3p0-config.xml 进行 c3p0 的配置)

* @date 2018 年 1 月 30 日下午 1:45:20

* Company www.igeekhome.com

*

*/

public class C3P0Demo_02 {

@Test

public void demo01() throws Exception {

// 1 获得连接池(数据源)

// * c3p0 jar 包将自动加载“ c3p0-config.xml”文件，并获得具体的配置信息

// ** 在配置文件中 <named-config name="名称"> ，可以通过核心类 new

//ComboPooledDataSource("名称")***注意这里named-config name="名称"***

ComboPooledDataSource dataSource = new

ComboPooledDataSource("igeekhome");

// 2 获得连接

Connection conn = dataSource.getConnection();

System.out.println(conn);

}

c3p0 连接池--工具类

C3P0 提供核心工具类：ComboPooledDataSource，如果要使用连接池，必须创建该类的实例对象。 new ComboPooledDataSource(“ 名称” ); 使用配置文件“命名配置” new ComboPooledDataSource(); 使用配置文件“默认配置”

c3p0Utils.java代码如下;

package com.igeek_01_c3p0;

import java.sql.Connection;

import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**

* @ClassName: C3P0Utils

* @Description: 等效 JdbcUtils，用于提供获得连接工具类

* @date 2018年1月30日下午1:56:50 Company www.igeekhome.com

*

*/

public class C3P0Utils {

// 连接池

private static ComboPooledDataSource dataSource = new

ComboPooledDataSource("igeekhome");

/**

* 获得数据源(连接池)

*

* @return

*/

public static DataSource getDataSource() {

return dataSource;

}

/**

* 获得连接

*

* @return

* @throws SQLException

*/

public static Connection getConnection() throws SQLException {

// 将从连接池中获得连接

return dataSource.getConnection();

}

}

dbcp 连接池

dbcp 连接池--核心类:

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

相关jar包

c3p0-0.9.2-pre5.jar

mchange-commons-java-0.2.3.jar

参考文档：http://commons.apache.org/proper/commons-dbcp/configuration.html

下面是通过手动来设置数据源：（后面讲解如何从配置文件*.properties 文件中来设置数据源）

package com.igeek_02_dbcp;

import java.sql.Connection;

import org.apache.commons.dbcp.BasicDataSource;

import org.junit.Test;

/**

* @ClassName: DBCPDemo_01

* @Description: DBCP的基本配置

* @date 2018年1月30日下午2:01:42

* Company www.igeekhome.com

*

*/

public class DBCPDemo_01 {

@Test

public void demo01() throws Exception{

//1 获得连接池

BasicDataSource dataSource = new BasicDataSource();

//1.1 基本项

dataSource.setDriverClassName("com.mysql.jdbc.Driver");

dataSource.setUrl("jdbc:mysql://localhost:3306/igeek");

dataSource.setUsername("root");

dataSource.setPassword("root");

//1.2 其他项

// * 初始化连接池中连个的个数

dataSource.setInitialSize(5);

// * 最大活劢数

dataSource.setMaxActive(10);

//2获得连接

Connection conn = dataSource.getConnection();

System.out.println(conn);

}

}

dbcp 连接池--配置文件使用

配置文件名称：*.properties

配置文件位置：任意，建议 src（classpath/类路径）

配置文件内容：.properties文件不能编写中文，不支持在 STS 中修改，必须使用记事本修改内容，否则中文注释就乱码了 (一般用=连接key（左），value（右）)

#连接设置

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/webdb

username=root

password=root

#

initialSize=10

#最大连接数量

maxActive=50

#

maxIdle=20

#

minIdle=5

#

maxWait=60000

#JDBC驱劢建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;]

#注意："user" 不 "password" 两个属性会被明确地传递，因此这里丌需要包含他们。

connectionProperties=useUnicode=true;characterEncoding=gbk

#指定由连接池所创建的连接的自劢提交（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

案例：

package com.igeek_02_dbcp;

import java.io.InputStream;

import java.sql.Connection;

import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSourceFactory;

import org.junit.Test;

/**

* @ClassName: DBCPDemo_02

* @Description: 使用配置文件配置dbcp

* @date 2018年1月30日下午2:11:33

* Company www.igeekhome.com

*

*/

public class DBCPDemo_02 {

@Test

public void demo01() throws Exception{

//1 获得连接池

//1.1 加载properties文件，获得Properties对象

InputStream is =

DBCPDemo_02.class.getClassLoader().getResourceAsStream("dbcp-config.properties");

Properties props = new Properties();

props.load(is);

//1.2获得连接池

DataSource dataSource = BasicDataSourceFactory.createDataSource(props);

//2获得连接

Connection conn = dataSource.getConnection();

System.out.println(conn);

}

}

dbcp-config.properties 配置文件

#基本配置内容

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/igeek

username=root

password=root

initialSize=10

maxActive=50

maxIdle=20

minIdle=5

maxWait=60000

connectionProperties=useUnicode=true;characterEncoding=UTF-8

defaultAutoCommit=true

defaultReadOnly=NONE

defaultTransactionIsolation=READ_UNCOMMITTED

dbcp 连接池--工具类

工具类概述：

工具类提供两个功能，分别是提供连接池对象，提供连接对象

案例：

package com.igeek_02_dbcp;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.SQLException;

import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSourceFactory;

/**

* @ClassName: DBCPUtils

* @Description: DBCP工具类

* @date 2018年1月30日下午2:13:55

* Company www.igeekhome.com

*

*/

public class DBCPUtils {

//1 创建连接池

private static DataSource dataSource;

// * 编写固定代码

static{

try {

//1) 加载properties文件，获得Properties对象

InputStream is =

DBCPUtils.class.getClassLoader().getResourceAsStream("dbcp-config.properties");

Properties prop = new Properties();

prop.load(is);

//2) 通过工厂，创建连接池

dataSource = BasicDataSourceFactory.createDataSource(prop);

} catch (Exception e) {

throw new RuntimeException(e);

}

}

/**

* 获得数据库(连接池)

* @return

*/

public static DataSource getDataSource(){

return dataSource;

}

/**

* 获得连接

* @return

* @throws SQLException

*/

public static Connection getConnection() throws SQLException{

return dataSource.getConnection();

}

}

DBUtils 工具类

概述

DBUtils 是 java 编程中的数据库操作实用工具，小巧简单实用。 DBUtils 封装了对 JDBC 的操作，简化了 JDBC 操作，可以少写代码。 Dbutils 三个核心功能介绍

QueryRunner 中提供对 sql 诧句操作的 API.

ResultSetHandler 接口，用于定义 select 操作后，怎样封装结果集.

DbUtils 类，它就是一个工具类,定义了兲闭资源不事务处理的方法

要引入jar包commons-dbutils-1.6.jar

准备数据

创建表：

create table product(

pid int primary key,

pname varchar(20),

price double,

category_id varchar(32)

);

插入数据

INSERT INTO product(pid,pname,price,category_id) VALUES(1,'IBM',5500,'c001');

INSERT INTO product(pid,pname,price,category_id) VALUES(2,'长城',3200,'c001');

INSERT INTO product(pid,pname,price,category_id) VALUES(3,'惠普',5000,'c001');

INSERT INTO product(pid,pname,price,category_id) VALUES(4,'华为',3800,'c002');

INSERT INTO product(pid,pname,price,category_id) VALUES(5,'小米',2000,'c002');

INSERT INTO product(pid,pname,price,category_id) VALUES(6,'OPPO',3400,'c002');

INSERT INTO product(pid,pname,price,category_id) VALUES(7,'NOKIA',2000,'c002');

INSERT INTO product(pid,pname,price,category_id) VALUES(8,'佰草集',800,'c003');

INSERT INTO product(pid,pname,price,category_id) VALUES(9,'玉兰油',200,'c003');

INSERT INTO product(pid,pname,price,category_id) VALUES(10,'大宝',5,'c003');

QueryRunner 核心类介绍

构造方法指定数据源，提供数据源DataSource

构造方法

QueryRunner(DataSource) 创建核心类，并提供数据源，内部自己维护Connection

普通方法

update(String sql , Object ... params) 执行 DML 语句

query(String sql , ResultSetHandler , Object ... params) 执行 DQL 语句，并将

查询结果封装到对象中。

构造方法未指定数据源，在方法中提供连接

构造方法

QueryRunner() 创建核心类，没有提供数据源，在进行具体操作时，需要手劢提

供 Connection

普通方法

update(Connection conn , String sql , Object ... params) 使用提供的

Connection，完成 DML 语句

query(Connection conn , String sql , ResultSetHandler , Object ... params)

使用提供的 Connection，执行 DQL 诧句，幵将查询结果封装到对象中。

ArrayHandler 将结果集中的第一条记彔封装到一个 Object[]数组中，数组中的每一个元素

就是这条记彔中的每一个字段的值

BeanHandler 将结果集中第一条记彔封装到一个指定的 javaBean 中。

BeanListHandler 将结果集中每一条记彔封装到指定的 javaBean 中，将这些 javaBean 在封装

到 List 集合中

ColumnListHandler 将结果集中指定的列的字段值，封装到一个 List 集合中

KeyedHandler 将结果集中每一条记彔封装到 Map<String,Object>,在将这个 map 集合做

为另一个 Map 的 value,另一个 Map 集合的 key 是指定的字段的值。

MapHandler 将结果集中第一条记彔封装到了 Map<String,Object>集合中，key 就是字

段名称，value 就是字段值

MapListHandler 将结果集中每一条记彔封装到了 Map<String,Object>集合中，key 就是字

段名称，value 就是字段值，在将这些 Map 封装到 List 集合中。

ScalarHandler 它是用于单数据。例如 select count(*) from 表操作

注意：JavaBean

JavaBean 就是一个类，在开发中常用诧封装数据。具有如下特性

1.需要实现接口：java.io.Serializable ，通常实现接口这步骤省略了，不会影响程序。

2. 提供私有字段：private 类型字段名;

3. 提供 getter/setter 方法：

4. 提供无参构造

public class Product {

//字段名要与数据库的字段名一致，不然有可能会取不到数据

private String pid;

private String pname;

private Double price;

private String category_id;

// 省略getter/setter方法

}

基本了解即可；

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 203,547评论 6赞 477
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,399评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,428评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,599评论 1赞 274
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,612评论 5赞 365
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,577评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,941评论 3赞 395
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,603评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,852评论 1赞 297
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,605评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,693评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,375评论 4赞 318
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,955评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,936评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,172评论 1赞 259
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 43,970评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,414评论 2赞 342

JDBC连接池

推荐阅读更多精彩内容