特色栏目： python 批处理 net编程 Javascript Php Asp Css Html5 Android seo centos

当前位置 : 主页 > 编程语言 > java >

Java 数据库连接池c3p0 介绍

来源：互联网收集：自由互联发布时间：2021-12-01

目录 1、配置参数 1.1、基础配置 1.2、连接池大小 1.3、连接池大小和连接存活时间 1.4、连接测试 1.5、预编译池 1.6、数据库中断的恢复 1.7、自定义连接生命周期管理 1.8、处理未提交的事

1、配置参数

1.1、基础配置

配置

参数默认值描述 driverClass null 驱动类名称 jdbcUrl null jdbc 连接 url user null 用户名 password null 密码

1.2、连接池大小

参数默认值描述 acquireIncrement 3 连接池中的连接耗尽时，一次创建的连接个数 initialPoolSize 3 初始连接池大小，介于 minPoolSize 和 maxPoolSize 之间 maxPoolSize 15 最大连接数 minPoolSize 3 最小连接数

1.3、连接池大小和连接存活时间

参数默认值描述 maxConnectionAge 0 连接存活的最长时间(秒)，0 表示没有限制。正在使用的连接不会不受此限制。 maxIdleTime 0 空闲连接数最大存活时间，0 表示永不过期 maxIdleTimeExcessConnections 0 当连接数大于 minPoolSize 时，空闲连接数最大存活时间，0 表示永不过期

1.4、连接测试

参数默认值描述 automaticTestTable null 测试的表名；如果设置了，c3p0 将使用该表名创建一个空表，并使用其来测试连接，preferredTestQuery 参数将被忽略。 connectionTesterClassName com.mchange.v2.c3p0.impl.DefaultConnectionTester 连接测试的类名，需实现 com.mchange.v2.c3p0.ConnectionTester 或 com.mchange.v2.c3p0.QueryConnectionTester 接口。 idleConnectionTestPeriod 0 空闲连接测试的间隔(秒)。 preferredTestQuery null 连接测试的语句；如果不设置，将使用 DatabaseMetaData 的 getTables 方法来测试，这可能时比较慢的。 testConnectionOnCheckin false 连接返回连接池时，是否测试 testConnectionOnCheckout false 从连接池获取连接时，是否测试

1.5、预编译池

参数默认值描述 maxStatements 0 缓存总体预编译语句的最大数量 maxStatementsPerConnection 0 缓存每个连接中预编译语句的最大数量 statementCacheNumDeferredCloseThreads 0 清理 statement 缓存的线程数，如果需要设置，应设置为 1。一些数据库，特别是 oracle 会在连接使用时关闭 statement，数据库无法很好的处理这种情况，进而导致死锁。清理的线程会在连接

maxStatements 和 maxStatementsPerConnection 如果都为 0，将不缓存预编译语句。如果 maxStatements=0 and maxStatementsPerConnection>0，maxStatementsPerConnection 起作用，不限制总的缓存数量；如果 maxStatements>0 and maxStatementsPerConnection=0，maxStatements 起作用，不限单个连接的缓存数量。

1.6、数据库中断的恢复

参数默认值描述 acquireRetryAttempts 30 获取连接失败时的重试次数 acquireRetryDelay 1000 连接获取重试的时间间隔(毫秒) breakAfterAcquireFailure false 尝试获取连接失败时，是否声明连接池断开并永久关闭

1.7、自定义连接生命周期管理

参数默认值描述 connectionCustomizerClassName null 连接生命周期管理的自定义类，需实现 com.mchange.v2.c3p0.ConnectionCustomizer 接口

1.8、处理未提交的事务

参数默认值描述 autoCommitOnClose false 连接在返回连接池时是否自动提交事务。true，提交事务；false，回滚事务 forceIgnoreUnresolvedTransactions false 连接在返回连接池时，是否强制不处理事务；强烈不推荐设置为 true。

1.9、调试

