Mysql 8.0 创建DBCP连接池

DBCP连接池简介

DBCP(DataBase connection pool)数据库连接池是 apache 上的一个Java连接池项目。DBCP通过连接池预先同数据库建立一些连接放在内存中(即连接池中)，应用程序需要建立数据库连接时直接到从接池中申请一个连接使用，用完后由连接池回收该连接，从而达到连接复用，减少资源消耗的目的。

MySQL 8.0

MySQL 8.0以后，对java连接MySQL的驱动进行了更新，使用mysql-connector-java-8.*方可进行数据库连接，在调用驱动包时也需要调用

com.mysql.cj.jdbc.Driver

创建基于MySQL8.0的DBCP连接池

创建DBCPUtils.java

创建数据库连接池需要导入五个jar包，

* commons-collections
* commons-dbcp2
* commons-logging
* commons-pool2
* mysql-connector

下载：https://download.csdn.net/download/weixin_39858881/10895706

import org.apache.commons.dbcp2.BasicDataSourceFactory;
import javax.sql.DataSource;
import java.sql.*;
import java.util.Properties;/** DBCP连接池在构建时需要引入* commons-collections* commons-dbcp2* commons-logging* commons-pool2* mysql-connector* 共五个jar包，缺一不可*//*** 本模块构建了一个DBCP连接池* DBCP连接池配置位于config/dbcpconfig.properties中* 连接数据库qzqmall user:root password:admin useSSL:false charset:utf8*/
public class DBCPUtils {private static DataSource ds;//定义一个连接池对象static{try {Properties pro = new Properties();pro.load(DBCPUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"));ds = BasicDataSourceFactory.createDataSource(pro);//得到一个连接池对象} catch (Exception e) {throw new ExceptionInInitializerError("初始化连接错误，请检查配置文件！");}}/*** 构造从连接池取出连接的方法* @return Connection* @throws SQLException*/public static Connection getConnection() throws SQLException {return ds.getConnection();}/*** 关闭rs & stmt & conn* @param rs ResultSet* @param stmt Statement* @param conn Connection*/public static void closeAll(ResultSet rs, Statement stmt, Connection conn){if(rs!=null){try {rs.close();} catch (SQLException e) {e.printStackTrace();}}if(stmt!=null){try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if(conn!=null){try {conn.close();//关闭} catch (SQLException e) {e.printStackTrace();}}}/*** 测试类* @param args*/public static void main(String[] args) {try {System.out.println("对DBCP池进行测试");Connection con = DBCPUtils.getConnection();Statement stmt = con.createStatement();ResultSet rs = stmt.executeQuery("SELECT * FROM book");System.out.println(rs.next());closeAll(rs,stmt,con);} catch (SQLException e) {e.printStackTrace();}}

创建DBCP连接池配置文件

该文件用于配置数据库连接池的IP、端口、用户、密码以及连接数等配置信息。

在连接MySQL 8.0及更高版本时，不仅需要设置字符编码属性，还需要对时区进行设置serverTimezone=UTC;

此外，连接Mysql8.0及更高版本时，驱动名为com.mysql.cj.jdbc.Driver，在8.0之前的版本为com.mysql.jdbc.Driver

#连接设置
driverClassName=com.mysql.cj.jdbc.Driver
#设置数据库端口、数据库名
url=jdbc:mysql://localhost:3306/DB_Name
#设置数据库连接用户、密码
username=root
password=admin#<!-- 初始化连接 -->
initialSize=10#最大连接数量
maxActive=50#<!-- 最大空闲连接 -->
maxIdle=20#<!-- 最小空闲连接 -->
minIdle=5#<!-- 超时等待时间以毫秒为单位 60000毫秒/1000等于60秒 -->
maxWait=60000#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;]
#注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=utf8;useSSL=false;serverTimezone=UTC;allowPublicKeyRetrieval=true#指定由连接池所创建的连接的自动提交（auto-commit）状态。
defaultAutoCommit=true#driver default 指定由连接池所创建的连接的只读（read-only）状态。
#如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
#defaultReadOnly=#driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
#可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=REPEATABLE_READ

至此，数据库连接池创建完成，使用数据库连接时可import DBCPUtils，并调用DBCPUtils中的getConnection()方法获取数据库连接，当数据库连接使用完毕后，可调用closeAll()方法，关闭Connection、Statement(or PreparedStatement)、ResultSet对象。