DBCP连接池

DBCP数据源

　　DBCP 是 Apache 软件基金组织下的开源连接池实现，要使用DBCP数据源，需要应用程序应在系统中增加如下两个 jar 文件：

• Commons-dbcp.jar：连接池的实现
• Commons-pool.jar：连接池实现的依赖库

　　Tomcat 的连接池正是采用该连接池来实现的。该数据库连接池既可以与应用服务器整合使用，也可由应用程序独立使用。

在应用程序中加入dbcp连接池

　　1.导入相关jar包
   　　   commons-dbcp-1.2.2.jar、commons-pool.jar
　　2、在类目录下加入dbcp的配置文件：dbcpconfig.properties

　　　　dbcpconfig.properties的配置信息如下：

#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbc
username=root
password=XDP
#初始化连接
initialSize=10

#最大连接数量
maxActive=200

#最大空闲连接
maxIdle=20

#最小空闲连接
minIdle=5

#超时等待时间以毫秒为单位 6000毫秒/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=READ_UNCOMMITTED

package com.adapter;

import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;

import org.apache.log4j.Logger;

public class ReadProperties {
    private static Logger logger = Logger.getLogger(ReadProperties.class);
    private static Map<String, String> map = new HashMap<String, String>();
    private static String username;
    private static String url;
    private static String password;
    private static String initialSize;
    private static String maxActive;
    private static String maxIdle;
    private static String minIdle;
    private static String maxWait;
    
    static{
//        String filePath = System.getProperty("user.dir") + "/setting.properties";
        
        InputStream in = ReadProperties.class.getResourceAsStream("/dbcpconfig.properties");
        Properties p = new Properties();
        try {
//            InputStream in = new BufferedInputStream(new FileInputStream(filePath));
            p.load(new InputStreamReader(in, "utf-8"));
        } catch (IOException e) {
            logger.error("ReadProperties读取失败", e);
        }
        username = p.getProperty("jdbc.username");
        url = p.getProperty("jdbc.url");
        password = p.getProperty("jdbc.password");
        initialSize = p.getProperty("jdbc.initialSize");
        maxActive = p.getProperty("jdbc.maxActive");
        maxIdle = p.getProperty("jdbc.maxIdle");
        minIdle = p.getProperty("jdbc.minIdle");
        maxWait = p.getProperty("jdbc.maxWait");
    }
    
    public static Map<String, String> getSettingInfo() {
        map.put("username", username);
        map.put("url", url);
        map.put("password", password);
        map.put("initialSize", initialSize);
        map.put("maxActive", maxActive);
        map.put("maxIdle", maxIdle);
        map.put("minIdle", minIdle);
        map.put("maxWait", maxWait);
        return map;
    }

}

package com.util;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Map;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
import com.szht.gpy.adapter.ReadProperties;

public class DBCPUtil {
    private static DataSource dSource = null;
    static{
        Map<String, String> map = ReadProperties.getSettingInfo();
        Properties prop = new Properties();
        try {
            prop.setProperty("driverClassName", "oracle.jdbc.driver.OracleDriver");
            prop.setProperty("url", map.get("url"));
            prop.setProperty("password", map.get("password"));
            prop.setProperty("username", map.get("username"));
            prop.setProperty("maxActive", map.get("maxActive"));
            prop.setProperty("maxIdle", map.get("maxIdle"));
            prop.setProperty("maxWait", map.get("maxWait"));
            prop.setProperty("initialSize", map.get("initialSize"));
            prop.setProperty("minIdle", map.get("minIdle"));
            dSource = BasicDataSourceFactory.createDataSource(prop);
            System.out.println(dSource);
        } catch (Exception e) {
            e.printStackTrace();
            throw new ExceptionInInitializerError(e);
        }
    }
    
    public static Connection getConnection(){
        Connection connection = null;
        try {
            connection = dSource.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return connection;
    }
    
    public static void release(Connection conn,Statement st,ResultSet rs) {
        if (rs != null) {
            try {
                //关闭存储查询结果的ResultSet对象
                rs.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
            rs = null;
        }
        if (st != null) {
            try {
                //关闭负责执行SQL命令的Statement对象
                st.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                //将Connection连接对象还给数据库连接池
                conn.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

}
                  

package com.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import org.junit.Test;
import me.gacl.util.JdbcUtils_DBCP;

public static void main(String[] args) {
  public void dbcpDataSourceTest() {
     Connection conn = null;
     PreparedStatement st = null;
     ResultSet rs = null;
     try{
           //获取数据库连接
           conn = DBCPUtil.getConnection();
           String sql = "insert into test1(name) values(?)";
           st = conn.prepareStatement(sql);
           st.setString(1, "gacl");
           st.executeUpdate();
           //获取数据库自动生成的主键
           rs = st.getGeneratedKeys();
           if(rs.next()){
               System.out.println(rs.getInt(1));
           }
       }catch (Exception e) {
            e.printStackTrace();
       }finally{
             //释放资源
             DBCPUtil.release(conn, st, rs);
            }
        }    
}