c3p0-----开源JDBC连接池使用及配置

悠悠 2022-06-18 08:13 178阅读 0赞

首先来个连接，介绍一下各种连接池的区别及性能差别（boneCP较新，性能较高）[连接池区别][Link 1]

c3p0是一个开源JDBC连接池，假如英文好的话完全可以[c3p0 - JDBC3 Connection and Statement Pooling][]

这里用到的version为c3p0-0.9.5.2：

所需的jdk为1.6或者以上版本
    需要导入的jar包有：c3p0-0.9.5.2.jar 和 mchange-commons-java-0.2.11.jar  可以在maven上下载，下载后导入项目的WEB-INF/lib下（只要在CLASSPATH路径下即可）

连接池的原理借图一张：  
![这里写图片描述][SouthEast]

不使用connection pool的话，图中没有中间池这一层，DAO层（数据连接对象）直接连接数据源（最底层），执行连接–执行–关闭操作，这样DAO每执行一次CRUD，就执行一次连接–执行sql–关闭连接，假如业务需要频繁地CRUD，就会频繁地连接关闭，造成性能上的浪费。

使用池连接，则项目运行后会创建connection pool并取得与数据源的连接（初始连接、最大连接、最小连接可以设置），这样DAO需要操作CRUD，就没必要直接访问数据源了，直接和池打交道，由于池是在内存中的，这样DAO每次获得与池的连接速度也会提高，关闭连接也是关闭与连接池的关闭，即连接与关闭都是操作连接池，并不直接操作数据源。（访问硬盘的速度远大于访问内存的速度）。

由于JDBC的连接没必要在每一处使用时重复性地写这些样板式代码，故可以把连接池的创建及连接写成一个工具类utils。

package com.dataSource.c3p0;
    
    import java.beans.PropertyVetoException;
    import java.io.IOException;
    import java.sql.Connection;
    import java.sql.SQLException;
    
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    
    public class DataSource { 
    
        private static DataSource datasource;
        private ComboPooledDataSource cpds;
    
        private DataSource() throws IOException, SQLException, PropertyVetoException { //该类构造时即创建c3p0数据库连接池
            cpds = new ComboPooledDataSource();
            cpds.setDriverClass("com.mysql.jdbc.Driver"); //loads the jdbc driver
            cpds.setJdbcUrl("jdbc:mysql://localhost/test");
            cpds.setUser("root");
            cpds.setPassword("root");
    
            // the settings below are optional -- c3p0 can work with defaults
            cpds.setMinPoolSize(5); //最小连接数目
            cpds.setAcquireIncrement(5); //连接不够时增加数目
            cpds.setMaxPoolSize(20); //最大连接数目
        }
    
        public static DataSource getInstance() throws IOException, SQLException, PropertyVetoException { //获得单例
            if (datasource == null) {
                datasource = new DataSource();
                return datasource;
            } else {
                return datasource;
            }
        }
    
        public Connection getConnection() throws SQLException {
            return this.cpds.getConnection();
        }
    
    }

在DAO层使用池连接：

try {
                connection = DataSource.getInstance().getConnection();
                statement = connection.createStatement();
                resultSet = statement.executeQuery("select * from employee");
                 while (resultSet.next()) {
                     System.out.println("employeeid: " + resultSet.getString("employeeid"));
                     System.out.println("employeename: " + resultSet.getString("employeename"));
                 }
            } catch (SQLException e) {
                e.printStackTrace();
            } finally {
                if (resultSet != null) try { resultSet.close(); } catch (SQLException e) {e.printStackTrace();}
                if (statement != null) try { statement.close(); } catch (SQLException e) {e.printStackTrace();}
                if (connection != null) try { connection.close(); } catch (SQLException e) {e.printStackTrace();}
            }

[Link 1]: http://blog.csdn.net/sqjhwl/article/details/8900568
[c3p0 - JDBC3 Connection and Statement Pooling]: http://www.mchange.com/projects/c3p0/#contents
[SouthEast]: /images/20220618/ec4331843b3b4466989ca51f756da577.png