参数默认值描述 debugUnreturnedConnectionStackTraces false 是否记录活动连接的堆栈信息；如果设为 true，且 unreturnedConnectionTimeout>0，当连接借出时间 > unreturnedConnectionTimeout 时，就会打印连接的堆栈信息，并删除该连接。 unreturnedConnectionTimeout 0 连接未返回连接池的超时时间(秒)

这两个参数可用于帮助发现连接泄露。

1.10、避免热部署内存泄露

参数默认值描述 contextClassLoaderSource caller 用于生成 c3p0 线程的类加载器来源，为 caller, library 或 none。caller 表示来源于连接池的调用者；library 表示来源于 c3p0 本身；none 表示使用系统类加载器 privilegeSpawnedThreads false 生成 c3p0 线程时是否使用 c3p0 库中的 AccessControlContext；默认(false)使用连接池调用者的 AccessControlContext。

在应用热部署、取消部署时，连接池可能会阻止垃圾回收进而导致内存泄露；这两个参数主要用于处理这种情况。

1.11、其它配置

参数默认值描述 checkoutTimeout 0 从连接获取连接的超时时间，0 表示永不超时 factoryClassLocation null c3p0 libraries的路径，如果在本地(通常都是这样)，那么无需设置 forceSynchronousCheckins false 连接返回连接池是否同步方式 maxAdministrativeTaskTime 0 管理任务运行的最大时间(秒)，超过改时间会终端任务；0 表示管理任务永远不被打断。 numHelperThreads 3 管理线程个数 usesTraditionalReflectiveProxies false 已过期。是否使用发射动态代理的方式来实现 Connection 及其他 JDBC 接口。

详细说明可参考官网文档：https://www.mchange.com/projects/c3p0/#configuration

2、原始连接操作

c3p0 提供 api 来访问原始连接中的非标准接口：

把连接转成 C3P0ProxyConnection
然后调用 rawConnectionOperation 方法

下面是获取 PostgreSQL JDBC 驱动中 CopyManager 对象的方法：

Connection connection = (C3P0ProxyConnection) c3p0DataSource.getConnection();

C3P0ProxyConnection castConnection = (C3P0ProxyConnection) connection;

Method method = BaseConnection.class.getMethod("getCopyAPI", new Class[]{});

CopyManager copyManager = (CopyManager) castConnection.rawConnectionOperation(method, C3P0ProxyConnection.RAW_CONNECTION, new Object[]{});

3、使用

3.1、直接使用

3.1.1、引入依赖

<dependency>

    <groupId>com.mchange</groupId>

    <artifactId>c3p0</artifactId>

    <version>0.9.5.5</version>

</dependency>

3.1.2、使用例子

package com.abc.demo.general.dbpool;

import com.mchange.v2.c3p0.ComboPooledDataSource;

