9. 数据库连接池
- 用户每次请求都需要向数据库获得链接，而数据库创建连接，通常需要消耗相对较大的资源，创建时间也较长；
- 如果网站一天10万的访问量，数据库服务器，就需要创建 10 万次连接，极大的浪费数据库资源，并且极易造成数据库服务器内存溢出、宕机。
数据库连接池的基本概念
- 数据库连接池，负责分配、管理和释放数据库连接，它允许应用程序，重复使用一个现有的数据库连接，而不是重新建立一个；
- 数据库连接池，在初始化时，创建一定数量的数据库连接，放到连接池中，这些数据库连接的数量，是由最小数据库连接数来设定的，无论这些数据库连接是否被使用，连接池都将一直保证，最小值的连接数量；
- 连接池的最大数据库连接数量，限定了这个连接池能占有的最大连接数，当应用程序向连接池请求的连接数，超过最大连接数时，这些请求，将被加入到等待队列中；
- 最小连接数和最大连接数的设置，要考虑到以下因素：
- 最小连接数：一直保持的数据库连接数，如果应用程序，对数据库连接的使用量不大，将会有大量的资源被浪费；
- 最大连接数：能申请的最大连接数，如果数据库连接请求超过次数，后面的数据库连接请求，将被加入到等待队列中，影响以后的数据库操作；
- 如果最小连接数与最大连接数相差很大：最先连接请求将会获利，之后，超过最小连接数量的连接请求，等价于建立一个新的数据库连接，不过，这些大于最小连接数的数据库连接，在使用完，不会马上被释放，将被放到连接池中，等待重复使用或是空间超时后被释放。
-
编写连接池，需实现
java.sql.DataSource接口；
开源数据库连接池
- 现在很多 WEB 服务器（Weblogic、 WebSphere、Tomcat），都提供了
DataSoruce的实现，即连接池的实现； - 通常把
DataSource的实现，按其英文含义称之为 数据源，数据源中，都包含了数据库连接池的实现； - 也有一些开源组织，提供了数据源的独立实现：
- DBCP 数据库连接池；
- C3P0 数据库连接池；
- Druid
- 使用了数据库连接池后，在项目的实际开发中，就不需要编写连接数据库的代码，直接从数据源，获得数据库的连接。
DBCP 数据源
- Apache 下的开源连接池实现，需要在系统中增加两个 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);
}
}
}
