DBCP數據庫鏈接池的簡單使用

0、DBCP簡介

     DBCP(DataBase connection pool)數據庫鏈接池是 apache 上的一個Java鏈接池項目。DBCP經過鏈接池預先同數據庫創建一些鏈接放在內存中(即鏈接池中)，應用程序須要創建數據庫鏈接時直接到從接池中申請一個鏈接使用，用完後由鏈接池回收該鏈接，從而達到鏈接複用，減小資源消耗的目的。

一、DBCP所依賴的jar包(如下例子基於以下jar包版本)

 　 commons-dbcp2-2.1.1.jar       commons-logging-1.2.jar       commons-pool2-2.4.2.jar

二、DBCP使用示例

　　下圖是在Eclipse中建立的Java工程，使用了DBCP相關的jar包，mysql的jdbc驅動jar包，junit4 。

　　 並在src同級目錄下建立了config目錄，用於存放DBCP的配置文件。

      【注】類DBCPUtil.java在下面的例子中未用到。

　　

　　1) DBCP配置文件dbcp.properties

########DBCP配置文件##########

#驅動名
driverClassName=com.mysql.jdbc.Driver
#url
url=jdbc:mysql://127.0.0.1:3306/mydb
#用戶名
username=sa
#密碼
password=123456
#初試鏈接數
initialSize=30
#最大活躍數
maxTotal=30
#最大idle數
maxIdle=10
#最小idle數
minIdle=5
#最長等待時間(毫秒)
maxWaitMillis=1000
#程序中的鏈接不使用後是否被鏈接池回收(該版本要使用removeAbandonedOnMaintenance和removeAbandonedOnBorrow)
#removeAbandoned=true
removeAbandonedOnMaintenance=true
removeAbandonedOnBorrow=true
#鏈接在所指定的秒數內未使用纔會被刪除(秒)(爲配合測試程序才配置爲1秒)
removeAbandonedTimeout=1

 　　

　　2) 建立初始化DBCP的類KCYDBCPUtil.java　　

  package dbcp;
  
  import java.io.FileInputStream;
  import java.io.IOException;
  import java.sql.Connection;
  import java.sql.SQLException;
  import java.util.Properties;
  
  import javax.sql.DataSource;
 
 import org.apache.commons.dbcp2.BasicDataSourceFactory;
 
 /**
  * DBCP配置類
  * @author SUN
  */
 public class KCYDBCPUtil {
     
     private static Properties properties = new Properties();
     private static DataSource dataSource;
     //加載DBCP配置文件
     static{
         try{
             FileInputStream is = new FileInputStream("config/dbcp.properties");  
             properties.load(is);
         }catch(IOException e){
             e.printStackTrace();
         }
         
         try{
             dataSource = BasicDataSourceFactory.createDataSource(properties);
         }catch(Exception e){
             e.printStackTrace();
         }
     }
     
     //從鏈接池中獲取一個鏈接
     public static Connection getConnection(){
         Connection connection = null;
         try{
             connection = dataSource.getConnection();
         }catch(SQLException e){
             e.printStackTrace();
         }
         try {
             connection.setAutoCommit(false);
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return connection;
     }
     
     public static void main(String[] args) {
         getConnection();
     }
 }

 

 　　3) 建立使用JDBC獲取數據庫鏈接的類DBConn.java（用於和DBCP鏈接池對比）

  package dbcp;

  
  import java.sql.Connection;
  import java.sql.DriverManager;
  
  public class DBConn {
      private static Connection conn = null;
      
      //獲取一個數據庫鏈接
     public static Connection getConnection() {
         try {
             Class.forName("com.mysql.jdbc.Driver");
             DriverManager.registerDriver(new com.mysql.jdbc.Driver());
            String dbUrl = "jdbc:mysql://127.0.0.1:3306/mydb";
             conn = DriverManager.getConnection(dbUrl, "sa", "123456");
 //            System.out.println("========數據庫鏈接成功========");
         } catch (Exception e) {
             e.printStackTrace();
 //            System.out.println("========數據庫鏈接失敗========");
             return null;
         }
         return conn;
     }
 }

 

 　　4) 建立測試類DBCPTest.java

　　　　測試類中採用3中方法將2000個數據插入數據庫同一張表中，每次插入數據以前，先清空表，並對結果進行了對比。

　　　　3中插入數據方法以下：

　　　　(1) 每次插入一條數據前，就建立一個鏈接，該條數據插入完成後，關閉該鏈接；

   　　　(2) 使用DBCP鏈接池，每次插入一條數據前，從DBCP鏈接池中獲取一條鏈接，該條數據插入完成後，該鏈接交由DBCP鏈接池管理；

