一、資料庫連線池

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

登入後複製

其中這些配置只需要放在.properties裡面即可，關於每一個的意義

其中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();
    }
}

登入後複製

上述是線程池使用的時候所用到的代碼，只是給出了大概的寫法，具體的DBDAO部分需要根據自己的需求去自己實現，比如批處理，查詢，更新等函數，可以根據個人的需求去進行修改，那麼如何判斷你所創建的連結是你想要的呢？有兩種辦法可以檢驗

1、建立一個空的資料庫，查看連結個數

2、在linux下面查看連結個數

得到processid