-
day48-JDBC和连接池04
10.数据库连接池
10.1传统连接弊端分析
- 传统获取Connection问题分析
- 传统的 JDBC 数据库连接使用DriverManager来获取,每次向数据库建立连接的时候都要将Connection加载到内存中,再验证IP地址,用户名和密码(约0.05s~1s时间)。需要数据库连接的时候,就向数据库要求一个,频繁地进行数据库连接操作将会占用很多的系统资源,容易造成服务器崩溃
- 每一次数据库连接,使用完后都得断开,如果程序出现异常而未能关闭,将导致数据库内存泄漏,最终将导致重启数据库
- 传统获取连接的方式,不能控制创建的连接数量,如连接过多,也可能导致内存泄漏,MySQL崩溃
- 解决传统开发中的数据库连接问题,可以采用数据库连接池技术(connection pool)

例子1
|
package li.jdbc.datasource; |
|
|
|
import li.jdbc.utils.JDBCUtils; |
|
import org.junit.Test; |
|
|
|
import java.sql.Connection; |
|
|
|
public class ConQuestion { |
|
|
|
public void testCon(){ |
|
for (int i = 0; i < 5000; i++) { |
|
//使用传统的jdbc方式得到连接 |
|
Connection connection = JDBCUtils.getConnection(); |
|
//这里做一些工作.... |
|
//不关闭连接资源,使其一直占用 |
|
} |
|
} |
|
} |
出现的异常:
|
java.lang.RuntimeException: com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Data source rejected establishment of connection, message from server: "Too many connections" |
例子2:
|
package li.jdbc.datasource; |
|
|
|
import li.jdbc.utils.JDBCUtils; |
|
import org.junit.Test; |
|
|
|
import java.sql.Connection; |
|
|
|
public class ConQuestion { |
|
|
|
|
|
public void testCon(){ |
|
long start = System.currentTimeMillis(); |
|
System.out.println("开始连接..."); |
|
for (int i = 0; i < 5000; i++) { |
|
//使用传统的jdbc方式得到连接 |
|
Connection connection = JDBCUtils.getConnection(); |
|
//这里做一些工作.... |
|
JDBCUtils.close(null,null,connection);//每次连接完都正常关闭连接资源 |
|
} |
|
long end = System.currentTimeMillis(); |
|
System.out.println("传统方式连接5000次耗时:"+(end-start));//20171ms |
|
} |
|
} |
每次连接完都正常关闭连接资源,可以看到5000次连接数据库需要耗时20171ms

10.2数据库连接池原理
- 数据库连接池基本介绍
- 预先在缓冲池中放入一定数量的连接,当需要建立数据库连接时,只需从“缓冲池”中取出一个,使用完毕之后再将连接放回连接池中。
- 数据库连接池负责分配、管理和释放数据库连接,它允许应用程序重复使用一个现有的数据库连接,而不是重新建立一个
- 当应用程序向连接池请求的连接数超过最大连接数量时,这些请求将被加入到等待队列中
- 数据库连接池种类
- JDBC的数据库连接池使用javax.sql.DataSource来表示,DataSource只是一个接口,该接口通常由第三方提供实现 [提供相应的jar包]
- C3P0数据库连接池,速度相对较慢,稳定性不错(hibernate,spring)
- DBCP数据库连接池,速度相对C3P0较快,但不稳定
- Proxool数据库连接池,有监控连接池状态的功能,稳定性较C3P0差一点
- BoneCP数据库连接池,速度快
- Druid(德鲁伊)是阿里提供的数据库连接池,集DBCP、C3P0、Proxool优点于一身的数据库连接池
10.3C3P0方式
10.3.1方式1-相关参数在程序中指定
使用代码实现c3p0数据库连接池
首先在网上下载c3p0jar包,并将其复制到项目的lib文件夹中,右键选择add as library


