Java 数据库连接池介绍(1)--DBCP 介绍

DBCP(Database connection pooling) 是 Apache 旗下 Commons 项目下的一个子项目，提供连接池功能；本文主要介绍 DBCP 的基本使用，文中使用到的软件版本：Java 1.8.0_191、DBCP 2.9.0、Spring Boot 2.3.12.RELEASE。

1、配置参数

参数	描述
username	用户名
password	密码
url	连接 url
driverClassName	驱动名称
connectionProperties	连接属性，格式为： [propertyName=property;]* "user" and "password" 将被除外，所以在此不需要包含这两个属性。

参数	默认值	描述
defaultAutoCommit	驱动的默认值	是否自动提交
defaultReadOnly	驱动的默认值	是否只读
defaultTransactionIsolation	驱动的默认值	默认的事务隔离级别 NONE、READ_COMMITTED、READ_UNCOMMITTED、 REPEATABLE_READ、SERIALIZABLE
defaultCatalog		默认的 catalog。(目录，类似于模式名，但比模式名更加抽象； Oracle，MySQL 不支持，MS SQL Server = 数据库名)
cacheState	true	是否缓存状态信息
defaultQueryTimeout	null	默认查询时间
enableAutoCommitOnReturn	true	连接归还到池时，是否设置为自动提交
rollbackOnReturn	true	如果设置为 true，则连接归还到连接池时， 如果 auto commit=true 且 read-only=false，则会自动执行一次 rollback()。

参数	默认值	描述
initialSize	0	初始连接数
maxTotal	8	最大连接数；负数表示没有限制
maxIdle	8	最大空闲连接数，多余的空闲连接将被释放；负数表示没有限制
minIdle	0	最小空闲连接数，如果不足则新的空闲连接将被创建。
maxWaitMillis	indefinitely	从连接池获取连接，最大等待时间，超过该时间将抛出异常；-1 表示无限期

参数	默认值	描述
validationQuery		连接池返回连接给调用者前用来校验的查询sql。 如果指定，则这个查询 SQL 必须至少返回一行数据；如果没有指定，则通过调用 isValid() 方法进行校验。
validationQueryTimeout	no timeout	验证查询超时时间（秒）。如果设置为正数，那么通过 setQueryTimeOut()方法来设置查询的超时时间。
testOnCreate	false	连接创建后，是否验证有效性
testOnBorrow	true	从连接池获取连接时，是否验证有效性
testOnReturn	false	连接返回连接池时，是否验证有效性
testWhileIdle	false	连接空闲时，是否验证有效性；如果验证失败，则丢弃该连接。
timeBetweenEvictionRunsMillis	-1	校验空闲连接的时间周期，非正表示不验证
numTestsPerEvictionRun	3	每次校验空闲连接的个数
minEvictableIdleTimeMillis	1000 * 60 * 30	空闲连接至少多长时间后，才会被校验
softMinEvictableIdleTimeMillis	-1	空闲连接至少多长时间后，才会被校验；还需满足"空闲连接数>=minIdle"
maxConnLifetimeMillis	-1	连接存活的最大时间；如果设置为非正数，则存活时间是无限的
logExpiredConnections	true	过期的连接被连接池关闭时，是否写日志
connectionInitSqls	null	连接第一次创建时，执行的初始化 SQL
lifo	true	true 表示获取连接时将返回最后返还连接池的连接(后进先出)；false，则相反(先进先出)。

参数	默认值	描述
poolPreparedStatements	false	预编译语句是否池化
maxOpenPreparedStatements	unlimited	最大打开的预处理语句，负数表示没有限制

参数	默认值	描述
accessToUnderlyingConnectionAllowed	false	是否允许访问底层连接

如果允许，可以使用下面的代码来访问底层连接：

Connection conn = ds.getConnection();
Connection dconn = ((DelegatingConnection) conn).getInnermostDelegate();
...
conn.close()

参数	默认值	描述
removeAbandonedOnMaintenance removeAbandonedOnBorrow	false	是否删除泄露的连接；如果超过一个活动连接未使用的时间超过 removeAbandonedTimeout，则是一个泄露的连接。 创建 Statement，PreparedStatement，CallableStatement 或使用这些对象执行一个查询都会重置连接的上传使用时间。 removeAbandonedOnMaintenance：空闲连接校验时是否回收泄露的连接，要使启用该设置需把 timeBetweenEvictionRunsMillis 设置为整数 removeAbandonedOnBorrow：从连接池获取连接时是否回收泄露的连接，要使启用该设置还需满足 'getNumActive() > getMaxTotal() - 3 and getNumIdle() < 2'
removeAbandonedTimeout	300	连接泄露的超时时间(秒)
logAbandoned	false	连接删除时是否打印堆栈信息
abandonedUsageTracking	false	如果设置为 true，数据库连接每执行一个方法都会打印堆栈信息

