开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> MySQL攻略 - 数据库连接池引出与使用，C3P0、德鲁伊链接案例与德鲁伊工具包使用 -> 正文阅读

[大数据]MySQL攻略 - 数据库连接池引出与使用，C3P0、德鲁伊链接案例与德鲁伊工具包使用

引出数据库连接池

编写程序完成连接Mysql5000次的操作
看看有什么问题，耗时又是多少 = > 数据库连接池

测试代码

package com.taotao.jdbc.datasource;

import com.taotao.jdbc.utils.JDBCUtils;
import org.junit.Test;

import java.sql.Connection;

/**
 * Create By 刘鸿涛
 * 2022/3/4 12:33
 */
@SuppressWarnings({"all"})
public class ConQuestion {

    //代码 连接mysql 5000次
    @Test
    public void testCon(){
        for (int i = 0; i < 5000; i++) {
            //使用传统的jdbc方式，得到连接
            Connection connection = JDBCUtils.getConnection();
            //做一些工作，比如得到PreparedStatement，发送sql
            //不关闭，一直往mysql开启连接....

        }
    }
}

报出异常（too many connections）

请添加图片描述

测试连接后关闭（耗时）

测试代码

package com.taotao.jdbc.datasource;

import com.taotao.jdbc.utils.JDBCUtils;
import org.junit.Test;

import java.sql.Connection;

/**
 * Create By 刘鸿涛
 * 2022/3/4 12:33
 */
@SuppressWarnings({"all"})
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();
            //做一些工作，比如得到PreparedStatement，发送sql

            //测试连接后及时关闭情况
            JDBCUtils.close(null,null,connection);

        }
        long end = System.currentTimeMillis();
        System.out.println("连接后及时关闭时，需要耗时：" + (end - start) + "毫秒");

    }
}

测试结果

9088ms

请添加图片描述

传统获取Connection问题分析

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

做图分析

请添加图片描述

数据库连接池种类

JDBC的数据库连接池使用javax.sql.DataSource 来表示，DataSource只是一个接口，该接口通常由第三方提供实现【提供jar包】
C3P0数据库连接池，速度相对较慢，稳定性不错（hibernate，spring）
DBCP数据库连接池，速度相对C3P0较快，但不稳定
Proxool数据库连接池，有监控连接池状态的功能，稳定性较c3p0差一点
BoneCP数据库连接池，速度快
Druid（德鲁伊）是阿里提供的数据库连接池，集DBCP，C3P0、Proxool优点于一身的数据库连接池

C3P0应用实例

使用代码实现c3p0数据库连接池，配置文件放src目录下

案例代码

package com.taotao.jdbc.datasource;

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

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

/**
 * Create By 刘鸿涛
 * 2022/3/5 8:15
 * 演示c3p0的使用
 */
@SuppressWarnings({"all"})
public class C3P0_ {
    @Test
    //方式1：相关参数，在程序中指定user，url，password等
    public void testC3P0_01() throws Exception {
        //1.创建一个数据源对象
        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource();
        //2.通过配置文件mysql.properties 获取相关连接的信息
        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 来管理
        comboPooledDataSource.setDriverClass(driver);
        comboPooledDataSource.setJdbcUrl(url);
        comboPooledDataSource.setUser(user);
        comboPooledDataSource.setPassword(password);

        //设置初始化连接数
        comboPooledDataSource.setInitialPoolSize(10);
        //设置最大连接数
        comboPooledDataSource.setMaxPoolSize(50);
        Connection connection = comboPooledDataSource.getConnection();  //这个方法就是从 DataSource接口实现
        System.out.println("连接ok");
        connection.close(); //关闭connection
    }
}

测试C3P0

package com.taotao.jdbc.datasource;

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

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

/**
 * Create By 刘鸿涛
 * 2022/3/5 8:15
 * 演示c3p0的使用
 */
@SuppressWarnings({"all"})
public class C3P0_ {
    @Test
    //方式1：相关参数，在程序中指定user，url，password等
    public void testC3P0_01() throws Exception {
        //1.创建一个数据源对象
        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource();
        //2.通过配置文件mysql.properties 获取相关连接的信息
        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 来管理
        comboPooledDataSource.setDriverClass(driver);
        comboPooledDataSource.setJdbcUrl(url);
        comboPooledDataSource.setUser(user);
        comboPooledDataSource.setPassword(password);

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

        //测试连接效率
        System.out.println("连接开始");
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++) {
            Connection connection = comboPooledDataSource.getConnection();  //这个方法就是从 DataSource接口实现
            connection.close(); //关闭connection
        }
        long end = System.currentTimeMillis();
        System.out.println("连接结束，耗时：" + (end - start));
    }
}

测试结果

649ms

请添加图片描述

XML文件测试连接

xml文件

<c3p0-config>
<!-- 数据源名称代表连接池 -->
  <named-config name="taotao">
