数据库连接池
01.JDBC开发流程
-
加载驱动(只需要执行一次)
-
建立数据库连接(Connection)
-
执行SQL语句(Statement)
-
ResultSet接收结果集(查询)
-
断开连接、释放资源
? 在这种情况下,数据库连接对象是通过 DriverManager 来获取的,每次获取都需要向数据库申请获取连接,验证,执?完 SQL 语句后断开连接,这样的?式会造成资源的浪费,数据连接资源没有得到很好的重复利?。可以使用数据库连接池解决这个问题。相对于传统的JDBC开发流程,数据库连接池只是改变了前两个流程,加载驱动和建立数据库连接两个流程,其他流程照旧。
02.数据库连接池
数据库连接池的基本思想就是为数据库建??个缓冲池,预先向缓冲池中放??定数量的连接对象,当需要获取数据库连接的时候,只需要从缓冲池中取出?个对象,?完之后再放回到缓冲池中,供下?次 请求使?,做到了资源的重复利?,允许程序重复使??个现有的数据库连接对象,?不需要重新创建。当数据库连接池中没有空闲的连接时,新的请求就会进?等待队列,等待其他线程释放连接。
03.数据库连接池的实现
? JDBC 的数据库连接池使? javax.sql.DataSource 接?来完成的,DataSource 是 Java 官?提供的接?,使?的时候开发者并不需要??来实现该接?,可以使?第三?的?具,C3P0 是?个常?的第三?实现,实际开发中直接使? C3P0 即可完成数据库连接池的操作。
1.导入jar包
? 导入c3p0-0.9.1.2.jar
2.代码实现
package com.wildfire.c3p0;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.SQLException;
public class DateSource {
public static void main(String []args){
try {
//创建一个数据库连接池
ComboPooledDataSource comboPooledDataSource =new ComboPooledDataSource();
comboPooledDataSource.setDriverClass("com.mysql.cj.jdbc.Driver");
comboPooledDataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai");
comboPooledDataSource.setUser("root");
comboPooledDataSource.setPassword("xjmwan1314");
Connection connection =comboPooledDataSource.getConnection();
System.out.println(connection);
// 归还至数据库连接池 这里的close不同于传统连接方式中的close
connection.close();
} catch (PropertyVetoException e) {
e.printStackTrace();
} catch(SQLException e)
{
e.printStackTrace();
}
}
}
- C3p0拿到的Connection:com.mchange.v2.c3p0.impl.NewProxyConnection@3d36e4cd
package com.wildfire.c3p0;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class CommonConnection {
public static void main(String []args){
try {
//加载驱动
Class.forName("com.mysql.cj.jdbc.Driver");
//获取连接
String url = "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";
String user = "root";
String password = "xjmwan1314";
Connection connection = DriverManager.getConnection(url, user, password);
System.out.println(connection);
//释放资源
connection.close();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
- 传统方式拿到的Connection:com.mysql.cj.jdbc.ConnectionImpl@1ea9f6af
? 实际开发,将 C3P0 的配置信息定义在 xml ?件中,Java 程序只需要加载配置?件即可完成数据库连接 池的初始化操作。
1、配置?件的名字必须是 c3p0-config.xml (这个文件应该创建在src下)
2、初始化 ComboPooledDataSource 时,传?的参数必须是 c3p0-config.xml 中 named-config 标签 的 name 属性值。
<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
<named-config name="testc3p0">
<!-- 指定连接数据源的基本属性 -->
<property name="user">root</property>
<property name="password">xjmwan1314</property>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai</property>
<!-- 若数据库中连接数不?时, ?次向数据库服务器申请多少个连接 -->
<property name="acquireIncrement">5</property>
<!-- 初始化数据库连接池时连接的数量 -->
<property name="initialPoolSize">20</property>
<!-- 数据库连接池中的最?的数据库连接数 -->
<property name="minPoolSize">2</property>
<!-- 数据库连接池中的最?的数据库连接数 -->
<property name="maxPoolSize">40</property>
</named-config>
</c3p0-config>
package com.wildfire.c3p0;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.sql.Connection;
import java.sql.SQLException;
public class TestC3p0 {
public static void main(String []args){
try {
//创建c3p0这里需要修改
ComboPooledDataSource comboPooledDataSource=new ComboPooledDataSource("testc3p0");
Connection connection=comboPooledDataSource.getConnection();
System.out.println(connection);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
? 相对于传统的JDBC开发流程,数据库连接池只是改变了前两个流程,加载驱动和建立数据库连接两个流程,其他流程照旧。
注意:XML文件中的& 使用转义字符转换 &;
?