　　　　(3) 在插入數據以前建立一條鏈接，2000個數據所有使用該鏈接，2000個數據插入完畢後，關閉該鏈接。

  package dbcp;
  
  import java.sql.Connection;
  import java.sql.SQLException;
  import java.sql.Statement;
  
  import org.junit.Test;
 
  public class DBCPTest {
     
     //測試,每寫一條數據前,就新建一個鏈接
     @Test
     public void testWriteDBByEveryConn() throws Exception{
         for(int i = 0; i < 2000; i++){
             writeDBByEveryConn(i);
         }
         System.out.println("DONE");
         
     }
     
     //測試,使用鏈接池,每寫一條數據前,從鏈接池中獲取一個鏈接
    @Test
     public void testWriteDBByDBCP() throws Exception{
         for(int i = 0; i < 2000; i++){
             writeDBByDBCP(i);
         }
         System.out.println("DONE");
     }
     
     //測試,只建一條鏈接,寫入全部數據
     @Test
     public void testWriteDBByOneConn() throws Exception{
         Connection conn = DBConn.getConnection();
         Statement stat = conn.createStatement();
         for(int i = 0; i < 2000; i++){
             writeDBByOneConn(i, stat);
        }
         conn.close();
         System.out.println("DONE");
     }
     
     //不使用鏈接池寫數據庫,每寫一條數據建立一個鏈接
     public void writeDBByEveryConn(int data){
         String sql = "insert into dbcp values (" + data + ")"; 
         Connection conn = DBConn.getConnection();
         try{    
             Statement stat = conn.createStatement();
             stat.executeUpdate(sql);            
         }catch(Exception e){
             e.printStackTrace() ;
         }finally{
             try {    
                 conn.close();    
             } catch (SQLException e) {
                 e.printStackTrace();
             }
             
         }
     }
     
     //不使用鏈接池寫數據庫,只用一個鏈接,寫全部數據
     public void writeDBByOneConn(int data, Statement stat){
         String sql = "insert into dbcp values (" + data + ")"; 
         try{    
             stat.executeUpdate(sql);            
         }catch(Exception e){
             e.printStackTrace() ;
         }
     }
     
     //經過DBCP鏈接池寫數據庫
     public void writeDBByDBCP(int data){ 
         String sql = "insert into dbcp values (" + data + ")"; 
         try {
             Connection conn = KCYDBCPUtil.getConnection();  
             Statement stat = conn.createStatement();
             stat.executeUpdate(sql);
             conn.commit();
             conn.close();
         } catch (SQLException e) {   
             e.printStackTrace();  
         }
     }
 
 } 

　　測試結果以下：

　　(1) 每次插入一條數據前，就建立一個鏈接，該條數據插入完成後，關閉該鏈接。耗時158.318秒

　　　

　　(2) 使用DBCP鏈接池，每次插入一條數據前，從DBCP鏈接池中獲取一條鏈接，該條數據插入完成後，該鏈接交由DBCP鏈接池管理。耗時122.404秒

 　　 

　　(3) 在插入數據以前建立一條鏈接，2000個數據所有使用該鏈接，2000個數據插入完畢後，關閉該鏈接。耗時117.87秒

 　　 

 　　經過對比結果看出，向同一個表中插入2000條數據，每插入一條數據前建立一個新鏈接，會很是耗時，而使用DBCP鏈接池和使用同一個鏈接操做，耗時比較接近。

 三、相關問題

　　1) 應用程序中，使用完一個數據庫鏈接後，DBCP鏈接池如何管理該鏈接。

 　　　分兩種狀況：

　　　 (1) 應用程序中主動關閉該鏈接，即DBCPTest.java中第79行  conn.close();

　　　　　這種狀況並非手動將該鏈接關閉，而是將該鏈接交回給DBCP鏈接池，由鏈接池管理該鏈接。即用完鏈接後顯示的將數據庫鏈接提交至DBCP鏈接池。

　　　 (2) 應用程序中不關閉該鏈接，即將DBCPTest.java中第79行  conn.close()註釋掉

　　　　　這種狀況DBCP配置文件dbcp.properties中的配置項(注意jar包版本，低版本中使用removeAbandoned=true配置項)　

　　　　　removeAbandonedOnMaintenance=true
     　　　removeAbandonedOnBorrow=true

　　　　  removeAbandonedTimeout=1

　　　　  會起做用，removeAbandonedOnMaintenance=true和removeAbandonedOnBorrow=true表示DBCP鏈接池自動管理應程序中使用完畢的鏈接，removeAbandonedTimeout=1表示一個鏈接在程序中使用完畢後，若在1秒以內沒有再次使用，則DBCP鏈接池回收該鏈接(一般removeAbandonedTimeout不會配置1，此處爲了測試使用)。

　　　 (3) 驗證removeAbandonedOnMaintenance=true、removeAbandonedOnBorrow=true和removeAbandonedTimeout=1配置項的做用

　　　　   將測試類DBCPTest.java的writeDBByDBCP(int data)方法修改成以下：

      //經過DBCP鏈接池寫數據庫
      public void writeDBByDBCP(int data){ 
          String sql = "insert into dbcp values (" + data + ")"; 
          try {
              Connection conn = KCYDBCPUtil.getConnection();  
              Statement stat = conn.createStatement();
              stat.executeUpdate(sql);
              conn.commit();
  //            conn.close();
         } catch (SQLException e) {   
             e.printStackTrace();  
         }
     }

 

　　　　從新執行testWriteDBByDBCP()方法，結果以下：

 　　　　

　　　　可見writeDBByDBCP(int data)方法修改後和修改前做用相同，說明鏈接使用完後，由DBCP鏈接池管理。

　　　　而若是將修改配置項removeAbandonedTimeout=180，即一個鏈接用完後會等待180秒，超過180秒後才由DBCP鏈接池回收，從新執行testWriteDBByDBCP()方法，執行一段時間後報錯(Cannot get a connection, pool error Timeout waiting for idle object)，以下：

　　　　

　　　　此時，查詢數據表，發現正好插入了30條數據，以下：

　　　　

　　　　這說明在插入第31條數據的時候報錯，錯誤緣由是鏈接池中沒有可用的鏈接了。這是由於DBCP鏈接池初始化鏈接數爲30，removeAbandonedTimeout設爲180秒，因此30個鏈接用完後，程序運行還未 到180秒，程序中用完的鏈接都尚未被DBCP鏈接池回收，因此DBCP鏈接池中沒有可用的鏈接了，纔會在插入第31條數據時報錯。