|
package li.jdbc.datasource; |
|
|
|
import com.mchange.v2.c3p0.ComboPooledDataSource; |
|
import org.junit.Test; |
|
|
|
import java.io.FileInputStream; |
|
import java.sql.Connection; |
|
import java.util.Properties; |
|
|
|
/** |
|
* 演示c3p0的使用 |
|
*/ |
|
public class C3P0_ { |
|
|
|
//方式1:相关参数在程序中指定,user,url,password等 |
|
|
|
public void testC3P0_01() throws Exception { |
|
|
|
//1.创建一个数据源对象 |
|
ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource(); |
|
//2.通过配置文件mysql.properties获取相关的连接信息 |
|
Properties properties = new Properties(); |
|
properties.load(new FileInputStream("src\\mysql.properties")); |
|
//读取相关的属性值 |
|
String user = properties.getProperty("user"); |
|
String password = properties.getProperty("password"); |
|
String url = properties.getProperty("url"); |
|
String driver = properties.getProperty("driver"); |
|
|
|
//给数据源 comboPooledDataSource设置相关的参数 |
|
//注意:连接管理 是由comboPooledDataSource来管理 |
|
comboPooledDataSource.setDriverClass(driver); |
|
comboPooledDataSource.setJdbcUrl(url); |
|
comboPooledDataSource.setUser(user); |
|
comboPooledDataSource.setPassword(password); |
|
|
|
//设置初始化连接数 |
|
comboPooledDataSource.setInitialPoolSize(10); |
|
//最大连接数--连接请求超过最大连接数据将进入等待队列 |
|
comboPooledDataSource.setMaxPoolSize(50); |
|
//测试连接池的效率 |
|
long start = System.currentTimeMillis(); |
|
for (int i = 0; i < 5000; i++) { |
|
Connection connection = comboPooledDataSource.getConnection();//这个方法就是从DataSource 接口实现的 |
|
//System.out.println("连接成功"); |
|
connection.close(); |
|
} |
|
long end = System.currentTimeMillis(); |
|
System.out.println("c3p0 5000次连接mysql 耗时=" + (end - start)); |
|
} |
|
} |
c3p0方式一:5000次的连接耗时553ms

10.3.2方式2-使用配置文件模板来完成
首先如10.3.1一样将jar包加入到项目中
然后将c3p0提供的配置文件c3p0-config.xml复制到src目录下,该文件指定了连接数据库和连接池的相关参数
c3p0-config.xml:
|
<c3p0-config> |
|
|
|
<!--数据源的名称,代表连接池,名字是随意的 --> |
|
<named-config name="hello"> |
|
<!-- 驱动类 --> |
|
<property name="driverClass">com.mysql.jdbc.Driver</property> |
|
<!-- url--> |
|
<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/hsp_db02</property> |
|
<!-- 用户名 --> |
|
<property name="user">root</property> |
|
<!-- 密码 --> |
|
<property name="password">123456</property> |
|
<!-- 每次增长的连接数--> |
|
<property name="acquireIncrement">5</property> |
|
<!-- 初始的连接数 --> |
|
<property name="initialPoolSize">10</property> |
|
<!-- 最小连接数 --> |
|
<property name="minPoolSize">5</property> |
|
<!-- 最大连接数 --> |
|
<property name="maxPoolSize">50</property> |
|
|
|
<!-- 可连接的最多的命令对象数 --> |
|
<property name="maxStatements">5</property> |
|
|
|
<!-- 每个连接对象可连接的最多的命令对象数 --> |
|
<property name="maxStatementsPerConnection">2</property> |
|
</named-config> |
|
</c3p0-config> |
测试程序:
|
package li.jdbc.datasource; |
|
|
|
import com.mchange.v2.c3p0.ComboPooledDataSource; |
|
import org.junit.Test; |
|
|
|
import java.sql.Connection; |
|
|
|
/** |
|
* 演示c3p0的使用 |
|
*/ |
|
public class C3P0_ { |
|
|
|
//方式2:使用配置文件模板来完成 |
|
//将c3p0提供的配置文件c3p0-config.xml复制到src目录下 |
|
// 该文件指定了连接数据库和连接池的相关参数 |
|
|
|
public void testC3P0_02() throws Exception { |
|
ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource("hello"); |
|
//测试5000次连接诶mysql |
|
long start = System.currentTimeMillis(); |
|
System.out.println("开始执行..."); |
|
for (int i = 0; i < 5000; i++) { |
|
Connection connection = comboPooledDataSource.getConnection(); |
|
//System.out.println("连接成功"); |
|
connection.close(); |
|
} |
|
long end = System.currentTimeMillis(); |
|
System.out.println("c3p0的第二种方式 5000次连接mysql 耗时=" + (end - start)); |
|
|
|
} |
|
} |
c3p0的第二种方式 5000次连接mysql 耗时=533ms

