C3p0連接池配置

本文轉載自查看原文 2016-09-23 17:03 12216 連接池

在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連接池常識點

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 Tomcat配置連接c3p0連接池 c3p0連接池標准配置 spring配置c3p0連接池 c3p0連接池配置以及使用 C3P0連接池參數配置說明 c3p0連接池基本配置mysql和oracle MyBatis配置C3P0連接池 spring配置c3p0連接池 Hibernate配置C3P0連接池 C3P0連接池配置