C3P0鏈接池的配置與使用

一、下載c3p0-0.9.1.2.jar

下載地址：http://download.csdn.net/detail/chunxiaqiudong5/9661922

 

二、添加配置文件c3p0-config.xml

 

三、配置文件內容以下：

 

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <!-- This is default config! -->
    <default-config>
        <property name="initialPoolSize">10</property>
        <property name="maxIdleTime">30</property>
        <property name="maxPoolSize">100</property>
        <property name="minPoolSize">10</property>
        <property name="maxStatements">200</property>
    </default-config>

    <!-- This is my config for mysql-->
    <named-config name="mysql">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbc?useUnicode=true&characterEncoding=UTF8</property>
        <property name="user">root</property>
        <property name="password"></property>
         <!-- 初始化鏈接池中的鏈接數，取值應在minPoolSize與maxPoolSize之間，默認爲3-->
        <property name="initialPoolSize">10</property>
        <!--最大空閒時間，60秒內未使用則鏈接被丟棄。若爲0則永不丟棄。默認值: 0 -->
        <property name="maxIdleTime">30</property>
        <!--鏈接池中保留的最大鏈接數。默認值: 15 -->
        <property name="maxPoolSize">100</property>
        <!-- 鏈接池中保留的最小鏈接數，默認爲：3-->
        <property name="minPoolSize">10</property>
        <!--c3p0全局的PreparedStatements緩存的大小。若是maxStatements與maxStatementsPerConnection均爲0，則緩存不生效，只要有一個不爲0，則語句的緩存就能生效。若是默認值: 0-->
        <property name="maxStatements">200</property>
        <!-- 當鏈接池鏈接耗盡時，客戶端調用getConnection()後等待獲取新鏈接的時間，超時後將拋出SQLException，如設爲0則無限期等待。單位毫秒。默認: 0 -->
        <property name="checkoutTimeout" value="3000"/>
        <!--當鏈接池中的鏈接耗盡的時候c3p0一次同時獲取的鏈接數。默認值: 3 -->
        <property name="acquireIncrement" value="2"/>
        <!--定義在從數據庫獲取新鏈接失敗後重復嘗試的次數。默認值: 30 ；小於等於0表示無限次-->
        <property name="acquireRetryAttempts" value="0"/>
        <!--從新嘗試的時間間隔，默認爲：1000毫秒-->
        <property name="acquireRetryDelay" value="1000" />
        <!--關閉鏈接時，是否提交未提交的事務，默認爲false，即關閉鏈接，回滾未提交的事務 -->
        <property name="autoCommitOnClose">false</property>
        <!--c3p0將建一張名爲Test的空表，並使用其自帶的查詢語句進行測試。若是定義了這個參數那麼屬性preferredTestQuery將被忽略。你不能在這張Test表上進行任何操做，它將只供c3p0測試使用。默認值: null -->
        <property name="automaticTestTable">Test</property>
         <!--若是爲false，則獲取鏈接失敗將會引發全部等待鏈接池來獲取鏈接的線程拋出異常，可是數據源仍有效保留，並在下次調用getConnection()的時候繼續嘗試獲取鏈接。若是設爲true，那麼在嘗試獲取鏈接失敗後該數據源將申明已斷開並永久關閉。默認: false-->
        <property name="breakAfterAcquireFailure">false</property>
        <!--每60秒檢查全部鏈接池中的空閒鏈接。默認值: 0，不檢查 -->
        <property name="idleConnectionTestPeriod">60</property>
        <!--maxStatementsPerConnection定義了鏈接池內單個鏈接所擁有的最大緩存statements數。默認值: 0 -->
        <property name="maxStatementsPerConnection"></property>
    </named-config>


    <!-- This is my config for oracle -->
    <named-config name="oracle">
        <property name="driverClass">oracle.jdbc.driver.OracleDriver</property>
        <property name="jdbcUrl">jdbc:oracle:thin:@localhost:1521:orcl</property>
        <property name="user">scott</property>
        <property name="password">liang</property>
        <property name="initialPoolSize">10</property>
        <property name="maxIdleTime">30</property>
        <property name="maxPoolSize">100</property>
        <property name="minPoolSize">10</property>
        <property name="maxStatements">200</property>
    </named-config>
</c3p0-config>

四、鏈接池鏈接類

 

package com.xxx.utils;

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JDBCUtil {

    private static DataSource dataSource=null;
    static{
        dataSource=new ComboPooledDataSource("mysql");
    }

    /**
     * 獲取數據庫鏈接
     * @return
     */
    public static Connection getConnection(){
        Connection conn=null;
        try {
             conn=dataSource.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }


    /**
     * 關閉數據庫鏈接
     * @param conn
     */
    public static void closeConn(Connection conn){
        try {
            if(conn!=null && conn.isClosed()){
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

五、測試

 

package com.xxx.test;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.junit.Test;

import com.xxx.utils.JDBCUtil;

public class TestJdbc {

    @Test
    public void test() {
        Connection conn=JDBCUtil.getConnection();
        System.out.println(conn);
        try {
            PreparedStatement stmt=conn.prepareStatement("select * from tb_user");
            ResultSet re=stmt.executeQuery();
            while(re.next()){
                String name=re.getString(2);
                System.out.println(name);

            }


        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }



}