Java基礎-DBCP連接池(BasicDataSource類)詳解

　　　　　　　　　　Java基礎-DBCP連接池(BasicDataSource類)詳解

　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　作者：尹正傑

版權聲明：原創作品，謝絕轉載！否則將追究法律責任。

 

 

 

　　實際開發中“獲得連接”或“釋放資源”是非常消耗系統資源的兩個過程，為了解決此類性能問題，通常情況我們采用連接池技術，來共享連接Connection。這樣我們就不需要每次都創建連接、釋放連接了，這些操作都交給了連接池。

 

一.連接池概述

1>.什么是連接池

　　用池來管理Connection，這樣可以重復使用Connection。有了池，所以我們就不用自己來創建Connection，而是通過池來獲取Connection對象。當使用完Connection后，調用Connection的close()方法也不會真的關閉Connection，而是把Connection“歸還”給池。池就可以再利用這個Connection對象了。

2>.規范

　　Java為數據庫連接池提供了公共的接口：javax.sql.DataSource，各個廠商需要讓自己的連接池實現這個接口。這樣應用程序可以方便的切換不同廠商的連接池！常見的連接池：DBCP、C3P0。本篇博客的主角是DBCP連接池。

 

 

二.DBCP連接池

　　DBCP也是一個開源的連接池，是Apache Common成員之一，在企業開發中也比較常見，tomcat內置的連接池。如果我們想要使用它的功能的話，需要導入jar包，可以用Maven方式進行下載包，它可以幫我們解決一些依賴關系。Maven的使用請參考：http://www.cnblogs.com/yinzhengjie/p/9017416.html

1>.導入連接池jar包

2>.常見配置項

分類	屬性	描述
必須項	driverClassName	數據庫驅動名稱
	url	數據庫的地址
	username	用戶名
	password	密碼
基本項（擴展）	maxActive	最大連接數量
	minIdle	最小空閑連接
	maxIdle	最大空閑連接
	initialSize	初始化連接

　　想要查看更詳細的信息可參考DBCP的官網：http://commons.apache.org/proper/commons-dbcp/configuration.html

 

三.BasicDataSource類的使用

1>.准備數據庫實驗環境

/*
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/%E6%95%B0%E6%8D%AE%E5%BA%93%E4%BB%8E%E5%85%A5%E9%97%A8%E5%88%B0%E7%B2%BE%E9%80%9A/
EMAIL:[e-mail]
*/

CREATE TABLE Teacher(
    id INT PRIMARY KEY AUTO_INCREMENT,
    Name varchar(30) COLLATE gbk_bin DEFAULT NULL,
    Age int DEFAULT NULL,
    Job varchar(50),
    JobDescription varchar(100)
);

2>.代碼如下：

#@author :yinzhengjie
#Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/
#EMAIL:[e-mail]
#
DriverName=com.mysql.jdbc.Driver
url=jdbc:mysql://192.168.0.254:5200/yinzhengjie?useServerPrepStmts=true&cachePrepStmts=true&rewriteBatchedStatements=true
username=root
password=yinzhengjie
initialSize=10
maxIdle=5
minIdle=3
maxActive=1

/*
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/
EMAIL:[e-mail]
*/
package cn.org.yinzhengjie.note3;

import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSource;
import java.util.ResourceBundle;

/**
 *    在dbcp連接池的jar中，有 一個定義好的BasicDataSource累，通過查看源碼，發現該實現類已經幫我們實現類了數據源的規范接口，即javax.sql.DataSource
 */
public class JDBCUtils {
    
    //創建DataSource接口的實現類對象(BasicDataSource)，我們的dbcp工具包已經幫我們實現好了，咱們直接用就好！
    private static BasicDataSource dataSource = new BasicDataSource();    
    
    //定義數據庫鏈接變量
    private static final String DRIVERNAME;
    private static final String URL;
    private static final String USERNAME;
    private static final String PASSWORD;
    private static final int INITIALSIZE;
    private static final int MAXIDLE;
    private static final int MINLDEL;
    private static final int MAXACTIVE;
    