10.4德鲁伊连接池
首先将Druid的jar包复制到项目的lib文件夹中,点击右键,选择add as library

jar包在该网站可以下载 Central Repository: com/alibaba/druid (maven.org)
然后将提供的配置文件的druid.properties(文件名可以随意)复制到src目录下
druid.properties:
|
#key=value |
|
driverClassName=com.mysql.jdbc.Driver |
|
url=jdbc:mysql://localhost:3306/hsp_02?rewriteBatchedStatements=true |
|
#url=jdbc:mysql://localhost:3306/hsp_02 |
|
username=root |
|
password=123456 |
|
#initial connection Size |
|
initialSize=10 |
|
#min idle connecton size |
|
minIdle=5 |
|
#max active connection size |
|
maxActive=50 |
|
#max wait time (5000 mil seconds) 在等待队列中的最大等待时间 |
|
maxWait=5000 |
测试程序:
|
package li.jdbc.datasource; |
|
|
|
import com.alibaba.druid.pool.DruidDataSourceFactory; |
|
import org.junit.Test; |
|
|
|
import javax.sql.DataSource; |
|
import java.io.FileInputStream; |
|
import java.sql.Connection; |
|
import java.util.Properties; |
|
|
|
/** |
|
* 测试德鲁伊Druid的使用 |
|
*/ |
|
public class Druid_ { |
|
|
|
|
|
public void testDruid() throws Exception { |
|
//1.加入Druid包 |
|
//2.加入配置文件 druid.properties,将该文件复制到项目的src目录下面 |
|
//3.创建Properties对象,读取配置文件 |
|
Properties properties = new Properties(); |
|
properties.load(new FileInputStream("src\\druid.properties")); |
|
|
|
//4.创建一个指定参数的数据库连接池,Druid连接池 |
|
DataSource dataSource = |
|
DruidDataSourceFactory.createDataSource(properties); |
|
long start = System.currentTimeMillis(); |
|
for (int i = 0; i < 5000; i++) { |
|
Connection connection = dataSource.getConnection(); |
|
//System.out.println("连接成功!"); |
|
connection.close(); |
|
} |
|
long end = System.currentTimeMillis(); |
|
System.out.println("Druid连接池 操作5000次耗时="+(end-start)); |
|
} |
|
} |
德鲁伊连接池操作5000次的总耗时为434ms

