c3p0,DBCP,Druid(德鲁伊)数据库连接池
文章目录
1. JDBC数据库连接池的必要性
传统方式的连接数据库,存在的问题:
普通的 JDBC 数据库连接使用 来获取到连接的,每次向数据库请求建立连接的时候,都要将 加载到内存中,再验证用户名和密码(需要花费0.05s ~ 1s的时间 ) 。需要数据库连接的时候,就向数据库要求一个,执行完成后再断开连接,这样的方式,将会消耗大量的资源和时间。数据库的连接资源并没有得到一个很好的重复利用 ,如果同时有 几百人甚至 几千人 在线,频繁的进行数据库连接操作将占用很多的系统资源,严重的甚至会造成服务器的崩溃。本博客后面会作相应的演示,请大家继续往后看下去。对于每一次数据库连接,使用完后都得断开。否则,如果程序出现异常而未能关闭,将会导致数据库系统中的内存泄漏,最终将导致重启数据库。 何为Java的内存泄漏这种开发不能控制被创建的连接对象数,不能很好的管理连接的资源信息,系统资源会被毫无顾忌的分配出去,如连接过多,也可能导致内存泄漏,服务器崩溃。 1.2 JDBC 连接数据库
这里我们演示使用传统的数据库连接池,将向 Mysql数据库请求 5000 次的连接,看看会发生什么事情 ???
包如下错误: java.sql.: Data source of , from server: "Too many "
package Blogs.blogs04;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
public class JDBCTest {
public static void main(String[] args) {
// 读取配置文件信息
InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties"); // 默认读取的是src目录下的文件
try {
Properties properties = new Properties(); // 创建读取.properties后缀的配置文件的对象
properties.load(is); // 以简单的线性格式输入字符读取属性列表(关键字/元素对)
// 通过对象传入关键字获取到其中的信息
String driverClass = properties.getProperty("driverClass");
String url = properties.getProperty("url");
String user = properties.getProperty("user");
String password = properties.getProperty("password");
// 3. 加载/注册驱动
Class.forName(driverClass);
// 测试连接 5000 次
for(int i = 0; i 北京的天安门:
2.1 数据库连接池技术的优点 资源重用
由于数据库连接得以重用 ,避免了频繁创建,释放连接引起的大量性能开销。在减少系统消耗的基础上,另一方面也增加了系统运行环境的 平稳性 .
更快的系统反应速度
数据库连接池在初始化过程中,往往已经创建了若干个数据库连接存放于连接池 中备用。此时连接的初始化工作均已完成。对于业务请求处理而言,直接利用现有可用的连接,避免了数据库连接初始化和释放过程的时间开销,从而减少了系统的响应时间。
新的资源分配手段
对于多应用共享同一数据库的系统而言,可在应用层通过数据库连接池的配置,实现某一应用最大可用数据库连接数的限制,避免某一应用独占所有的数据库资源。
统一的连接管理,避免数据库连接泄漏
在较为完善的数据库连接池实现中,可根据预先的占用超时设定,强制回收被占用的连接,从而避免了常规数据库连接操作中可能出现的资源的泄漏问题。
3. 多种开源的数据库连接池
JDBC 的数据库连接池使用 javax.sql. 来表示, 只是一个接口,该接口通常由服务器(,,Tomcat) 提供实现,也有一些开源组织提供实现了:如下
通常被称为数据源,是在javax.sql.包下的一个接口。它包含连接池和管理连接池两部分,习惯上也经常把 称为连接池
用来取代 来获取 连接,获取速度快,同时可以大幅度提高数据库访问速度。
特别注意:
数据源(数据库连接池)和数据库连接不同,数据库连接池不需要创建多个,我们可以把它比作是生产数据库连接 的工厂,当我们的连接数量不够时,可以通过配置增加数据库连接池中的存储的连接,因此整个应用只需要一个数据库连接池(数据源)即可 。创建过多的数据库连接池,反而会适得其反。当访问数据库,操作数据库结束后,程序还是像以前一样关闭数据连接:.close(),不过使用数据库连接池不同的是,这里仅仅是把数据库连接 归还 数据库连接池,并不是真正关闭对数据库的连接。这个连接还在。
虽然它们使用都是 .close() 方法,但是所在的包路径是不同的,因为实现方式是不同的。在’com.mysql.cj.jdbc.’包中的是真正的关闭与数据库的连接,而在``包下是 归还 连接给数据库连接池。
javax.sql. 包下的 接口的文档:
4. C3P0数据库连接池
C3P0 是第三方的封装的数据库连接池,所以我们需要导入相关的 c3p0-0.9.1.2-jdk1.3.jar 包才可以使用:如下
相关的jar 文件,我已经提交到 Github ,Gitee 当中的了,如有需要的可以自行获取。
这里我使用的是 IDEA 编辑器,下面为我们的项目中导入 c3p0-0.9.1.2-jdk1.3.jar 包,操作如下:
这里就导入jar包成功了,后面的 DBCP,Druid 同样也是需要这样导入相关的 jar 包也是这样操作。
至于如何创建 c3p0 数据库连接池以及 获取其中的连接,我们可以打开我们下载到的 c3p0 文档中路径为 c3p0\c3p0-0.9.1.2 下找了一个名为 index.html 的帮助文档,打开它,里面有相关的 c3p0 的使用
打开显示如下效果:
import com.mchange.v2.c3p0.*;
...
ComboPooledDataSource cpds = new ComboPooledDataSource();
cpds.setDriverClass( "org.postgresql.Driver" ); //loads the jdbc driver
cpds.setJdbcUrl( "jdbc:postgresql://localhost/testdb" );
cpds.setUser("dbuser");
cpds.setPassword("dbpassword");
我们按照上面的创建 c3p0 的案例演示,创建 c3p0 数据库连接池并获取其中连接池中的连接 package Blogs.blogs04; import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.SQLException;
public class C3P0Test {
public static void main(String[] args) {
try {
// 通过传入配置参数,创建 c3p0 数据库连接池
ComboPooledDataSource cpds = new ComboPooledDataSource();
cpds.setDriverClass( "com.mysql.cj.jdbc.Driver" ); // 注册数据库驱动信息
cpds.setJdbcUrl( "jdbc:mysql://localhost:3306/test"); // 实际连接的数据库的url在网络中所在的位置
cpds.setUser("root"); // 用户名
cpds.setPassword("MySQL123"); // 密码
// 从c3p0 数据库连接池中获取连接数据库的对象
Connection connection = cpds.getConnection();
System.out.println(connection); // 打印连接的地址
System.out.println(connection.getClass()); // 打印显示实现该类的所在包路径
} catch (PropertyVetoException e) {
throw new RuntimeException(e); // 将编译异常转换为运行异常抛出
} catch (SQLException e) {
throw new RuntimeException(e);
}
}
}
关于如何编写 c3p0 的配置文件,同样查看其 index.html 的文档,如下:
con_test
30000
30
10
30
100
10
200
10
1
0
50
100
50
1000
0
5
1
1
1
5
50
需要注意的是:c3p0 的配置文件名是:c3p0-config.xml 是不可以修改的,默认使用的就是这个文件名. 我们使用的是 IDEA 编译器,下面是如果在 IDEA 中创建 xml 文件,有的 IDEA 中 new 没有 xml,这时候就需要我们自己手动配置了。具体操作如下: 接下来就是仿照上面 index.html 中 c3p0-config.xml 配置文件案例编写配置文件信息了。具体的编写的配置信息如下,大家可以直接复制粘贴上去,就可以直接使用了。不对,大家还要手动修改一下你所对应的 user用户名和 密码,以及 url 实际数据库的网络位置。其他的到没有什么问题了。
root
MySQL123
jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true
com.mysql.cj.jdbc.Driver
5
5
5
10
20
5
我们编写好相关的 c3p0-config.xml 配置文件以后,就可以通过访问配置文件中的信息,创建c3p0数据库连接池,以及获取其中的连接了。 具体代码实现如下: import com.mchange.v2.c3p0.ComboPooledDataSource; import javax.sql.DataSource;
import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.SQLException;
public class C3P0Test {
// 方式二: 通过读取配置文件中的信息,创建c3p0数据库连接池
public static void main(String[] args) {
// 创建c3p0数据库连接池
DataSource dataSource = new ComboPooledDataSource("helloc3p0");
try {
// 获取到数据库连接池中的连接
Connection connection = dataSource.getConnection();
System.out.println(connection); // 打印连接地址
System.out.println(connection.getClass()); // 打印类所在包下的路径
} catch (SQLException e) {
throw new RuntimeException(e); // 将编译异常转换为运行异常抛出
}
}
}
对 c3p0 数据库连接池进行一个封装,封装到 类当中。 错误演示: package Blogs.blogs04; import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.sql.Connection;
import java.sql.SQLException;
public class JDBCUtils {
public static Connection getConnection() {
// 通过 c3p0-config.xml 配置文件,创建c3p0数据库连接池
ComboPooledDataSource cpds = new ComboPooledDataSource("helloc3p0");
Connection connection = null;
try {
connection = cpds.getConnection();
} catch (SQLException e) {
throw new RuntimeException(e); // 将编译异常转换为运行异常抛出
}
return connection;
}
}
错误原因: 我们把创建 c3p0数据库连接池 放到了,调用返回连接中了。 把创建c3p0数据库连接池定义在方法中的后果是:我们每次调用该方法获取连接池,都会创建一个新的 c3p0 数据库连接池,一个连接池的创建的消耗远远比创建一个连接消耗来的大,而我们这么做就是:每创建一个连接就需要创建一个数据库连接池,还不如不用数据库连接池呢。 所以注意:一个应用使用一个数据库连接池就足够了,需要连接时,从数据库连接池中获取,如果数据库连接池中的连接不够了,可以通过配置增加数据库连接池中存有的连接,就把数据库连接池比作是一个生产连接的工厂。 综上所述:我们只要一个数据库连接池,所以我们可以将创建 c3p0 数据库连接池定义成静态 static 的类属性,和类一起加载到内存当中,只定义一次,所有对象共用这个数据库连接池 修改代码如下: package Blogs.blogs04; import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.sql.Connection;
import java.sql.SQLException;
public class JDBCUtils {
// 通过 c3p0-config.xml 配置文件,创建c3p0数据库连接池
private static ComboPooledDataSource cpds = new ComboPooledDataSource("helloc3p0"); // 作为类属性存在
public static Connection getC3p0Connection() {
Connection connection = null;
try {
connection = cpds.getConnection(); // static 静态不要使用 this的引用
} catch (SQLException e) {
throw new RuntimeException(e); // 将编译异常转换为运行异常抛出
}
return connection;
}
}
比较传统的 JDBC 连接数据库,和 C3P0 使用数据连接池的性能 jdbc 与 c3p0 都与数据库连接 5000 次,比较连接完后所消耗的时间: 传统的 JDBC 连接数据库 5000 次package Blogs.blogs04;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
public class JDBCTest {
public static void main(String[] args) {
// 读取配置文件信息
InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties"); // 默认读取的是src目录下的文件
try {
Properties properties = new Properties(); // 创建读取.properties后缀的配置文件的对象
properties.load(is); // 以简单的线性格式输入字符读取属性列表(关键字/元素对)
// 通过对象传入关键字获取到其中的信息
String driverClass = properties.getProperty("driverClass");
String url = properties.getProperty("url");
String user = properties.getProperty("user");
String password = properties.getProperty("password");
// 3. 加载/注册驱动
Class.forName(driverClass);
long start = System.currentTimeMillis(); // 获取到 5000 次连接数据库的前的时间点:单位:毫秒
// 测试连接 5000 次
for(int i = 0; i
[1]: https://xuan.ddwoo.top/index.php/archives/400/
[2]: https://xuan.ddwoo.top/index.php/archives/404/
本文共 2860 个字数,平均阅读时长 ≈ 8分钟