数据库连接池

　　用池来管理Connection,这可以重复使用Connection。有了池，所有我们就不用自己来创建Connection，而是通过取来获取Connection对象。当使用完Connection后，调用Connection的close（）方法也不会真的关闭Connection，而是把Connection"归还"给池。池就可以在利用这个Connection对象了，便于管理连接，达到资源与时间的平衡。

一、连接池原理图

1、池中有，则从池中拿；

2、池中没有，就先等待，等待超时后，则新创建connection；

3、如果这个连接是原本就在池中的，那么用完之后，就放回池中；

3、如果这个连接是新创建的，那么用完之后，就直接销毁；

二、连接池的配置

1、池参数（所有池参数都有默认值）：

• 初始大小：10个；
• 最小空闲连接数：3个；
• 增量：一次创建的最小单位（5个）；
• 最大空闲连接数：12个；
• 最大连接数：20个；
• 最大的等待时间：1000毫秒。

2、四大连接参数

　　连接池也是使用四大连接参数来完成创建连接对象。

3、实现的接口

连接池必须实现：javax.sql.DataSource接口。

连接池返回的Connection对象，它的close（）方法与众不同，调用它的close（）不是关闭，而是把连接归还给池。

三、常用连接池

（一）DBCP

1、DBCP

　　DBCP(DataBase connection pool),数据库连接池。是 apache 上的一个 java 连接池项目，也是 tomcat 使用的连接池组件。单独使用dbcp需要2个包：commons-dbcp.jar,commons-pool.jar由于建立数据库连接是一个非常耗时耗资源的行为，所以通过连接池预先同数据库建立一些连接，放在内存中，应用程序需要建立数据库连接时直接到连接池中申请一个就行，用完后再放回去。

2、核心API：BasicDataSource、BasicDataSourceFactory

3、依赖的jar包：commons-dbcp-1.4.jar、commons-pool-1.5.6.jar、mysql-connector-java-5.1.44-bin.jar（数据库驱动，根据连接的数据库提供）；

4、DBCP连接池配置文件（dbcpconfig.properties）：

　　配置文件需放在src的根目录下

#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/mydb1
username=root
password=

#<!-- 初始化连接 -->
initialSize=5

#最大连接数量
maxActive=50

#<!-- 超时等待时间以毫秒为单位 60000毫秒/1000等于60秒 -->
maxWait=60000

#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;] 
#注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=utf8

#指定由连接池所创建的连接的自动提交（auto-commit）状态。
defaultAutoCommit=true

#driver default 指定由连接池所创建的连接的只读（read-only）状态。
#如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
defaultReadOnly=

#driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
#可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=REPEATABLE_READ

#<!-- 最大空闲连接 -->
maxIdle=20

#<!-- 最小空闲连接 -->
minIdle=5

5、DBCP连接池示例：

import org.apache.commons.dbcp.BasicDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class DBCPUtils02 {
    private static DataSource dataSource;
    static {
        Properties properties = new Properties ();
        //使用类加载将文件转换成流
        //获取类加载器对象:当前类名.class.getClassLoader();
        ClassLoader classLoader = DBCPUtils02.class.getClassLoader ();
        //调用classLoader的getResourceAsStream()方法，将资源文件转换成流
        InputStream inStream = classLoader.getResourceAsStream ("dbcpconfig.properties");
        //1.创建连接池对象
        try {
            //使用properties将文件转换成的流加载进来
            properties.load (inStream);
            //使用连接池工厂创建连接池
            dataSource = BasicDataSourceFactory.createDataSource (properties);
        } catch (Exception e) {
            e.printStackTrace ();
        }
    }

    // 从DBCP连接池中获取连接
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection ();
    }

    //释放资源
    public static void close(ResultSet resultSet, Statement statement, Connection conn)  {
       if (resultSet != null){
           try {
               resultSet.close ();
           } catch (SQLException e) {
               e.printStackTrace ();
           }
       }
       if (statement != null){
           try {
               statement.close ();
           } catch (SQLException e) {
               e.printStackTrace ();
           }
       }
       if (conn != null) {
           try {
               conn.close ();
           } catch (SQLException e) {
               e.printStackTrace ();
           }
       }
    }
}

（二） C3P0连接池

　　C3P0是一个开源的JDBC连接池，它实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate，Spring等。

1、C3P0的核心类：CombopooledDataSource。

