初識數據庫連接池開源框架Druid

Druid是阿里巴巴的一個數據庫連接池開源框架，准確來說它不僅僅包括數據庫連接池這么簡單，它還提供強大的監控和擴展功能。本文僅僅是在不采用Spring框架對Druid的窺探，采用目前最新版本druid1.0.26 github地址：https://github.com/alibaba/druid。

在開始之前還是再說說為什么不配套使用Spring來使用Druid連接池，原因其實很簡單，在Spring框架的配置文件中僅僅一個配置datasource就可以使用Druid了。那到底配置這個datasource數據源時Spring到底對它做了什么呢？它到底是怎么來實現這個datasource數據源的呢？如果不知其二只知其一，那才真是只是個搬磚的。

下面我們正式開始吧，首先還是一覽工程包結構。

同樣有兩個jar需要引入，一是druid，二是mysql-connector。

我們首先實現util包里的DBPoolConnection類，這個類用來創建數據庫連接池單例以及返回一個數據庫連接。為什么數據庫連接池需要單例呢？原因其實很簡單，我們可以想象在一個web應用中，同時可能會存在多個請求如果為每一個請求都創建一個數據庫連接池，那還有什么意義呢？應該是不論有多少個並發請求，都應該只存在一個數據庫連接池，在這個數據庫連接池中為每個請求創建一個數據庫連接。

package util;

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.sql.SQLException;
import java.util.Properties;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import com.alibaba.druid.pool.DruidPooledConnection;

/**
 * 要實現單例模式，保證全局只有一個數據庫連接池
 * @author ylf
 *
 * 2016年10月21日
 */
public class DBPoolConnection {
    private static DBPoolConnection dbPoolConnection = null;
    private static DruidDataSource druidDataSource = null;
    
    static {
        Properties properties = loadPropertiesFile("db_server.properties");
        try {
            druidDataSource = (DruidDataSource)DruidDataSourceFactory.createDataSource(properties);    //DruidDataSrouce工廠模式
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    /**
     * 數據庫連接池單例
     * @return
     */
    public static synchronized DBPoolConnection getInstance(){
        if (null == dbPoolConnection){
            dbPoolConnection = new DBPoolConnection();
        }
        return dbPoolConnection;
    }

    /**
     * 返回druid數據庫連接
     * @return
     * @throws SQLException
     */
    public DruidPooledConnection getConnection() throws SQLException{
        return druidDataSource.getConnection();
    }
    /**
     * @param string 配置文件名
     * @return Properties對象
     */
    private static Properties loadPropertiesFile(String fullFile) {
        String webRootPath = null;
        if (null == fullFile || fullFile.equals("")){
            throw new IllegalArgumentException("Properties file path can not be null" + fullFile);
        }
        webRootPath = DBPoolConnection.class.getClassLoader().getResource("").getPath();
        webRootPath = new File(webRootPath).getParent();
        InputStream inputStream = null;
        Properties p =null;
        try {
            inputStream = new FileInputStream(new File(webRootPath + File.separator + fullFile));
            p = new Properties();
            p.load(inputStream);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (null != inputStream){
                    inputStream.close();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        return p;
    }
    
}

第26行代碼實例化一個DruidDataSource時，我們可以通過Druid框架為我們提供的DruidDataSourceFactory創建出一個DruidDataSource實例，工廠模式給我們提供了大大的便利。

第36行getInstance方法為我們創建出一個數據庫連接池實例，這里即用到了單例模式，在這個地方我們可以使用synchronized方法來對getInstance加鎖（懶加載）實現線程安全，同時我們也可以使用勤加載來實現線程安全即去掉synchronized關鍵字，刪掉37-39行代碼，將第20行代碼修改為private static DBPoolConnection dbPoolConnection = new DBPoolConnection()。這兩種方式各有其優缺點，懶加載好處就是“用到才實例化”，缺點就是“synchronized關鍵字對方法加鎖的粒度稍稍有點大，采用同步的方式實現線程安全會帶來額外的開銷”，而勤加載的好處就是“不使用同步的方式實現線程安全，省去了同步機制帶來的額外開銷”，缺點即是“未用到也會實例化”。至於怎么選擇，根據實際情況。這里是之前對單例模式的兩篇博文，《單例模式》、《再說單例模式的線程安全問題》。

第55行代碼loadPropertiesFile方法是對properties配置文件的加載。

我們在這個類所做的工作差不多就是在spring配置文件中的那一句<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">。很簡單的一句話，這就是為什么我不想使用Spring框架來配合使用Druid，因為這只會造成只知其一不知其二的結果。

我們接在來實現dao包中的DruidDao類，開始對數據進行持久化操作。由於我們沒有用到MyBatis等持久層框架，所以我們不得不使用JDBC來操作數據庫，雖然麻煩一點，但這是所有所有框架的基礎。

/**
 * 
 */
package dao;

import java.sql.PreparedStatement;
import java.sql.SQLException;

import com.alibaba.druid.pool.DruidPooledConnection;

import util.DBPoolConnection;

/**
 * @author ylf
 *
 * 2016年10月21日
 */
public class DruidDao {
    
    public void insert(String sql){
        DBPoolConnection dbp = DBPoolConnection.getInstance();    //獲取數據連接池單例
        DruidPooledConnection conn = null;
        PreparedStatement ps = null;
        try {
            conn = dbp.getConnection();    //從數據庫連接池中獲取數據庫連接
            ps = conn.prepareStatement(sql);
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (null != ps){
                    ps.close();
                }
                if (null != conn){
                    conn.close();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

我們只對數據做插入操作。下面我們測試一下，各個屬性的含義可參考：https://github.com/alibaba/druid/wiki/DruidDataSource%E9%85%8D%E7%BD%AE%E5%B1%9E%E6%80%A7%E5%88%97%E8%A1%A8

/**
 * 
 */
package test;

import dao.DruidDao;

/**
 * @author ylf
 *
 * 2016年10月21日
 */
public class Client {

    /**
     * @param args
     */
    public static void main(String[] args) {
        DruidDao druidDao = new DruidDao();
        String sql = "insert into test (name) values(\"keven\")";
        druidDao.insert(sql);
    }

}

查看數據庫插入成功。

另外db_server.properties數據庫的配置文件如下：

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/DruidTest
username=root
password=0000
filters=stat
initialSize=2
maxActive=300
maxWait=60000
timeBetweenEvictionRunsMillis=60000
minEvictableIdleTimeMillis=300000
validationQuery=SELECT 1
testWhileIdle=true
testOnBorrow=false
testOnReturn=false
poolPreparedStatements=false
maxPoolPreparedStatementPerConnectionSize=200