C3p0連接池配置_ZenDei技術網路在線

在Java開發中，使用JDBC操作資料庫的四個步驟如下： ①載入資料庫驅動程式(Class.forName("資料庫驅動類");) ②連接資料庫(Connection con = DriverManager.getConnection();) ③操作資料庫(PreparedStatement sta ...

在Java開發中，使用JDBC操作資料庫的四個步驟如下：

　　　　①載入資料庫驅動程式(Class.forName("資料庫驅動類");)
  　　　　②連接資料庫(Connection con = DriverManager.getConnection();)
  　　　　③操作資料庫(PreparedStatement stat = con.prepareStatement(sql);stat.executeQuery();)
  　　　　④關閉資料庫，釋放連接(con.close();)
　　也就是說，所有的用戶都需要經過此四步進行操作，但是這四步之中有三步(①載入資料庫驅動程式、②連接資料庫、④關閉資料庫，釋放連接)對所有人都是一樣的，而所有人只有在操作資料庫上是不一樣，那麼這就造成了性能的損耗。
　　那麼最好的做法是，準備出一個空間，此空間里專門保存著全部的資料庫連接，以後用戶用資料庫操作的時候不用再重新載入驅動、連接資料庫之類的，而直接從此空間中取走連接，關閉的時候直接把連接放回到此空間之中。那麼此空間就可以稱為連接池（保存所有的資料庫連接）

C3P0相關認識

C3P0是一個開源的JDBC連接池，它實現了數據源和JNDI綁定，支持JDBC3規範和JDBC2的標準擴展。目前使用它的開源項目有Hibernate，Spring等。

什麼是連接池：

連接池是創建和管理一個連接的緩衝池的技術，這些連接準備好被任何需要它們的線程使用；簡單理解為，當一輛汽車搬運東西，如果使用jdbc連接，(jdbc連接:與資料庫建立連接、發送操作資料庫的語句並處理結果)那麼每一次都要去打開資料庫，獲得連接，關閉資料庫。假設汽車搬運的東西是連接，那麼我可不可以每一次將連接搬運多個呢？而不是jdbc那樣，一次只搬運一個連接，然後就把汽車扔掉？這時候，使用連接池。

原理：

連接池基本的思想是在系統初始化的時候，將資料庫連接作為對象存儲在記憶體中，當用戶需要訪問資料庫時，並非建立一個新的連接，而是從連接池中取出一個已建立的空閑連接對象。使用完畢後，用戶也並非將連接關閉，而是將連接放回連接池中，以供下一個請求訪問使用。而連接的建立、斷開都由連接池自身來管理。同時，還可以通過設置連接池的參數來控制連接池中的初始連接數、連接的上下限數以及每個連接的最大使用次數、最大空閑時間等等。也可以通過其自身的管理機制來監視資料庫連接的數量、使用情況等。

為什麼要用到連接池

資料庫連接池的基本思想就是為資料庫連接建立一個“緩衝池”。預先在緩衝池中放入一定數量的連接，當需要建立資料庫連接時，只需從“緩衝池”中取出一個，使用完畢之後再放回去。我們可以通過設定連接池最大連接數來防止系統無盡的與資料庫連接。連接池主要由三部分組成：連接池的建立、連接池中連接的使用管理、連接池的關閉。

資料庫連接池的最小連接數和最大連接數的設置要考慮到以下幾個因素:

最小連接數:是連接池一直保持的資料庫連接,所以如果應用程式對資料庫連接的使用量不大,將會有大量的資料庫連接資源被浪費.
最大連接數:是連接池能申請的最大連接數,如果資料庫連接請求超過次數,後面的資料庫連接請求將被加入到等待隊列中,這會影響以後的資料庫操作
如果最小連接數與最大連接數相差很大:那麼最先連接請求將會獲利,之後超過最小連接數量的連接請求等價於建立一個新的資料庫連接.不過,這些大於最小連接數的資料庫連接在使用完不會馬上被釋放,他將被放到連接池中等待重覆使用或是空間超時後被釋放

使用c3p0需要導包:

c3p0-0.9.5.2-sources.jar

mchange-commons-java-0.2.11-sources.jar

c3p0-oracle-thin-extras-0.9.5.2.jar

hsqldb.jar

commons-pool-1.4.jar

commons-dbcp-1.2.2.jar

將包導入到lib中

測試代碼：

連接oracle資料庫

使用c3p0-config.xml配置：

package com.c3p0;

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

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class TestC3P0 {
      static ComboPooledDataSource cpds=null;  
        static{  
            //這裡有個優點，寫好配置文件，想換資料庫，簡單  
            //cpds = new ComboPooledDataSource("oracle");//這是oracle資料庫  
            cpds = new ComboPooledDataSource("oracle");//這是mysql資料庫  
        }  
        /** 
         * 獲得資料庫連接 
         * @return   Connection 
         */  
        public static Connection getConnection(){  
            try {  
                return cpds.getConnection();  
            } catch (SQLException e) {  
                e.printStackTrace();  
                return null;  
            }  
        }  
          
        /** 
         * 資料庫關閉操作 
         * @param conn   
         * @param st     
         * @param pst 
         * @param rs 
         */  
        public static void close(Connection conn,PreparedStatement pst,ResultSet rs){  
            if(rs!=null){  
                try {  
                    rs.close();  
                } catch (SQLException e) {  
                    e.printStackTrace();  
                }  
            }  
            if(pst!=null){  
                try {  
                    pst.close();  
                } catch (SQLException e) {  
                    e.printStackTrace();  
                }  
            }  
      
            if(conn!=null){  
                try {  
                    conn.close();  
                } catch (SQLException e) {  
                    e.printStackTrace();  
                }  
            }  
        }  
        /** 
         * 測試DBUtil類 
         * @param args 
         */  
        public static void main(String[] args) {  
            Connection conn=getConnection();  
            System.out.println(conn.getClass().getName());
            Statement stmt;
            ResultSet rs=null;
            try {
                stmt = conn.createStatement();
                rs=stmt.executeQuery("select empno from emp");
                while(rs.next()){
                    System.out.println(rs.getInt(1));
                }
            } catch (SQLException e) {
                e.printStackTrace();
            } finally {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            close(conn,null,null);  
        }  
}

配置文件：c3p0-config.xml(路徑放在src下)

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
<named-config name="oracle">  
        <property name="driverClass">oracle.jdbc.driver.OracleDriver</property>  
        <property name="jdbcUrl">jdbc:oracle:thin:@192.168.85.2:1521:orcl</property>  
        <property name="user">scott</property>  
        <property name="password">tiger</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>

java配置連接hsqldb資料庫

以下測試代碼需要開啟hsqldb，否則會有異常信息(具體方法請看proxool+hsqldb)

hsqldb.jar --> org.hsqldb.server --> Server 右擊選擇run -->java Application ，開啟hsqldb

新建監聽類，繼承 ServletContextListenpackage com.c3p0.Listener;

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

import javax.annotation.Resource;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;


@WebListener
public class cplistener implements ServletContextListener {
    @Override
    public void contextDestroyed(ServletContextEvent arg0) {
        com.close();
    }

    @Override
    public void contextInitialized(ServletContextEvent arg0) {
      //封裝資料庫連接
　　　　private ComboPooledDataSource com = new ComboPooledDataSource();

        System.out.println("初始化參數");

        try {
             //載入hsqldb資料庫的驅動
            com.setDriverClass("org.hsqldb.jdbc.JDBCDriver");
            //使用客戶端連接
            com.setJdbcUrl("jdbc:hsqldb:hsql://localhost/");
            com.setUser("sa");           //賬號
            com.setPassword("");         //密碼
            com.setMaxPoolSize(15);      //最大連接數
            com.setMaxIdleTime(10);      //設置連接時間
            Connection conn = com.getConnection();
            arg0.getServletContext().setAttribute("conn", conn);
            } catch (PropertyVetoException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

使用properties配置文件連接hsqldb

新建c3p0.properties(註意名字必須為這個，放在src文件夾下麵)

c3p0.driverClass=org.hsqldb.jdbc.JDBCDriver
c3p0.jdbcUrl=jdbc:hsqldb:hsql://localhost/
c3p0.user=sa
c3p0.password=

測試代碼

package com.c3p0.Listener;

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

import javax.annotation.Resource;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

@WebListener
public class cplistener implements ServletContextListener {
    //封裝資料庫連接
    private ComboPooledDataSource com = new ComboPooledDataSource();
    @Override
    public void contextDestroyed(ServletContextEvent arg0) {
        com.close();
    }

    @Override
    public void contextInitialized(ServletContextEvent arg0) {
        // TODO Auto-generated method stub
        System.out.println("監聽資料庫連接");
        //使用java代碼配置hsqldb
        try {
            Connection conn = com.getConnection();
            //將連接賦值給上下文的屬性中，後期可通過請求獲取
            arg0.getServletContext().setAttribute("conn", conn);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("監聽初始化方法結束");
    }
}

使用jndi連接mysql資料庫

導包：mysql-connector-java-5.1.39-bin.jar，可將包導入到Tomcat伺服器lib中。

註意:mysql資料庫必須啟動

使用JNDI數據源
在項目Servers中，該項目是Tomcat導入eclipse中的自動生成的，裡面是配置文件信息，找到context.xml，將以下代碼添加進去

代碼：

<Resource 
        name="jdbc/mysql"
        auth="Container" 
        type="javax.sql.DataSource"
        maxActive="100" 
        maxIdle="30" 
        maxWait="10000"
        username="root" 
        password="root"
        driverClassName="com.mysql.jdbc.Driver"
        url="jdbc:mysql://localhost:3306/mysql?useUnicode=true&amp;characterEncoding=utf-8"/>

註意：

1、name的名字必須和等下在Web.xml中一樣，還有在java代碼中連接資料庫語句的一處一樣。

2、這裡使用的是mysql資料庫連接，外部mysql伺服器必須開著。

3、jdbc:mysql://localhost:3306/mysql中的mysql是你mysql中的資料庫，必須存在，否則會包null錯誤

4、如果異常報空，要麼就是配置文件錯誤，要麼就是mysql中沒有當前的資料庫錯誤。

5、context.xml配置信息，當eclipse項目刪除Tomcat伺服器的時候，該配置需要重新配置

在Web.xml配置中添加以下代碼

<resource-ref>
 <res-ref-name>jdbc/mysql</res-ref-name>
 <res-type>javax.sql.DataSource</res-type>
 <res-auth>Container</res-auth>
</resource-ref>

java代碼，新建監聽類繼承 ServletContextListener

package com.c3p0.Listener;

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

import javax.annotation.Resource;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

@WebListener
public class cplistener implements ServletContextListener {
    //封裝資料庫連接
    private ComboPooledDataSource com = new ComboPooledDataSource();
    @Override
    public void contextDestroyed(ServletContextEvent arg0) {
        com.close();
    }

    @Override
    public void contextInitialized(ServletContextEvent arg0) {
        // TODO Auto-generated method stub
        System.out.println("初始化參數");
        
        Connection connMySQL = null;
        try {
            //1、初始化名稱查找上下文
            InitialContext ctx = new InitialContext();
            //2、通過JNDI名稱找到DataSource,對名稱進行定位java:comp/env是必須加的,後面跟的是DataSource名
            /*
            DataSource名在web.xml文件中的<res-ref-name>jdbc/mysql</res-ref-name>進行了配置
              <!--MySQL資料庫JNDI數據源引用 -->
              <resource-ref>
                  <res-ref-name>jdbc/mysql</res-ref-name>
                  <res-type>javax.sql.DataSource</res-type>
                  <res-auth>Container</res-auth>
              </resource-ref>
            */
            DataSource ds = (DataSource)ctx.lookup("java:comp/env/jdbc/mysql");
            //3、通過DataSource取得一個連接
            connMySQL = ds.getConnection();
            System.out.println("連接正常！");
            //4、操作資料庫
        } catch (NamingException e) {
            System.out.println(e.getMessage());
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //5、關閉資料庫，關閉的時候是將連接放回到連接池之中
            try {
                connMySQL.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
}

Java連接池編輯
在Java中開源的資料庫連接池有以下幾種 ：
1、C3P0：是一個開放源代碼的JDBC連接池，它在lib目錄中與Hibernate[2]  一起發佈，包括了實現jdbc3和jdbc2擴展規範說明的Connection 和Statement 池的DataSources 對象。
2、Proxool：是一個Java SQL Driver驅動程式，提供了對選擇的其它類型的驅動程式的連接池封裝。可以非常簡單的移植到現存的代碼中，完全可配置，快速、成熟、健壯。可以透明地為現存的JDBC驅動程式增加連接池功能。
3、Jakarta DBCP：DBCP是一個依賴Jakartacommons-pool對象池機制的資料庫連接池。DBCP可以直接的在應用程式中使用。
4、DDConnectionBroker：是一個簡單、輕量級的資料庫連接池。
5、DBPool：是一個高效、易配置的資料庫連接池。它除了支持連接池應有的功能之外，還包括了一個對象池，使用戶能夠開發一個滿足自己需求的資料庫連接池。
6、XAPool：是一個XA資料庫連接池。它實現了javax.sql.XADataSource並提供了連接池工具。
7、Primrose：是一個Java開發的資料庫連接池。當前支持的容器包括Tomcat4&5、Resin3與JBoss3。它同樣也有一個獨立的版本，可以在應用程式中使用而不必運行在容器中。Primrose通過一個WEB介面來控制SQL處理的追蹤、配置，以及動態池管理。在重負荷的情況下可進行連接請求隊列處理。
8、SmartPool：是一個連接池組件，它模仿應用伺服器對象池的特性。SmartPool能夠解決一些臨界問題如連接泄漏（connection leaks）、連接阻塞、打開的JDBC對象（如Statements、PreparedStatements）等。SmartPool的特性包括：
支持多個pool
自動關閉相關聯的JDBC對象
在所設定time-outs之後察覺連接泄漏
追蹤連接使用情況
強制啟用最近最少用到的連接
把SmartPool“包裝”成現存的一個pool
9、MiniConnectionPoolManager：是一個輕量級JDBC資料庫連接池。它只需要Java1.5（或更高）並且沒有依賴第三方包。
10、BoneCP：是一個快速、開源的資料庫連接池。幫用戶管理數據連接，讓應用程式能更快速地訪問資料庫。比C3P0/DBCP連接池速度快25倍。
11、Druid：Druid不僅是一個資料庫連接池，還包含一個ProxyDriver、一系列內置的JDBC組件庫、一個SQL Parser。
支持所有JDBC相容的資料庫，包括Oracle、MySql、Derby、Postgresql、SQL Server、H2等。
Druid針對Oracle和MySql做了特別優化，比如：
Oracle的PS Cache記憶體占用優化
MySql的ping檢測優化
Druid提供了MySql、Oracle、Postgresql、SQL-92的SQL的完整支持，這是一個手寫的高性能SQL Parser，支持Visitor模式，使得分析SQL的抽象語法樹很方便。
簡單SQL語句用時10微秒以內，複雜SQL用時30微秒。
通過Druid提供的SQL Parser可以在JDBC層攔截SQL做相應處理，比如說分庫分表、審計等。Druid防禦SQL註入攻擊的WallFilter，就是通過Druid的SQL Parser分析語義實現的

Java連接池常識點