MySQL 入门（七）

9. 数据库连接池

• 用户每次请求都需要向数据库获得链接，而数据库创建连接，通常需要消耗相对较大的资源，创建时间也较长；
• 如果网站一天10万的访问量，数据库服务器，就需要创建 10 万次连接，极大的浪费数据库资源，并且极易造成数据库服务器内存溢出、宕机。

数据库连接池的基本概念

• 数据库连接池，负责分配、管理和释放数据库连接，它允许应用程序，重复使用一个现有的数据库连接，而不是重新建立一个；
• 数据库连接池，在初始化时，创建一定数量的数据库连接，放到连接池中，这些数据库连接的数量，是由最小数据库连接数来设定的，无论这些数据库连接是否被使用，连接池都将一直保证，最小值的连接数量；
• 连接池的最大数据库连接数量，限定了这个连接池能占有的最大连接数，当应用程序向连接池请求的连接数，超过最大连接数时，这些请求，将被加入到等待队列中；
• 最小连接数和最大连接数的设置，要考虑到以下因素：
  • 最小连接数：一直保持的数据库连接数，如果应用程序，对数据库连接的使用量不大，将会有大量的资源被浪费；
  • 最大连接数：能申请的最大连接数，如果数据库连接请求超过次数，后面的数据库连接请求，将被加入到等待队列中，影响以后的数据库操作；
  • 如果最小连接数与最大连接数相差很大：最先连接请求将会获利，之后，超过最小连接数量的连接请求，等价于建立一个新的数据库连接，不过，这些大于最小连接数的数据库连接，在使用完，不会马上被释放，将被放到连接池中，等待重复使用或是空间超时后被释放。
• 编写连接池，需实现 java.sql.DataSource 接口；

开源数据库连接池

• 现在很多 WEB 服务器（Weblogic、 WebSphere、Tomcat），都提供了DataSoruce 的实现，即连接池的实现；
• 通常把 DataSource 的实现，按其英文含义称之为 数据源，数据源中，都包含了数据库连接池的实现；
• 也有一些开源组织，提供了数据源的独立实现：
  • DBCP 数据库连接池；
  • C3P0 数据库连接池；
  • Druid
• 使用了数据库连接池后，在项目的实际开发中，就不需要编写连接数据库的代码，直接从数据源，获得数据库的连接。

DBCP 数据源

• Apache 下的开源连接池实现，需要在系统中增加两个 jar 文件：
  • Commons-dbcp-1.4.jar：连接池的实现；下载链接
  • Commons-pool-1.6.jar：连接池实现的依赖库；下载链接
• Tomcat 的连接池，正是采用该连接池来实现的，该数据库连接池，既可以与应用服务器整合使用，也可由应用程序独立使用；

DBCP 测试：

• 导入相关 jar 包；

image

• 类目录下，创建 DBCP 配置文件：dbcpconfig.properties

# 连接设置
driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcStudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=123456

# 初始化连接
#initialSize=10

# 最大连接数量
#maxActive=50

# 最大空闲连接
#maxIdle=20

# 最小空闲连接
#minIdle=5

# 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒
#maxWait=60000

# JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;]
# 注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
#connectionProperties=useUnicode=true;characterEncoding=UTF8

# 指定由连接池所创建的连接的自动提交（auto-commit）状态。
#defaultAutoCommit=true

# driver default 指定由连接池所创建的连接的只读（read-only）状态。
# 如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
#defaultReadOnly=

# driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
# 可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
#defaultTransactionIsolation=READ_UNCOMMITTED

• 编写工具类：JdbcUtils_DBCP

package com.xxx.demo05.utils;

import org.apache.commons.dbcp.BasicDataSourceFactory;

import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JdbcUtils_DBCP {
    /*
        在java中，编写数据库连接池需实现java.sql.DataSource接口，
        每一种数据库连接池都是DataSource接口的实现
        DBCP连接池就是java.sql.DataSource接口的一个具体实现
     */
    private static DataSource ds = null;

    // 在静态代码块中创建数据库连接池
    static {
        try {
            // 加载dbcpconfig.properties配置文件
            InputStream in = JdbcUtils_DBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
            // 创建属性集合
            Properties props = new Properties();
            // 读取流
            props.load(in);

            // 创建数据源    工厂模式->创建
            ds = BasicDataSourceFactory.createDataSource(props);
        } 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.demo05;

import com.xxx.demo05.utils.JdbcUtils_DBCP;

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

public class TestDBCP {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            // 通过数据库连接池，获取数据库连接
            conn = JdbcUtils_DBCP.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_DBCP.release(conn, st, null);
        }
    }
}