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

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

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路径下即可）

连接池的原理借图一张：

不使用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();}
        }