JavaWeb學習過程 之c3p0的使用

　　這幾天在學習使用MVC模式來做幾個小項目，在學習的過程中，用到了數據庫連接池。便特意去學習了一下。

 

一、談一談為什么要使用數據庫連接池

　　在開發基於數據庫的web程序時，傳統的模式（在servlet，beans 中建立數據庫鏈接，進行sql操作， 斷開數據庫鏈接） 存在着一些問題。

　　每次連接都需要驗證用戶，消耗了大量的資源和時間。數據庫的連接資源並沒有得到很好地重復利用。再如，同時幾萬人在線頻繁的連接數據庫，系統資源消耗巨大，內存可能泄漏，服務器也可能會崩潰。

 

二、什么是數據庫連接池

　　1.基本思想：可以為數據庫建立一個“緩沖池”。預先在緩沖池中放入一定數量的連接，當需要建立數據庫連接時，只需要從“緩沖池”中取出一個，使用完畢再放回去，避免了重復連接所消耗的時間與資源。

　　

　　2.職責：數據庫連接池負責分配，管理，和釋放數據庫鏈接，它允許應用程序重復使用一個現有的數據庫鏈接，而不是新建立一個。

　　

　　3.JDBC的數據庫鏈接池使用javax.sql.DataSource 來表示，DataSource 只是一個接口，該接口通常由服務器（Webblogic，Tomact）提供實現，也有一些開源組織提供實現：DBCP，C3P0。

 

三、使用C3P0 數據庫連接池

　　C3P0有兩種連接方式。

　　1.第一種：

　　　　具體步驟：

　　　　　　1.導入所需jar包

　　　　　　2.java代碼

　　　　　　

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.SQLException;

import com.mchange.v2.c3p0.ComboPooledDataSource;


public class JDBCUtils {
    private static Connection conn=null;
    private static ComboPooledDataSource comboPooledDataSource=new ComboPooledDataSource();
    
    public static Connection getConnection(){
        try {
            comboPooledDataSource.setDriverClass("com.microsoft.sqlserver.jdbc.SQLServerDriver");
            comboPooledDataSource.setJdbcUrl("jdbc:sqlserver://localhost:1433;databasename=mysql");
            comboPooledDataSource.setUser("sa");
            comboPooledDataSource.setPassword("1546873");
            
            comboPooledDataSource.setAcquireIncrement(5);// 可以設置連接池的各種屬性
            
            conn=comboPooledDataSource.getConnection();
        } catch (PropertyVetoException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return conn;
    }

}

 

　　2.第二種：

　　　　具體步驟：

　　　　　　1.導入jar包

　　　　　　2.配置xml文件。 配置文件名必須名為 c3p0-config.xml 並且放在src目錄下

　　　　　　代碼如下

<c3p0-config> 
    <named-config name="myc3p0"> 
        <property name="user">sa</property> 
        <property name="password">ztg591379771</property> 
        <property name="driverClass">com.microsoft.sqlserver.jdbc.SQLServerDriver</property> 
        <property name="jdbcUrl">jdbc:sqlserver://localhost:1433;databasename=mysql</property> 
        
        <!-- 若數據庫中連接數不足時，一次向數據庫服務器申請多少個鏈接 -->
        <!--當連接池中的連接耗盡的時候c3p0一次同時獲取的連接數。Default: 3 -->
        <property name="acquireIncrement">5</property> 
        
        
        <!--初始化時獲取三個連接，取值應在minPoolSize與maxPoolSize之間。Default: 3 -->
        <property name="initialPoolSize">10</property> 
        
        
        <!--連接池中保留的最小連接數。-->
        <property name="minPoolSize">10</property> 
        
        
        <!--連接池中保留的最大連接數。Default: 15 -->
        <property name="maxPoolSize">50</property> <!-- intergalactoApp adopts a different approach to configuring statement caching --> 
        
        <!--JDBC的標准參數，用以控制數據源內加載的PreparedStatements數量。但由於預緩存的statements
            屬於單個connection而不是整個連接池。所以設置這個參數需要考慮到多方面的因素。
            如果maxStatements與maxStatementsPerConnection均為0，則緩存被關閉。Default: 0-->
        <property name="maxStatements">20</property> 
        
        
        <!--maxStatementsPerConnection定義了連接池內單個連接所擁有的最大緩存statements數。Default: 0 -->
        <!-- 每個鏈接可以使用的Statements 對象的個數 -->
        <property name="maxStatementsPerConnection">5</property> <!-- he's important, but there's only one of him --> 
    
    </named-config> 
</c3p0-config>

　　　　　　3.編寫utils工具類

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

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JdbcUtils {
    
    /**
     * 釋放鏈接
     * @param connection
     */
    public static void releaseConnection(Connection connection){
        if(connection!=null){
            try {
                connection.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
    
    
    private static ComboPooledDataSource dataSource=null;
    
    static{
        //只被創建一次
        dataSource=new ComboPooledDataSource("myc3p0");  // myc3p0 一定要與配置文件中的名字一樣 29     }
        
    /**
     * 返回數據源的一個Connection 對象
     * @return
     * @throws Exception 
     */
    public static Connection getConnection() throws Exception{
        return dataSource.getConnection();
    }    
}

 

 

　　以上是我今天學到的關於c3p0的一些知識，今后在學習的過程中慢慢摸索，逐漸補充。