本文主要是介绍关于数据库连接池你不知道的事儿 C3P0 Druid,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
1.数据库连接池
1.1为什么需要数据库连接池
复习线程池
1. 初始化一些线程,提供给程序使用
2. 节约了资源,关于线程的开闭资源,节约了内存空间
3. 例如初始化5个线程对象,这里有10个线程目标
首先执行5个线程目标,其他线程目标等待
5个线程目标执行完毕,会执行其他线程,不会关闭线程。
数据库连接池
现在的代码有什么问题
每一次执行业务都需要申请新的数据库里链接,同时运行结束之后关闭资源。
会导致资源浪费,数据库压力过大,同时性能非常一般。
希望采用一种共享单车的形式
1. 投放一定数量的共享单车
2. 用户可以使用,用户使用完毕,【归还】共享单车平台
3. 市场需求非常大,可能会再次【投放】
1.2 数据库连接池考虑的问题
数据库连接池是用于管理数据库连接资源,属性和数据库连接对象
数据库连接必要的资源
1 .URL
2. user
3. password
4. DriverClass
连接池关于数据库连接对象的管理内容
1.初始化数量
2. 容量Max值为多少
3. 等待时间
数据库连接归还功能
该功能是自带功能
依然是调用原始的close方法,实际效果是归还数据库连接池
【代理】
1.3 常见数据库连接池
常见数据库连接池有哪些
1.C3P0
2.DBCP
3.Druid
常见数据库连接池对比
1.3.1 C3P0使用
使用流程:
1.导包
mchange-commons-java-0.2.17.jar
C3P0-0.9.5.2.jar
2.书写配置文件
3.创建核心类
配置文件
<!-- c3p0-config.xml需要存储于src目录下 -->
<c3p0-config><!-- 使用默认的配置读取连接池对象 --><default-config><!-- 连接参数 --><property name="driverClass">com.mysql.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql://localhost:3306/nzgp2001?useSSL=true</property><property name="user">root</property><property name="password">root</property><!-- 连接池参数 --><!--初始化申请的连接数量--><property name="initialPoolSize">5</property><!--最大的连接数量--><property name="maxPoolSize">10</property><!--超时时间--><property name="checkoutTimeout">3000</property></default-config><named-config name="otherc3p0"> <!-- 连接参数 --><property name="driverClass">com.mysql.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql://localhost:3306/company?useSSL=true</property><property name="user">root</property><property name="password">123456</property><!-- 连接池参数 --><property name="initialPoolSize">5</property><property name="maxPoolSize">8</property><property name="checkoutTimeout">1000</property></named-config>
</c3p0-config>
package util;import com.mchange.v2.c3p0.ComboPooledDataSource;import java.io.FileInputStream;
import java.io.IOException;
import java.sql.*;
import java.util.Properties;/*** JDBC工具类,负责数据库连接对象和数据库资源关闭** @author Anonymous 2020/3/24 10:08*/
public class JdbcUtil {/*** 默认加载 default-config配置*/private static ComboPooledDataSource pool = new ComboPooledDataSource();/*指定选择c3p0配置文件中哪一个配置private static ComboPooledDataSource pool = new ComboPooledDataSource("otherc3p0");*//*** 返回数据库连接对象,连接失败返回null** @return java.sql.Connection 数据库连接对象*/public static Connection getConnection() {Connection connection = null;try {connection = pool.getConnection();} catch (SQLException e) {e.printStackTrace();}return connection;}/*以下三个方法实际上都是执行同一个方法,使用这种方式1. 简化代码结构2. 规范化所有的操作*//*** 处理数据库操作对应的资源问题** @param connection java.sql.Connection 数据库连接对象*/public static void close(Connection connection) {close(connection, null, null);}/*** 处理数据库操作对应的资源问题** @param connection java.sql.Connection 数据库连接对象* @param statement java.sql.Statement 数据库SQL语句搬运工对象*/public static void close(Connection connection, Statement statement) {close(connection, statement, null);}/*** 处理数据库操作对应的资源问题** @param connection java.sql.Connection 数据库连接对象* @param statement java.sql.Statement 数据库SQL语句搬运工对象* @param resultSet java.sql.ResultSet 数据库查询结果集对象*/public static void close(Connection connection, Statement statement, ResultSet resultSet) {try {if (resultSet != null) {resultSet.close();}if (statement != null) {statement.close();}if (connection != null) {connection.close();}} catch (SQLException e) {e.printStackTrace();}}
}
1.3.2 Druid使用
使用流程:
1. 导包
druid-1.0.9.jar
2. 书写配置文件
配置文件是一个druid.properties文件
3. 创建核心类
# 文件名 druid.properties 存储在src目录下
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test?useSSL=true
username=root
password=root# 初始化数据库连接池容量
initialSize=5# 最大容量
maxActive=20# TimeOut 等待超时时间
maxWait=2000
package util;import com.alibaba.druid.pool.DruidDataSourceFactory;import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.*;
import java.util.Properties;/*** JDBC工具类,负责数据库连接对象和数据库资源关闭** @author Anonymous 2020/3/24 10:08*/
public class JdbcUtil {/*** 数据库资源*/private static DataSource ds;static {try {// 加载Properties文件Properties properties = new Properties();properties.load(new FileInputStream("./src/druid.properties"));// 已经完成数据库连接池操作ds = DruidDataSourceFactory.createDataSource(properties);} catch (Exception e) {e.printStackTrace();}}/*** 返回数据库连接对象,连接失败返回null** @return java.sql.Connection 数据库连接对象*/public static Connection getConnection() {Connection connection = null;try {connection = ds.getConnection();} catch (SQLException e) {e.printStackTrace();}return connection;}/*以下三个方法实际上都是执行同一个方法,使用这种方式1. 简化代码结构2. 规范化所有的操作*//*** 处理数据库操作对应的资源问题** @param connection java.sql.Connection 数据库连接对象*/public static void close(Connection connection) {close(connection, null, null);}/*** 处理数据库操作对应的资源问题** @param connection java.sql.Connection 数据库连接对象* @param statement java.sql.Statement 数据库SQL语句搬运工对象*/public static void close(Connection connection, Statement statement) {close(connection, statement, null);}/*** 处理数据库操作对应的资源问题** @param connection java.sql.Connection 数据库连接对象* @param statement java.sql.Statement 数据库SQL语句搬运工对象* @param resultSet java.sql.ResultSet 数据库查询结果集对象*/public static void close(Connection connection, Statement statement, ResultSet resultSet) {try {if (resultSet != null) {resultSet.close();}if (statement != null) {statement.close();}if (connection != null) {connection.close();}} catch (SQLException e) {e.printStackTrace();}}
}
这篇关于关于数据库连接池你不知道的事儿 C3P0 Druid的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!