import java.beans.PropertyVetoException;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class C3p0Case {

    public static void main(String[] args) throws PropertyVetoException {

        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource();

        comboPooledDataSource.setDriverClass("com.mysql.cj.jdbc.Driver");

        comboPooledDataSource.setJdbcUrl("jdbc:mysql://10.40.9.11:3306/mydb?useUnicode=true&characterEncoding=UTF-8");

        comboPooledDataSource.setUser("root");

        comboPooledDataSource.setPassword("123456");

        comboPooledDataSource.setInitialPoolSize(2);

        comboPooledDataSource.setMinPoolSize(2);

        comboPooledDataSource.setMaxPoolSize(10);

        comboPooledDataSource.setPreferredTestQuery("select 1");

        comboPooledDataSource.setIdleConnectionTestPeriod(60);

        comboPooledDataSource.setTestConnectionOnCheckout(true);

        comboPooledDataSource.setCheckoutTimeout(1000 * 30);

        Connection connection = null;

        Statement st = null;

        ResultSet rs  = null;

        try {

            connection = comboPooledDataSource.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);

        }

        //实际使用中一般是在应用启动时初始化数据源，应用从数据源中获取连接；并不会关闭数据源。

        comboPooledDataSource.close();

    }

    private static void close(Connection connection) {

        if (connection != null) {

            try {

                connection.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

}

3.2、在 SpringBoot 中使用

3.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>com.mchange</groupId>

        <artifactId>c3p0</artifactId>

        <version>0.9.5.5</version>

    </dependency>

    <dependency>

        <groupId>mysql</groupId>

        <artifactId>mysql-connector-java</artifactId>

    </dependency>

</dependencies>

3.1.2、单数据源

application.yml 配置：

spring:

  datasource:

    c3p0:

      driver-class: com.mysql.cj.jdbc.Driver

      jdbc-url: jdbc:mysql://10.40.9.11:3306/myDb?useUnicode=true&characterEncoding=UTF-8

      user: root

      password: 123456

      initial-pool-size: 2

      min-pool-size: 2

      max-pool-size: 10

      preferred-test-query: select 1

      idle-connection-test-period: 60

      test-connection-on-checkout: true

      checkout-timeout: 30000

数据源配置类：

package com.abc.demo.config;

import com.mchange.v2.c3p0.ComboPooledDataSource;

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("dataSource")

    @ConfigurationProperties(prefix = "spring.datasource.c3p0")

    public DataSource dataSource1() {

        return DataSourceBuilder.create().type(ComboPooledDataSource.class).build();

    }

}

使用：

@Autowired

private DataSource dataSource;

3.1.3、多数据源

application.yml 配置：

spring:

  datasource:

    c3p0:

      db1:

        driver-class: com.mysql.cj.jdbc.Driver

        jdbc-url: jdbc:mysql://10.40.9.11:3306/myDb?useUnicode=true&characterEncoding=UTF-8

        user: root

        password: InsYR0ot187!

        initial-pool-size: 2

        min-pool-size: 2

        max-pool-size: 10

        preferred-test-query: select 1

        idle-connection-test-period: 60

        test-connection-on-checkout: true

        checkout-timeout: 30000

      db2:

        driver-class: com.mysql.cj.jdbc.Driver

        jdbc-url: jdbc:mysql://10.40.9.12:3306/myDb?useUnicode=true&characterEncoding=UTF-8

        user: root

        password: InsYR0ot187!

        initial-pool-size: 2

        min-pool-size: 2

        max-pool-size: 10

        preferred-test-query: select 1

        idle-connection-test-period: 60

        test-connection-on-checkout: true

        checkout-timeout: 30000

数据源配置类：

package com.abc.demo.config;

import com.mchange.v2.c3p0.ComboPooledDataSource;

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.c3p0.db1")

    public DataSource dataSource1() {

        return DataSourceBuilder.create().type(ComboPooledDataSource.class).build();

    }

    @Bean("dataSource2")

    @ConfigurationProperties(prefix = "spring.datasource.c3p0.db2")

    public DataSource dataSource2() {

        return DataSourceBuilder.create().type(ComboPooledDataSource.class).build();

    }

}

使用：

@Autowired

@Qualifier("dataSource1")

private DataSource dataSource1;



@Autowired

@Qualifier("dataSource2")

private DataSource dataSource2;

到此这篇关于 Java 数据库连接池c3p0 介绍的文章就介绍到这了,更多相关 Java 连接池c3p0 内容请搜索自由互联以前的文章或继续浏览下面的相关文章希望大家以后多多支持自由互联！

上一篇：一文搞懂Java的SPI机制(推荐)
下一篇：没有了

Java&nbsp;数据库连接池c3p0&nbsp;介绍

目录

1、配置参数

1.1、基础配置

配置

1.2、连接池大小

1.3、连接池大小和连接存活时间

1.4、连接测试

1.5、预编译池

1.6、数据库中断的恢复

1.7、自定义连接生命周期管理

1.8、处理未提交的事务

1.9、调试

1.10、避免热部署内存泄露

1.11、其它配置

2、原始连接操作

3、使用

3.1、直接使用

3.1.1、引入依赖

3.1.2、使用例子

3.2、在 SpringBoot 中使用

3.1.1、引入依赖

3.1.2、单数据源

3.1.3、多数据源

相关文章

Java 数据库连接池c3p0 介绍