前言：因為需要正式做專案，瞭解到了連線池這個東西。在網上找了很多資料，發現都是大同小異，各種轉載，看上去搜出來了幾十個答案，結果很可能是同一個。並且大多都是基於框架的資料庫連線池。可是我只是想採用MVC做一個不是很大的專案，不需要使用到框架啊。這可怎麼辦，最後沒辦法，弄清楚連線池的原理，配合網上的資料，自己寫一個簡單的吧（這裡暫時不考慮多執行緒操作，後面會繼續完善這個連線池，自己挖坑，後面慢慢補）

1、連線池是什麼以及連線池的好處

這裡想借用老師的例子，覺得非常的貼切。我是一個圖書管理員（CPU），當需要有人來借書的時候（進行資料庫操作），我首先需要去圖書館找到這本書（連線資料庫），然後登記把書給借書的人（執行並返回執行結果），人們來還書的時候，我們再把書放回圖書館（關閉資料庫）。這是我們普通的做法，這樣的做法有一個問題是這樣的，圖書管理員在找書的時候需要花費10分鐘（連線資料庫），登記把書給借書的人（執行SQL語句）只需要1分鐘。這就極大的降低了效能，因此就圖書管理員就想了一個辦法，我首先放一些書放在前臺書桌上（連線池），然後別人來借書的時候（進行資料庫操作的時候），我直接看書桌上還有沒有書，如果有的話，直接登記就可以了，花費的時間約為1分鐘，相對之前的借書流程提高了11倍。如果沒有的話，我們再去圖書館找這本書（連線資料庫）。在別人還書的時候，我們也不直接把書放回圖書館，而是放在書桌上（不關閉連線，放入連線池）。

2、簡單連線池的具體實現

建立一個連線池，基本原理就是，我們先建立一堆資料庫連線放在List中（初始化），在要進行連線的時候，我們判斷是否連線池中還有連線，如果有就直接從連線池中獲取，如果沒有，我們再重新建立連線。並且我們使用完成以後也不要關閉，而是重新放回List中。
IDatabaseConnection介面檔案

package DBPool;

import java.sql.Connection;
/**
 * @author xiaoD
 * @date 2017年11月22日 上午9:00:05
 * Description: 定義一個介面，更換資料庫的時候方便
 */
public
 
 interface IDatabaseConnection {
    //初始化
    public void init();
    //取得連線
    public  Connection getConnection();
    //關閉
    public void close(Connection conn);
}

SQLServerHandler處理器

package DBPool;

import java.sql.Connection;
import java.sql.DriverManager;


/**
 * @author xiaoD
 * @date 2017年11月22日 上午9:02:19
 * Description: 
 */
 

public class SQLServerHandler {
    private static final String DBDRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
    private static final String DBURL = "jdbc:sqlserver://localhost:1433;DatabaseName=xiaoD";
    private static final String USERNAME = "sa";
    private static final String PASSWORD = "sql2008";
    private Connection conn = null;

    public Connection buildConnection() {
        try {
            Class.forName(DBDRIVER);
            this.conn = DriverManager.getConnection(DBURL, USERNAME, PASSWORD);
        }catch(Exception e) {
            e.printStackTrace();
        }
        return conn;
    }
}

SQLServerPool

package DB;

import java.sql.Connection;
import java.util.LinkedList;


/**
 * @author xiaoD
 * @date 2017年11月22日 下午2:49:38
 * Description: 構建一個連線池
 */
public class SQLServerPool implements IDatabaseConnection{
    //最小連線數
        private static final int minCount = 1;
        //最大連線數
        private static final int maxCount = 10;
        //連線池
        private static final LinkedList<Connection> pools = new LinkedList<Connection>();
        SQLServerHandler handler = new SQLServerHandler();
        /**
         * @author xiaoD
         * @date 2017年11月22日 下午2:49:38
         * Description: 重寫init
         */
        public void init() {
            Connection conn = null;
            try{
                for(int i=0; i<minCount; i++) {
                    conn = handler.buildConnection();
                    pools.add(conn);
                }
            }catch(Exception e) {
                e.printStackTrace();
            }
        }

        /**
         * @author xiaoD
         * @date 2017年11月22日 下午2:49:38
         * Description: 重寫getConnection
         */
        public synchronized Connection getConnection() {
            Connection conn = null;
            if(pools.size() == 0) {
                conn = handler.buildConnection();
            } else {
                conn = pools.remove(0);
            }
            return conn;
        }

        /**
         * @author xiaoD
         * @date 2017年11月22日 下午2:49:38
         * Description: 重寫close
         */
        public synchronized void close(Connection conn) {
            if(pools.size() < maxCount) {
                pools.add(conn);
            }
            System.out.println(pools);
        }
}

測試類

package DB;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

/**
 * @author xiaoD
 * @date 2017年11月22日 下午2:52:00
 * Description: 
 */
public class DatabseTest {
    static IDatabaseConnection SQLServer = new SQLServerPool();
    public static void main(String args[]) {
        SQLServer.init();
        long start = System.currentTimeMillis();
        for(int i=0; i<300; i++) {
            test();
        }
        long end = System.currentTimeMillis();
        System.out.println(end-start);
    }
    private static void test() {
        try{
            Connection conn = SQLServer.getConnection();
            String sql = "select * from users";
            PreparedStatement pst = conn.prepareStatement(sql);
            ResultSet rs = pst.executeQuery();
            System.out.println(rs);
            pst.close();
            SQLServer.close(conn);
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
}

（完） 2017/11/222 20:30