数据库连接池

传统获取Connection问题分析

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

案例：

package com.hspedu.jdbc.datasource;

import com.hspedu.jdbc.utils.JDBCUtils;
import org.junit.jupiter.api.Test;

import java.sql.Connection;

public class ConQuestion {

    //代码 连接mysql 5000次
    @Test
    public void testCon(){
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++){
            //使用传统jdbc连接方式
            Connection connection = JDBCUtils.getConnection();

            //可能会抛出too many connections的异常

            //再看看，如果得到连接就立即关闭，总共会耗时多久
            JDBCUtils.close(null, null, connection);
        }
        long end = System.currentTimeMillis();
        System.out.println("耗时 = " + (end - start));//耗时 = 6598
    }
}

数据库连接池原理

• 基本介绍

  1. 预先在缓冲池中放入一定数量的连接，当需要建立数据库连接时，只需要从“缓冲池”中取出一个，使用完毕之后再放回去（放回连接，其实就是指程序不再引用这个连接）。
  2. 数据库连接池负责分配、管理和释放数据库连接，它允许应用程序重复使用一个现有的数据库连接，而不是重新建立一个。
  3. 当应用程序向连接池请求的连接数超过最大连接数量时，这些请求将被加入到等待队列中。

  原理示意图：

  

  

常用的数据库连接池

​ JDBC 的数据库连接池使用 javax.sql.DateSource 来表示，DataSource 只是一个接口，该接口通常由第三方提供实现。

数据库连接池种类：**

1. C3P0 数据库连接池：速度相对较慢，稳定性不错 （hibernate，spring）；
2. DBCP 数据库连接池：速度相对C3P0较快，但不稳定；
3. Proxool 数据库连接池：有监控连接池状态的功能，稳定性较C3P0差一点；
4. BoneCP 数据库连接池：速度快；
5. Druid（德鲁伊） 数据库连接池：是阿里提供的数据库连接池，集DBCP、C3P0、Proxool优点于一身的数据库连接池；

C3P0的使用

需要自行导入相关的jar包。

1. 方式1：相关参数，在程序中指定user，url， password。
2. 方式2： 使用配置文件的模板来完成。

代码演示：

package com.hspedu.jdbc.datasource;

import com.mchange.v2.c3p0.ComboPooledDataSource;
import org.junit.jupiter.api.Test;

import java.beans.PropertyVetoException;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

public class C3P0_ {

    //方式1：相关参数，在程序中指定user, url, password
    @Test
    public void testC3P0_01() throws IOException, PropertyVetoException, SQLException {

        //1. 创建一个数据源对象
        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource();

        //2. 通过配置文件获取相关连接信息
        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.setDriverClass(driver);
        comboPooledDataSource.setJdbcUrl(url);
        comboPooledDataSource.setUser(user);
        comboPooledDataSource.setPassword(password);

        //设置初始化连接数
        comboPooledDataSource.setInitialPoolSize(10);

        //最大连接数
        comboPooledDataSource.setMaxPoolSize(50);

        //获取连接
        //测试连接池的效率，连接5000次
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++) {
            Connection connection = comboPooledDataSource.getConnection();//这个方法就是从DateSource接口实现的
//            System.out.println("连接OK");

            //关闭
            connection.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("c3p0 5000次连接mysql 耗时 = " + (end - start));//c3p0 5000次连接mysql 耗时 = 280，之前传统的耗时 = 6598
    }


    //第二种方式， 使用配置文件的模板来完成
    //1. 将c3p0 提供的 c3p0.config.xml 拷贝到src目录
    //2. 该文件指定了连接数据库和连接池的相关参数
    @Test
    public void testC3P0_02() throws SQLException {
        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource("hsp_edu");//填入数据源名称

        long start = System.currentTimeMillis();
        for (int i = 0; i < 500000; i++) {
            Connection connection = comboPooledDataSource.getConnection();//这个方法就是从DateSource接口实现的
//            System.out.println("连接OK");

            //关闭
            connection.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("c3p0 第二种方式500000次连接mysql 耗时 = " + (end - start));//c3p0 第二种方式500000次连接mysql 耗时 = 1452

    }
}

配置文件 c3p0-config.xml：

<c3p0-config>
        <named-config name="hsp_edu">
            <!--  连接参数 -->
            <property name="driverClass">com.mysql.jdbc.Driver</property>
            <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbc_learning</property>
            <property name="user">root</property>
            <property name="password">root</property>

            <!-- 连接池参数 -->
            <!-- 每次增长的连接数 -->
            <property name="acquireIncrement">5</property>
            <!-- 初始的连接数 -->
            <property name="initialPoolSize">5</property>
            <!-- 最大连接数 -->
            <property name="maxPoolSize">10</property>
            <!-- 最小连接数 -->
            <property name="minPoolSize">5</property>
            <!-- 每个连接对象可连接的最多的命令对象数 -->
            <property name="maxStatementPerConnection">2</property>
        </named-config>
</c3p0-config>

Druid（德鲁伊）的使用

需要自行导入相关的jar包。

代码演示：

package com.hspedu.jdbc.datasource;

import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.junit.jupiter.api.Test;

import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.util.Properties;

public class Druid_ {

    @Test
    public void testDruid() throws Exception {
        //1. 加入 Druid jar包
        //2. 加入 配置文件 druid.properties，将该文件拷贝到项目的src目录
        //3. 创建 Properties 对象
        Properties properties = new Properties();
        properties.load(new FileInputStream("src\\druid.properties"));

        //4. 创建一个指定参数的数据库连接池
        DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);

        long start = System.currentTimeMillis();
        for (int i = 0; i < 500000; i++) {
            Connection connection = dataSource.getConnection();
//            System.out.println("连接成功");
            connection.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("druid连接池， 连接500000次 耗时 = " + (end - start));//druid连接池， 连接500000次 耗时 = 549

    }
}

配置文件 druid.properties：

#key=value
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbc_learning?rewriteBatchedStatements=true
username=root
password=root
#initial connection size
initialSize=10
#min idle connection size
minIdle=5
#max active connection size
maxActive=50
#max wait time (5000 mil seconds)
maxWait=5000

本栏目推荐文章
• Jmeter 如何连接mysql数据库？
• SQL Server 检测是不是数字型数据的两种方法
• 如何通过Navicat把MySQL远程数据库导入到本地数据库
• 和利时MACS6通过dat文件实现任意时间范围与测点的历史数据提取与科研分析
• 深入理解spring框架：剖析多线程模式下数据库连接
• 数据可视化是如何帮助大型企业提高效率的？
• redis 数据库
• openpyxl模块--------------------------------重复数据
• Django客户端应用1向服务端应用2发送POST请求并接收解析数据
• 数据可视化是如何帮助我们高效了解数据的？

数据库 数据 JDBC p5数据库 数据jdbc p5 数据jdbc 数据库 数据jdbc 数据库 数据jmeter jdbc jdbc数据库 数据 问题 数据库 数据 流程jdbc jmeter-jdbc数据库 数据jmeter sharding-jdbc sharding数据库 数据 sqlite-jdbc版本 数据sqlite 写法 数据库 数据jdbc