基于JDBC的數(shù)據(jù)庫(kù)連接池技術(shù)研究與應(yīng)用
1、連接池模型
本文討論的連接池包括一個(gè)連接池類(DBConnectionPool)和一個(gè)連接池管理類(DBConnetionPoolManager)。連接池類是對(duì)某一數(shù)據(jù)庫(kù)所有連接的“緩沖池”,主要實(shí)現(xiàn)以下功能:①?gòu)倪B接池獲取或創(chuàng)建可用連接;②使用完畢之后,把連接返還給連接池;③在系統(tǒng)關(guān)閉前,斷開(kāi)所有連接并釋放連接占用的系統(tǒng)資源;④還能夠處理無(wú)效連接(原來(lái)登記為可用的連接,由于某種原因不再可用,如超時(shí),通訊問(wèn)題),并能夠限制連接池中的連接總數(shù)不低于某個(gè)預(yù)定值和不超過(guò)某個(gè)預(yù)定值。
連接池管理類是連接池類的外覆類(wrapper),符合單例模式,即系統(tǒng)中只能有一個(gè)連接池管理類的實(shí)例。其主要用于對(duì)多個(gè)連接池對(duì)象的管理,具有以下功能:①裝載并注冊(cè)特定數(shù)據(jù)庫(kù)的JDBC驅(qū)動(dòng)程序;②根據(jù)屬性文件給定的信息,創(chuàng)建連接池對(duì)象;③為方便管理多個(gè)連接池對(duì)象,為每一個(gè)連接池對(duì)象取一個(gè)名字,實(shí)現(xiàn)連接池名字與其實(shí)例之間的映射;④跟蹤客戶使用連接情況,以便需要是關(guān)閉連接釋放資源。連接池管理類的引入主要是為了方便對(duì)多個(gè)連接池的使用和管理,如系統(tǒng)需要連接不同的數(shù)據(jù)庫(kù),或連接相同的數(shù)據(jù)庫(kù)但由于安全性問(wèn)題,需要不同的用戶使用不同的名稱和密碼。
2、連接池實(shí)現(xiàn)
下面給出連接池類和連接池管理類的主要屬性及所要實(shí)現(xiàn)的基本接口:
public class DBConnectionPool implements TimerListener{
private int checkedOut;//已被分配出去的連接數(shù)
private ArrayList freeConnections = new ArrayList();//容器,空閑池,根據(jù)//創(chuàng)建時(shí)間順序存放已創(chuàng)建但尚未分配出去的連接
private int minConn;//連接池里連接的最小數(shù)量
private int maxConn;//連接池里允許存在的最大連接數(shù)
private String name;//為這個(gè)連接池取個(gè)名字,方便管理
private String password;//連接數(shù)據(jù)庫(kù)時(shí)需要的密碼
private String url;//所要?jiǎng)?chuàng)建連接的數(shù)據(jù)庫(kù)的地址
private String user;//連接數(shù)據(jù)庫(kù)時(shí)需要的用戶名
public Timer timer;//定時(shí)器
public DBConnectionPool(String nAME, String URL, String user, String
password, int maxConn)//公開(kāi)的構(gòu)造函數(shù)
public synchronized void freeConnection(Connection con) //使用完畢之后,//把連接返還給空閑池
public synchronized Connection getConnection(long timeout)//得到一個(gè)連接,//timeout是等待時(shí)間
public synchronized void release()//斷開(kāi)所有連接,釋放占用的系統(tǒng)資源
private Connection newConnection()//新建一個(gè)數(shù)據(jù)庫(kù)連接
public synchronized void TimerEvent() //定時(shí)器事件處理函數(shù)
}
public class DBConnectionManager {
static private DBConnectionManager instance;//連接池管理類的唯一實(shí)例
static private int clients;//客戶數(shù)量
private ArrayList drivers = new ArrayList();//容器,存放數(shù)據(jù)庫(kù)驅(qū)動(dòng)程序
private HashMap pools = new HashMap ();//以name/value的形式存取連接池//對(duì)象的名字及連接池對(duì)象
static synchronized public DBConnectionManager getInstance()//如果唯一的//實(shí)例instance已經(jīng)創(chuàng)建,直接返回這個(gè)實(shí)例;否則,調(diào)用私有構(gòu)造函數(shù),創(chuàng)//建連接池管理類的唯一實(shí)例
private DBConnectionManager()//私有構(gòu)造函數(shù),在其中調(diào)用初始化函數(shù)init()
public void freeConnection(String name, Connection con)// 釋放一個(gè)連接,//name是一個(gè)連接池對(duì)象的名字
public Connection getConnection(String name)//從名字為name的連接池對(duì)象//中得到一個(gè)連接
public Connection getConnection(String name, long time)//從名字為name
//的連接池對(duì)象中取得一個(gè)連接,time是等待時(shí)間
public synchronized void release()//釋放所有資源
private void createPools(Properties props)//根據(jù)屬性文件提供的信息,創(chuàng)建//一個(gè)或多個(gè)連接池
private void init()//初始化連接池管理類的唯一實(shí)例,由私有構(gòu)造函數(shù)調(diào)用
private void loadDrivers(Properties props)//裝載數(shù)據(jù)庫(kù)驅(qū)動(dòng)程序
}
評(píng)論