5000次连接池的时间和c3p0的时间差不多,但是当连接数量到50万、500万时差距就会很明显,因此在实际开发中推荐使用Druid连接池。
10.4.1德鲁伊工具类
将之前7.1的JDBCUtils工具类改为Druid(德鲁伊)实现
通过德鲁伊数据库连接池获取连接对象
工具类:JDBCUtilsByDruid
|
package li.jdbc.datasource; |
|
|
|
import com.alibaba.druid.pool.DruidDataSourceFactory; |
|
|
|
import javax.sql.DataSource; |
|
import java.io.FileInputStream; |
|
import java.sql.Connection; |
|
import java.sql.ResultSet; |
|
import java.sql.SQLException; |
|
import java.sql.Statement; |
|
import java.util.Properties; |
|
|
|
/** |
|
* 基于Druid数据库连接池的工具类 |
|
*/ |
|
public class JDBCUtilsByDruid { |
|
|
|
private static DataSource ds; |
|
|
|
//在静态代码块完成ds的初始化 |
|
//静态代码块在加载类的时候只会执行一次,因此数据源也只会初始化一次 |
|
static { |
|
Properties properties = new Properties(); |
|
try { |
|
properties.load(new FileInputStream("src\\druid.properties")); |
|
ds = DruidDataSourceFactory.createDataSource(properties); |
|
} catch (Exception e) { |
|
e.printStackTrace(); |
|
} |
|
} |
|
|
|
//编写getConnection方法 |
|
public static Connection getConnection() throws SQLException { |
|
return ds.getConnection(); |
|
} |
|
|
|
//关闭连接(注意:在数据库连接池技术中,close不是真的关闭连接,而是将Connection对象放回连接池中) |
|
public static void close(ResultSet resultSet, Statement statemenat, Connection connection) { |
|
try { |
|
if (resultSet != null) { |
|
resultSet.close(); |
|
} |
|
if (statemenat != null) { |
|
statemenat.close(); |
|
} |
|
if (connection != null) { |
|
connection.close(); |
|
} |
|
} catch (SQLException e) { |
|
throw new RuntimeException(e); |
|
} |
|
} |
|
} |
测试程序:JDBCUtilsByDruid_Use
|
package li.jdbc.datasource; |
|
|
|
import org.junit.Test; |
|
|
|
import java.sql.Connection; |
|
import java.sql.PreparedStatement; |
|
import java.sql.ResultSet; |
|
import java.sql.SQLException; |
|
import java.util.Date; |
|
|
|
public class JDBCUtilsByDruid_Use { |
|
|
|
|
|
public void testSelect() { |
|
System.out.println("使用druid方式完成"); |
|
//1.得到连接 |
|
Connection connection = null; |
|
//2.组织一个sql语句 |
|
String sql = "Select * from actor where id >=?"; |
|
//3.创建PreparedStatement对象 |
|
PreparedStatement preparedStatement = null; |
|
ResultSet set = null; |
|
try { |
|
connection = JDBCUtilsByDruid.getConnection(); |
|
/** |
|
* Connection是个接口,是由sun公司定义的规范,根据Connection的实现类不同,close方法也不同 |
|
* mysql的厂商的实现类是直接把连接关闭,Alibaba的实现是将引用的连接放回到连接池等待下一次引用 |
|
* 因此在Druid中的close方法并不是真正地关闭连接 |
|
*/ |
|
System.out.println(connection.getClass());//运行类型 class com.alibaba.druid.pool.DruidPooledConnection |
|
|
|
preparedStatement = connection.prepareStatement(sql); |
|
preparedStatement.setInt(1, 1);//给?号赋值 |
|
//执行sql,得到结果集 |
|
set = preparedStatement.executeQuery(); |
|
//遍历该结果集 |
|
while (set.next()) { |
|
int id = set.getInt("id"); |
|
String name = set.getString("name"); |
|
String sex = set.getString("sex"); |
|
Date borndate = set.getDate("borndate"); |
|
String phone = set.getString("phone"); |
|
System.out.println(id + "\t" + name + "\t" + sex + "\t" + borndate + "\t" + phone); |
|
} |
|
} catch (SQLException e) { |
|
e.printStackTrace(); |
|
} finally { |
|
//关闭资源(不是真的关闭连接,而是将Connection对象放回连接池中) |
|
JDBCUtilsByDruid.close(set, preparedStatement, connection); |
|
} |
|
} |
|
} |

注意:
Connection是个接口,是由sun公司定义的规范,根据Connection的实现类不同,close方法也不同
mysql的厂商的实现类是直接把连接关闭,Alibaba的实现是将引用的连接放回到连接池等待下一次引用
因此在Druid中的close方法并不是真正地关闭连接,而是将Connection对象放回连接池中
出处:https://www.cnblogs.com/liyuelian/p/16797382.html