<!-- 驱动类 -->
  <property name="driverClass">com.mysql.jdbc.Driver</property>
  <!-- url-->
  	<property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/taotao_db01</property>
  <!-- 用户名 -->
  		<property name="user">root</property>
  		<!-- 密码 -->
  	<property name="password">12345</property>
  	<!-- 每次增长的连接数-->
    <property name="acquireIncrement">5</property>
    <!-- 初始的连接数 -->
    <property name="initialPoolSize">10</property>
    <!-- 最小连接数 -->
    <property name="minPoolSize">5</property>
   <!-- 最大连接数 -->
    <property name="maxPoolSize">10</property>

	<!-- 可连接的最多的命令对象数 -->
    <property name="maxStatements">5</property> 
    
    <!-- 每个连接对象可连接的最多的命令对象数 -->
    <property name="maxStatementsPerConnection">2</property>
  </named-config>
</c3p0-config>

测试代码

package com.taotao.jdbc.datasource;

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

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

/**
 * Create By 刘鸿涛
 * 2022/3/5 8:15
 * 演示c3p0的使用
 */
@SuppressWarnings({"all"})
public class C3P0_ {

    //第二种方式，使用配置文件模板来完成
    //1.将c3p0提供的 c3p0.config.xml 快被盗 src目录下
    //2.该文件指定了连接数据库和连接池的相关参数
    @Test
    public void testC3P0_02() throws SQLException {

        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource("taotao");
        Connection connection = comboPooledDataSource.getConnection();
        System.out.println("连接成功");
        connection.close();
    }
}

测试结果

请添加图片描述

测试XML连接速度

    @Test
    public void testC3P0_02() throws SQLException {

        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource("taotao");

        //测试速度
        System.out.println("开始连接");
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++) {
            Connection connection = comboPooledDataSource.getConnection();
            connection.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("连接耗时：" + (end - start));

    }

测试结果

734ms

请添加图片描述

德鲁伊应用实例

案例代码

package com.taotao.jdbc.datasource;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.junit.Test;

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

/**
 * Create By 刘鸿涛
 * 2022/3/5 12:02
 * 测试druid的使用
 */
@SuppressWarnings({"all"})
public class Druid_ {
    @Test
    public void testDruid() throws Exception {
        //1.加入 Druid jar包
        //2.加入 配置文件，将该文件拷贝项目的src目录
        //3.创建Properties对象，读取配置文件
        Properties properties = new Properties();
        properties.load(new FileInputStream("src\\druid.properties"));

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

        Connection connection = dataSource.getConnection();
        System.out.println("连接成功");
        connection.close();
    }
}

测试德鲁伊

package com.taotao.jdbc.datasource;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.junit.Test;

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

/**
 * Create By 刘鸿涛
 * 2022/3/5 12:02
 * 测试druid的使用
 */
@SuppressWarnings({"all"})
public class Druid_ {
    @Test
    public void testDruid() throws Exception {
        //1.加入 Druid jar包
        //2.加入 配置文件，将该文件拷贝项目的src目录
        //3.创建Properties对象，读取配置文件
        Properties properties = new Properties();
        properties.load(new FileInputStream("src\\druid.properties"));

        //4.创建一个指定参数的数据库连接池,Druid连接池
        DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++) {
            Connection connection = dataSource.getConnection();
            connection.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("连接耗时：" + (end - start));
    }
}

测试结果

705ms

请添加图片描述

结论

德鲁伊在应用项目比较大时会非常快，比C3P0还要快，德鲁伊是阿里巴巴实现的

实现德鲁伊连接utils

utils源码

package com.taotao.jdbc.datasource;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

/**
 * Create By 刘鸿涛
 * 2022/3/5 13:24
 * 基于 druid 数据库池的工具类
 */
@SuppressWarnings({"all"})
public class JDBCUtilsByDruid {
    private static DataSource ds;

    //在静态代码块完成 ds初始化
    static {
        Properties properties = new Properties();
        try {
            properties.load(new FileInputStream("src\\druid.properties"));
            ds = DruidDataSourceFactory.createDataSource(properties);
        }catch(Exception e){
            e.printStackTrace();
        }
    }

    //编写getConnection方法
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

    //关闭连接，再次强调，在数据库连接池技术中心，close不是真的断掉连接
    //而是把使用的Connection对象放回连接池
    public static void close(ResultSet resultSet, Statement statement, Connection connection){
        try {
            if (resultSet != null){
                resultSet.close();
            }
            if (statement != null){
                statement.close();
            }
            if (connection != null){
                connection.close();
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }
}

测试德鲁伊utils

package com.taotao.jdbc.datasource;

import org.junit.Test;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Date;

/**
 * Create By 刘鸿涛
 * 2022/3/5 14:33
 */
@SuppressWarnings({"all"})
public class JDBCUtilsByDruid_USE {
    @Test
    public void testSelect() {
        //1.得到连接
        Connection connection = null;
        //2.组织sql
        String sql = "select * from actor where Id = ?";
        PreparedStatement preparedStatement = null;
        ResultSet set = null;
        //3.创建PreparedStatement 对象

        try {
            connection = JDBCUtilsByDruid.getConnection();
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setInt(1, 2);  //给？号赋值
            //执行，得到结果集
            set = preparedStatement.executeQuery();
            //遍历该结果集
            while (set.next()) {
                int id = set.getInt("Id");
                String name = set.getString("name");
                String sex = set.getString("sex");
                Date borndate = set.getDate("borndate");
                String phone = set.getString("phone");
                System.out.println(id + "\t" + name + "\t" + sex + "\t" + borndate + "\t" + phone);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtilsByDruid.close(set,preparedStatement,connection);
        }
    }

}