参数	默认值	描述
fastFailValidation	false	是否快速失败验证；如果设置为 true，当发生致命异常时，不再执行 isValid()，也不去执行验证查询语句。致命的异常码有： 57P01 (ADMIN SHUTDOWN) 57P02 (CRASH SHUTDOWN) 57P03 (CANNOT CONNECT NOW) 01002 (SQL92 disconnect error) JZ0C0 (Sybase disconnect error) JZ0C1 (Sybase disconnect error) Any SQL_STATE code that starts with "08" 要覆盖默认的异常代码，可以设置 disconnectionSqlCodes 属性。
disconnectionSqlCodes	null	自定义异常代码
jmxName		注册连接池的 jmx 名称

详细的配置说明可参考官网文档：http://commons.apache.org/proper/commons-dbcp/configuration.html。

2、使用

2.1、直接使用

2.1.1、引入依赖

<dependency>
  <groupId>org.apache.commons</groupId>
  <artifactId>commons-dbcp2</artifactId>
  <version>2.9.0</version>
</dependency>

2.1.2、使用例子

package com.abc.demo.general.dbpool;

import org.apache.commons.dbcp2.BasicDataSource;

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

public class DBCPCase {
    public static void main(String[] args) {
        BasicDataSource basicDataSource = new BasicDataSource();
        basicDataSource.setUrl("jdbc:mysql://10.40.9.11:3306/mydb?useUnicode=true&characterEncoding=UTF-8");
        basicDataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        basicDataSource.setUsername("root");
        basicDataSource.setPassword("123456");
        basicDataSource.setMaxTotal(20);
        basicDataSource.setMinIdle(5);

        Connection connection = null;
        Statement st = null;
        ResultSet rs  = null;
        try {
            connection = basicDataSource.getConnection();
            st = connection.createStatement();
            rs = st.executeQuery("select version()");
            if (rs.next()) {
                System.out.println(rs.getString(1));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            close(connection);
        }

        try {
            //实际使用中一般是在应用启动时初始化数据源，应用从数据源中获取连接；并不会关闭数据源。
            basicDataSource.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static void close(Connection connection) {
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

2.2、在 SpringBoot 中使用

2.1.1、引入依赖

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.3.12.RELEASE</version>
    <relativePath />
</parent>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-dbcp2</artifactId>
        <version>2.9.0</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
</dependencies>

2.1.2、单数据源

application.yml 配置：

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://10.40.9.11:3306/myDb?useUnicode=true&characterEncoding=UTF-8
    username: root
    password: 123456
    type: org.apache.commons.dbcp2.BasicDataSource
    dbcp2:
      max-total: 20
      max-idle: 5

使用：

@Autowired
private DataSource dataSource;

2.1.3、多数据源

application.yml 配置：

spring:
  datasource:
    dbcp2:
      db1:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://10.40.9.11:3306/myDb?useUnicode=true&characterEncoding=UTF-8
        username: root
        password: 123456
        max-total: 20
        max-idle: 5
      db2:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://10.40.9.12:3306/myDb?useUnicode=true&characterEncoding=UTF-8
        username: root
        password: 123456
        max-total: 20
        max-idle: 5

数据源配置类：

package com.abc.demo.config;

import org.apache.commons.dbcp2.BasicDataSource;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;

@Configuration
public class DataSourceConfig {
    @Bean("dataSource1")
    @ConfigurationProperties(prefix = "spring.datasource.dbcp2.db1")
    public DataSource dataSource1() {
        return DataSourceBuilder.create().type(BasicDataSource.class).build();
    }

    @Bean("dataSource2")
    @ConfigurationProperties(prefix = "spring.datasource.dbcp2.db2")
    public DataSource dataSource2() {
        return DataSourceBuilder.create().type(BasicDataSource.class).build();
    }
}

使用：

@Autowired
@Qualifier("dataSource1")
private DataSource dataSource1;

@Autowired
@Qualifier("dataSource2")
private DataSource dataSource2;