334 else {
335 con = DriverManager.getConnection(URL, user, password);
336 }
337 log("連接池" + name+"創(chuàng)建一個(gè)新的連接");
338 }
339 catch (SQLException e) {
340 log(e, "無法創(chuàng)建下列URL的連接: " + URL);
341 return null;
342 }
343 return con;
344 }
345 }
346 }
三、類DBConnectionPool說明
該類在209至345行實(shí)現(xiàn),它表示指向某個(gè)數(shù)據(jù)庫的連接池。數(shù)據(jù)庫由JDBC URL標(biāo)識(shí)。一個(gè)JDBC URL由三部分組成:協(xié)議標(biāo)識(shí)(總是jdbc),驅(qū)動(dòng)程序標(biāo)識(shí)(如 odbc、idb、oracle等),數(shù)據(jù)庫標(biāo)識(shí)(其格式依賴于驅(qū)動(dòng)程序)。例如,jdbc:odbc:demo,即是一個(gè)指向demo數(shù)據(jù)庫的JDBC URL,而且訪問該數(shù)據(jù)庫要使用JDBC-ODBC驅(qū)動(dòng)程序。每個(gè)連接池都有一個(gè)供客戶程序使用的名字以及可選的用戶帳號(hào)、密碼、最大連接數(shù)限制。如果Web應(yīng)用程序所支持的某些數(shù)據(jù)庫操作可以被所有用戶執(zhí)行,而其它一些操作應(yīng)由特別許可的用戶執(zhí)行,則可以為兩類操作分別定義連接池,兩個(gè)連接池使用相同的JDBC URL,但使用不同的帳號(hào)和密碼。
類DBConnectionPool的建構(gòu)函數(shù)需要上述所有數(shù)據(jù)作為其參數(shù)。如222至238行所示,這些數(shù)據(jù)被保存為它的實(shí)例變量:
如252至283行、285至305行所示, 客戶程序可以使用DBConnectionPool類提供的兩個(gè)方法獲取可用連接。兩者的共同之處在于:如連接池中存在可用連接,則直接返回,否則創(chuàng)建新的連接并返回。如果沒有可用連接且已有連接總數(shù)等于最大限制數(shù),第一個(gè)方法將直接返回null,而第二個(gè)方法將等待直到有可用連接為止。
所有的可用連接對(duì)象均登記在名為freeConnections的向量(Vector)中。如果向量中有多于一個(gè)的連接,getConnection()總是選取第一個(gè)。同時(shí),由于新的可用連接總是從尾部加入向量,從而使得數(shù)據(jù)庫連接由于長(zhǎng)時(shí)間閑置而被關(guān)閉的風(fēng)險(xiǎn)減低到最小程度。
第一個(gè)getConnection()在返回可用連接給客戶程序之前,調(diào)用了isClosed()方法驗(yàn)證連接仍舊有效。如果該連接被關(guān)閉或觸發(fā)異常,getConnection()遞歸地調(diào)用自己以嘗試獲取另外的可用連接。如果在向量freeConnections中不存在任何可用連接,getConnection()方法檢查是否已經(jīng)指定最大連接數(shù)限制。如已經(jīng)指定,則檢查當(dāng)前連接數(shù)是否已經(jīng)到達(dá)極限。此處maxConn為0表示沒有限制。如果沒有指定最大連接數(shù)限制或當(dāng)前連接數(shù)小于該值,該方法嘗試創(chuàng)建新的連接。如創(chuàng)建成功,則增加已使用連接的計(jì)數(shù)并返回,否則返回空值。
如325至345行所示,創(chuàng)建新連接由newConnection()方法實(shí)現(xiàn)。創(chuàng)建過程與是否已經(jīng)指定數(shù)據(jù)庫帳號(hào)、密碼有關(guān)。
JDBC的DriverManager類提供多個(gè)getConnection()方法,這些方法要用到JDBC URL與其它一些參數(shù),如用戶帳號(hào)和密碼等。DriverManager將使用指定的JDBC URL確定適合于目標(biāo)數(shù)據(jù)庫的驅(qū)動(dòng)程序及建立連接。
在285至305行實(shí)現(xiàn)的第二個(gè)getConnection()方法需要一個(gè)以毫秒為單位的時(shí)間參數(shù),該參數(shù)表示客戶程序能夠等待的最長(zhǎng)時(shí)間。建立連接的具體操作仍舊由第一個(gè)getConnection()方法實(shí)現(xiàn)。
該方法執(zhí)行時(shí)先將startTime初始化為當(dāng)前時(shí)間。在while循環(huán)中嘗試獲得一個(gè)連接。如果失敗,則以給定的時(shí)間值為參數(shù)調(diào)用wait()。wait()的返回可能是由于其它線程調(diào)用notify()或notifyAll(),也可能是由于預(yù)定時(shí)間已到。為找出wait()返回的真正原因,程序用當(dāng)前時(shí)間減開始時(shí)間(startTime),如差值大于預(yù)定時(shí)間則返回空值,否則再次調(diào)用getConnection()。
把空閑的連接登記到連接池由240至250行的freeConnection()方法實(shí)現(xiàn),它的參數(shù)為返回給連接池的連接對(duì)象。該對(duì)象被加入到freeConnections向量的末尾,然后減少已使用連接計(jì)數(shù)。調(diào)用notifyAll()是為了通知其它正在等待可用連接的線程。
許多Servlet引擎為實(shí)現(xiàn)安全關(guān)閉提供多種方法。數(shù)據(jù)庫連接池需要知道該事件以保證所有連接能夠正常關(guān)閉。DBConnectionManager類負(fù)協(xié)調(diào)整個(gè)關(guān)閉過程,但關(guān)閉連接池中所有連接的任務(wù)則由DBConnectionPool類負(fù)責(zé)。在307至323行實(shí)現(xiàn)的release()方法供DBConnectionManager調(diào)用。該方法遍歷freeConnections向量并關(guān)閉所有連接,然后從向量中刪除這些連接。
相關(guān)推薦:計(jì)算機(jī)等級(jí)考試二級(jí)Java經(jīng)典算法大全匯總
北京 | 天津 | 上海 | 江蘇 | 山東 |
安徽 | 浙江 | 江西 | 福建 | 深圳 |
廣東 | 河北 | 湖南 | 廣西 | 河南 |
海南 | 湖北 | 四川 | 重慶 | 云南 |
貴州 | 西藏 | 新疆 | 陜西 | 山西 |
寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
黑龍江 | 內(nèi)蒙古 |