亲宝软件园·资讯

展开

Java  连接池 DBCP

咏吟 人气:0

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.2.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.2.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.2.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;

加载全部内容

相关教程
猜你喜欢
用户评论