DBCP数据库连接池

一、数据库连接池原理

连接池基本的思想是在系统初始化的时候，将数据库连接作为对象存储在内存中，当用户需要访问数据库时，并非建立一个新的连接，而是从连接池中取出一个已建立的空闲连接对象。

使用完毕后，用户也并非将连接关闭，而是将连接放回连接池中，以供下一个请求访问使用。而连接的建立、断开都由连接池自身来管理。

同时，还可以通过设置连接池的参数来控制连接池中的初始连接数、连接的上下限数以及每个连接的最大使用次数、最大空闲时间等等。也可以通过其自身的管理机制来监视数据库连接的数量、使用情况等。

二、DBCP数据库连接池

所需jar文件：

1）commons-dbcp2-2.1.jar

2）commons-pool2-2.3.jar

3）mysql-connector-java-5.1.7-bin.jar

首页，下载以上jar包，放到项目的lib目录下，并build path

其次，编写dbcpconfig.properties配置文件

内容如下：

#数据库驱动
driverClassName=com.mysql.jdbc.Driver

#数据库地址
url=jdbc:mysql://localhost:3306/dbname?characterEncoding=UTF-8

#数据库用户名
username=root

#数据库密码
password=

#初始化大小
initialSize=10

#最大连接数据库连接数
maxActive=50

#最大等待连接中的数量
maxIdle=20

#最小等待连接中的数量
minIdle=5

#最大等待毫秒数
maxWait=5000

#默认自动提交
defaultAutoCommit=true

#默认只读
defaultReadOnly= 

#默认事务分离
defaultTransactionIsolation=READ_UNCOMMITTED

接着，在src下的工具类包（一般包名是xx.xxx.utils）里面创建一个DBUtil.java文件,内容如下：

package com.poster.dby.utils;

import java.io.InputStream;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp2.BasicDataSourceFactory;

import java.sql.PreparedStatement;

import java.sql.Connection;
/** * @version1.0 * @author szs * @time 2015-5-2 * DBCP数据库连接池 */
public class DBUtil {
    //数据源
    private static DataSource dataSource = null;
    //静态代码块
    static{
        try {
            //加载配置文件
            InputStream in = DBUtil.class.getResourceAsStream("dbcpconfig.properties");
            Properties p = new Properties();
            p.load(in);
            //创建数据源
            dataSource = BasicDataSourceFactory.createDataSource(p);
        } catch (Exception e) {
            throw new ExceptionInInitializerError(e);
        }
    }
    //获取数据库连接
    public static Connection getConnection() throws  SQLException{
         return  dataSource.getConnection();
    }
    //关闭数据库连接，将连接返还给数据库连接池
    public static void closeDB(ResultSet rs,PreparedStatement ps,Connection conn) {
        try {
            if (rs!=null) {
                rs.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            try {
                if (ps!=null) {
                    ps.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }finally{
                try {
                    if (conn!=null) {
                        conn.close();
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    //关闭数据库连接，将连接返还给数据库连接池
    public static void closeDB(PreparedStatement ps,Connection conn) {
         try {
            if (ps!=null) {
                ps.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally{
            try {
                if (conn!=null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

最后，在操作数据库的时候，使用

Connection conn = DBUtil.getConnection();

即可获取连接。

最后的最后，不要忘记关闭数据库哦

//用来回收连接，适用于删改查
DBUtil.closeDB(rs,ps,conn);

//用来回收连接，适用于增
DBUtil.closeDB(ps,conn);