    static {
        //注意，我在Windows的配置文件全名是：“yinzhengjie.properties”，但是我們在給ResourceBundle的getBundle傳參時應該注意兩件事：第一，只傳遞文件名稱並不傳遞文件后綴(即:yinzhengjie)，第二，該文件應該在classpath中或者是跟包名在同一路徑(即：在src目錄中)
        DRIVERNAME = ResourceBundle.getBundle("yinzhengjie").getString("DriverName");
        URL = ResourceBundle.getBundle("yinzhengjie").getString("url");
        USERNAME = ResourceBundle.getBundle("yinzhengjie").getString("username");
        PASSWORD = ResourceBundle.getBundle("yinzhengjie").getString("password");
        INITIALSIZE = Integer.parseInt( ResourceBundle.getBundle("yinzhengjie").getString("initialSize"));
        MAXIDLE = Integer.parseInt(ResourceBundle.getBundle("yinzhengjie").getString("maxIdle"));
        MINLDEL = Integer.parseInt(ResourceBundle.getBundle("yinzhengjie").getString("minIdle"));
        MAXACTIVE = Integer.parseInt(ResourceBundle.getBundle("yinzhengjie").getString("maxActive"));
    }
    
    //靜態代碼塊，對象BasicDataSource對象中的配置，自定義
    static {
        //鏈接數據庫的4個最基本信息，通過對象的set方法進行設置如下：
        dataSource.setDriverClassName(DRIVERNAME);                    //設置數據庫驅動
        dataSource.setUrl(URL);                                        //設置訪問數據庫的路徑
        dataSource.setUsername(USERNAME);                            //設置登錄數據庫的用戶名
        dataSource.setPassword(PASSWORD);                            //設置登錄數據庫的密碼
        
        //對象連接池中的常見配置項，以下的四個配置可以不配置(因為有默認配置)，但是上面的四個是必須要配置的！
        dataSource.setInitialSize(INITIALSIZE);            //指定初始化的連接數
        dataSource.setMaxActive(MAXIDLE);                  //指定最大鏈接數量
        dataSource.setMaxIdle(MINLDEL);                    //指定最大空閑數
        dataSource.setMinIdle(MAXACTIVE);               //指定最小空閑數
    }
    
    //定義靜態方法，返回BasicDataSource類的對象
    public static DataSource getDataSource() {
        return dataSource;
    }

}

/*
@author :yinzhengjie
Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/
EMAIL:[e-mail]
*/
package cn.org.yinzhengjie.note3;

import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayListHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;

public class QueryRunnerDemo {
    //定義兩個方法，實現數據表的添加，數據表查詢，QueryRunner類對象，寫在類成員位置
    private static QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
    
    public static void main(String[] args) {
//        insert();
        select();
    }
    
    //數據表查詢
    private static void select() {
        String sql = "SELECT * FROM Teacher where name = ?";
        try {
            String FirstArgs = "尹正傑";
            List<Map<String, Object>> list = qr.query(sql, new MapListHandler(), FirstArgs);
            //遍歷集合list
            for (Map<String, Object> map : list) {
                for(String key :map.keySet()){
                    System.out.println(key + ": " + map.get(key) );
                }
            }
        } catch (SQLException e) {
            System.out.println(e);
            throw new RuntimeException("數據查詢失敗！");
        }
    }
    
    //數據表添加數據
    private static void insert() {
        String sql = "INSERT INTO Teacher VALUES(null,?,?,?,?)";
        Object[] params = {"尹正傑",26,"高級雲計算工程師","負責網站架構維護，維護上萬台服務器正常運行！"};
        
        try {
            int row = qr.update(sql,params);
            if(row != 0) {
                System.out.println("添加成功");
            }
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException("數據添加失敗！");
        }
    }
}