2、相关jar包下载链接：https://sourceforge.net/projects/c3p0/files/latest/download?source=files

3、依赖包：c3p0-0.9.5.2.jar 和mchange-commons-java-0.2.11.jar包、mysql-connector-java-5.1.44-bin.jar（针对MySQL数据库）

4、c3p0也可以指定配置文件，而配置文件可以是properties，也可以是xml的，当然xml高级一些，但是c3p0的配置文件名必须为“c3p0-config.xml”,并放在类的路径下（src下）。

 1 <?xml version="1.0" encoding="utf-8"?>
 2 <c3p0-config>
 3     <!--默认配置信息-->
 4     <default-config>
 5         <!--连接四大参数配置-->
 6         <property name="droverClass">com.mysql.jdbc.Driver</property>
 7         <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>
 8         <property name="user">root</property>
 9         <property name="password"></property>
10         <!--池参数配置-->
11         <property name="acquireIncrement">3</property>
12         <property name="initialPoolSize">10</property>
13         <property name="minPoolSize">2</property>
14         <property name="maxPoolSize">10</property>
15     </default-config>
16     <!-- 专门为oracle提供的配置信息 -->
17     <named-config name="oracle-config">
18         <!--连接四大参数配置-->
19         <property name="droverClass">oracle.jdbc.driver.OracleDriver</property>
20         <property name="jdbcUrl">jdbc:oracle:thin:@地址:端口:ORCL</property>
21         <property name="user">root</property>
22         <property name="password"></property>
23         <!--池参数配置-->
24         <property name="acquireIncrement">3</property>
25         <property name="initialPoolSize">10</property>
26         <property name="minPoolSize">2</property>
27         <property name="maxPoolSize">10</property>
28     </named-config>
29 </c3p0-config>

 5、C3P0 使用示例：

import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * Created by kong on 12/12/2017.
 */
 
public class C3P0Utils02 {
    private static ComboPooledDataSource dataSource;
    static {
        //创建连接池对象
        dataSource = new ComboPooledDataSource ();
    }
    //获取连接
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection ();
    }
    //释放资源
    public static void close(ResultSet resultSet, Statement statement,Connection connection) throws SQLException {
        if (resultSet != null){
            resultSet.close ();
        }
        if (statement != null){
            statement.close ();
        }
        if (connection != null){
            connection.close ();
        }
    }
}    

(三) Druid 连接池

　　Druid首先是一个数据库连接池。Druid是目前最好的数据库连接池，在功能、性能、扩展性方面，都超过其他数据库连接池，包括DBCP、C3P0、BoneCP、Proxool、JBoss DataSource。Druid已经在阿里巴巴部署了超过600个应用，经过一年多生产环境大规模部署的严苛考验。

1、核心类：DruidDataSourceFactory

2、依赖包：druid-1.1.0.jar、mysql-connector-java-5.1.44-bin.jar

3、配置文件：druidconfig.properties 放置于src下

url=jdbc:mysql://localhost:3306/mydb1
driverClassName=com.mysql.jdbc.Driver
username=root
password=
filters=stat
maxActive=20
initialSize=1
maxWait=60000
minIdle=10
maxIdle=15
timeBetweenEvictionRunsMillis=60000
minEvictableIdleTimeMillis=300000
validationQuery=SELECT'x'
testWhileIdle=true
testOnBorrow=false
testOnReturn=false
maxOpenPreparedStatements=20
removeAbandoned=true
removeAbandonedTimeout=1800
logAbandoned=true

4、Druid使用示例：

import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

public class DruidUtil {
    private static DataSource dataSource;
    static {
        Properties properties = new Properties ();
        ClassLoader classLoader = DruidUtils02.class.getClassLoader ();
        InputStream resourceAsStream = 
                classLoader.getResourceAsStream ("druidconfig.properties");
        try {
            properties.load (resourceAsStream);
            dataSource = DruidDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            e.printStackTrace ();
        }
    }

    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection ();

    }

    public static void close(ResultSet resultSet, PreparedStatement prsm,Connection conn){
        if (resultSet !=null){
            try {
                resultSet.close ();
            } catch (SQLException e) {
                e.printStackTrace ();
            }
        }
        if (prsm != null){
            try {
                prsm.close ();
            } catch (SQLException e) {
                e.printStackTrace ();
            }
        }
        if (conn != null) {
            try {
                conn.close ();
            } catch (SQLException e) {
                e.printStackTrace ();
            }
        }

    }
}