一、資料庫連線池

開發的時候經常會需要對資料庫進行一些操作，比如說常見的增刪改查之類的，當資料量小的時候，可以直接進行操作，但是當資料量增多的時候，每一次連線以及釋放資料庫都會耗費一定的時間，這個時候，可以採用資料庫連線池來保持資料庫的連結，減少連線資料庫對程式帶來的開銷，並且可以減少資料庫的壓力，那麼資料庫連結池是一個什麼樣的東西呢？顧名思義，它是一個池子，池子裡放的是對資料庫的連結，打個比方魚塘，就是養魚的池子，想要吃魚可以直接去撈，不用自己去親自的買魚苗養魚等，資料庫連線池就是放的對於資料庫的連結，統一的把所有的連結都給建立好了，用的時候就可以直接的從裡面去取，用完了之後放回池子裡就可以，既然用這個東西，那麼我們也沒必要完全自己去寫程式碼實現，有些開源的可以直接用，常見的有三種開源的連線池，c3p0，dbcp，proxool這三種，對於c3p0、proxool這兩種沒用過，只是簡單的用過dbcp的池子，在此講下如何使用dbcp資料庫連線池，以及使用的時候遇到的一些坑

圖1、使用連線池之前

圖2 使用連線池之後

如上圖1所示，在使用連線池之前，需要每次都對資料庫建立連結，並且需要隨時進行釋放，在資料量大的情況下，需要很大的連線資料庫的開銷，並且頻繁的對資料庫進行訪問以及釋放，也會對資料庫造成很大的壓力，圖2為使用資料庫連線池之後，將所有的連結放在池子裡，不進行釋放，當用的時候直接從池子裡去取，用完之後放回池子裡，池子保持對資料庫的長連結，連結斷開會進行自動重連，如果連線不夠那麼對應後來的使用者就需要進行等待

二、使用tomcat-dbcp所使用的jar包

包含tomcat-dbcp.jar即可，剩下的都是一些基礎包

三、所使用的配置

dbname.Driver=com.mysql.jdbc.Driver
dbname.Url=jdbc:mysql://<your ip>/<your dbname>?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=false&maxReconnects=10&autoReconnectForPools=true&zeroDateTimeBehavior=convertToNull&connectTimeout=3000
dbname.Username=<your username>
dbname.Password=<your password>
dbname.InitialSize=15
dbname.MinIdle=10
dbname.MaxIdle=20
dbname.MaxWait=5000
dbname.MaxActive=20
dbname.validationQuery=select 1
 

其中driver，url，username，password為常見的資料庫連線的配置

InitialSize為初始化建立的連線數

minidle為資料庫連線池中保持的最少的空閒的連結數

maxidle資料庫連線池中保持的最大的連線數

maxwait等待資料庫連線池分配連線的最長時間，超出之後報錯

maxactivite最大的活動連結數，如果是多執行緒可以設定為超出多執行緒個數個連結數

<pre name="code" class="java">validationQuery測試是否連線是有效的sql語句
 

三、連線池程式碼

public abstract class DB {

    private static HashMap<String, DataSource> dsTable = new HashMap<String, DataSource>();//此處記得用static
    private BasicDataSource ds;
    private PreparedStatement stmt = null;

    private DataSource getDataSource(String n) {
        if (dsTable.containsKey(n)) {
            return dsTable.get(n);//如果不同的資料庫，多個連線池
        } else {
        	synchronized (dsTable) {
        		ds = new BasicDataSource();
                ds.setDriverClassName(DBConfig.getString("db", n.concat(".Driver")));//將<yourname>.properties的值讀進來
                ds.setUrl(DBConfig.getString("db", n.concat(".Url")));
                ds.setUsername(DBConfig.getString("db", n.concat(".Username")));
                ds.setPassword(DBConfig.getString("db", n.concat(".Password")));
                ds.setInitialSize(DBConfig.getInteger("db", n.concat(".InitialSize")));
                ds.setMinIdle(DBConfig.getInteger("db", n.concat(".MinIdle")));
                ds.setMaxIdle(DBConfig.getInteger("db", n.concat(".MaxIdle")));
                ds.setMaxWait(DBConfig.getInteger("db", n.concat(".MaxWait")));
                ds.setMaxActive(DBConfig.getInteger("db", n.concat(".MaxActive")));
                ds.setValidationQuery(DBConfig.getString("db", n.concat(".validationQuery")));
                dsTable.put(n, ds);

                return ds;
			}
        }
    }

    protected Connection conn;

    public boolean open() throws SQLException {
    	BasicDataSource bds=(BasicDataSource)this.getDataSource(this.getConnectionName());
    	System.out.println("connection_number:"+bds.getNumActive()+"dsTable:"+dsTable);
        this.conn = this.getDataSource(this.getConnectionName()).getConnection();
        return true;
    }

    public void close() throws SQLException {
    	
        if (this.conn != null)
            this.conn.close();
    }

    protected abstract String getConnectionName();//此函式可以根據自己的需求，將資料庫的名字傳進來即可

    public void prepareStatement(String sql) throws SQLException {
        this.stmt = this.conn.prepareStatement(sql);
    }

    public void setObject(int index, Object value, int type) throws SQLException {
        this.stmt.setObject(index, value, type);
    }

    public void setObject(int index, Object value) throws SQLException {
        this.stmt.setObject(index, value);
    }

    public int execute() throws SQLException {
        return this.stmt.executeUpdate();
    }
}

1、建立一個空的資料庫，檢視連結個數

2、在linux下面檢視連結個數

得到processid

ps aux|grep <your java name>

netstat -apn|grep <your processid>

四、遇到的一些坑

因為使用的時候是多執行緒形式使用的，遇到的最主要的一個坑就是static的用法，因為不是太熟，沒用static，導致了每個執行緒都建立了一個數據庫連線池，出現了一個“too many files open”的錯誤，這就是因為執行緒池那邊沒用static所導致的。