MySQL 入门（八）

C3P0

• 下载地址
• C3P0 是一个开源的 JDBC 连接池，实现了数据源和 JNDI 绑定，支持 JDBC3 规范和 JDBC2 的标准扩展；
• C3P0 数据源，在项目开发中使用得较多，有Hibernate，Spring等；
• C3P0 与 DBCP 区别：
  • DBCP 没有自动回收空闲连接的功能；
  • C3P0 有自动回收空闲连接功能。

测试

• 导入相关 jar 包；

image

• 在类目录下创建 C3P0 的配置文件：c3p0-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <!-- 注意：XML文件中，标签内容不能换行，&用转义符&amp;代替，否则程序出现异常 -->
    <!--
        C3P0的缺省(默认)配置：
        如果在代码中“ComboPooledDataSource ds = new ComboPooledDataSource();”
        这样写就表示使用的是C3P0的缺省(默认)配置信息来创建数据源
    -->
    <default-config>
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </default-config>
    <!--
        C3P0的命名配置：
        如果在代码中“ComboPooledDataSource ds = newComboPooledDataSource("MySQL");”
        这样写就表示使用的是name是MySQL的配置信息来创建数据源
    -->
    <named-config name="MySQL">
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true</property>
        <property name="user">root</property>
        <property name="password">123456</property>
        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </named-config>
</c3p0-config>

• 创建工具类

package com.xxx.demo06.utils;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcUtils_C3P0 {

    private static ComboPooledDataSource ds = null;

    // 在静态代码块中创建数据库连接池
    static {
        try {
            // 通过代码创建C3P0数据库连接池
            /*
                ds = new ComboPooledDataSource();
                ds.setDriverClass("com.mysql.cj.jdbc.Driver");
                ds.setJdbcUrl("jdbc:mysql://localhost:3306/jdbcstudy");
                ds.setUser("root");
                ds.setPassword("123456");
                ds.setInitialPoolSize(10);
                ds.setMinPoolSize(5);
                ds.setMaxPoolSize(20);
             */

            // 通过读取C3P0的xml配置文件创建数据源，C3P0的xml配置文件，必须放在src目录下
            // ds = new ComboPooledDataSource();    默认配置来创建数据源

            // C3P0的命名配置来创建数据源
            ds = new ComboPooledDataSource("MySQL");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // 从数据源中获取数据库连接
    public static Connection getConnection() throws SQLException {
        // 从数据源中获取数据库连接
        return ds.getConnection();
    }

    // 释放资源：从后往前关闭
    public static void release(Connection conn, Statement st, ResultSet rs) {
        if (rs != null) {
            try {
                // 关闭结果集ResultSet对象
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (st != null) {
            try {
                // 关闭执行SQL命令的Statement对象
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                // 关闭Connection数据库连接对象
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

• 测试：

package com.xxx.demo06;

import com.xxx.demo06.utils.JdbcUtils_C3P0;

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

public class TestC3P0 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            // 通过 C3P0 数据库连接池，获取数据库连接
            conn = JdbcUtils_C3P0.getConnection();

            // 执行SQL命令
            String sql = "INSERT INTO `users`(`id`,`name`,`password`,`email`,`birthday`)" +
                    "VALUES(?,?,?,?,?);";
            // 对SQL进行预编译
            st = conn.prepareStatement(sql);
            st.setInt(1, 5);
            st.setString(2, "测试3");
            st.setString(3, "123");
            st.setString(4, "cc@cc.com");
            st.setDate(5, new java.sql.Date(new Date().getTime()));

            // 执行SQL
            int i = st.executeUpdate();
            if (i > 0) {
                System.out.println("插入成功");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 释放资源
            JdbcUtils_C3P0.release(conn, st, null);
        }
    }
}

Druid

• druid-1.2.8.jar：下载链接
• Druid 连接池（德鲁伊），阿里巴巴的连接池，Java 性能最好的数据库连接池，类似于 DBCP连接池；
• Druid 和 DBCP 的连接属性是完全相同的，只是创建连接池的对象不同；

// DBCP 的数据库连接池实现
// import org.apache.commons.dbcp2.BasicDataSourceFactory;
// Druid 的替换为
import com.alibaba.druid.pool.DruidDataSourceFactory;

// ds = BasicDataSourceFactory.createDataSource(props);
// Druid
ds = DruidDataSourceFactory.createDataSource(props);

结论：

• 无论使用什么数据源，本质还是一样，DataSource 接口不会变，方法就不会变。