关于数据库连接池你不知道的事儿 C3P0 Druid

2024年4月18日 互联网

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();}}
}

     

最新文章