java之編寫數據庫連接池實現連接的復用

    一般我們在操作數據庫時候，需要頻繁的打開和關閉連接，而創建數據庫連接往往開銷比較大，因而我們需要避免這種情況的發生，在這里我們可以創建一個連接池，當操作數據的時候，我們從連接池中取出連接，操作完畢后再將連接放回到池中。

    在這里我們需要用到集合，大家知道ArrayList結合其實是一個數組，它讀取數據的時候速度比較快，而LinkedList集合在操作的時候要比ArrayList要快的多，所以這里我們選擇集合LinkedList。

1.編寫一個連接池的類

package cn.mycast.bank.db;

import java.sql.Connection;
import java.util.LinkedList;
import cn.mycast.bank.util.JdbcUtil;
public class MyDatabasePool {
    private LinkedList<Connection> connPool=new LinkedList<Connection>();//存放連接
    public MyDatabasePool(){
        for(int i=0;i<10;i++)//連接池中存放10個連接
        {
            this.connPool.addLast(this.CreateConnection());//每次添加到集合最后面
        }
    }
    public Connection CreateConnection(){//獲得連接
        return JdbcUtil.getConnection();
    }
    public Connection GetConnection(){
        return connPool.removeFirst();//取出最上面的一個連接
    }
    public void FreeConnection(Connection conn){//將用完后的連接放回到集合中
        this.connPool.addLast(conn);
    }
}

2.編寫一個操作數據庫連接的工具類

package cn.mycast.bank.util;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import cn.mycast.bank.db.MyDatabasePool;
public class JdbcUtil {
    private static String driver;
    private static String url;
    private static String username;
    private static String password;
    private static MyDatabasePool connPool;//連接池類
    static{
        // 通過類加載器獲得資源，並以流的方式進行操作
        InputStream is=JdbcUtil.class.getClassLoader().getResourceAsStream("cn/mycast/bank/util/Mysqldb.properties");
        Properties properties=new Properties();
        try {
            properties.load(is);
            url=properties.getProperty("url");
            driver=properties.getProperty("driver");
            username=properties.getProperty("username");
            password=properties.getProperty("password");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    static{
        try {
            Class.forName(driver);//注冊驅動
            connPool=new MyDatabasePool();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    
    public static Connection getConnection(){
        Connection conn=null;
        try {
            conn=DriverManager.getConnection(url, username, password);//獲得連接
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            
        }
        return conn;
    }
    public static void close(Connection conn){
        if(conn!=null)
            connPool.FreeConnection(conn); //將連接放回集合
    }
    public static void close(Statement stm){
        try {
            if(stm!=null)
                stm.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    public static void close(ResultSet rs){
        try {
            if(rs!=null)
                rs.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

后面只需調用該工具類的相關方法即可

其實可以注意到，在獲取數據庫連接的時候，如果是多個線程並發的獲取的話，當連接池中沒有連接的時候，那么這候再獲取的時候就會報錯，而且該操作屬於非線程安全的，這里

需要加上同步代碼塊，避免多個線程獲取同一個連接。

public Connection CreateConnection(){//獲得連接
      synchronized(connectionsPool){
            if(this.connectionsPool.size()>0){
                   return JdbcUtil.getConnection();
            }
            if(this.currentCount<MaxCount){
                   this.currentCount++;
                   return this.CreateConnection();
            }
        }    
}