使用了數(shù)據(jù)庫連接池的機制：

（1）  程序初始化時創(chuàng)建連接池
（2） 使用時向連接池申請可用連接
（3） 使用完畢，將連接返還給連接池
（4） 程序退出時，斷開所有連接，并釋放資源

 

一. 為何要使用數(shù)據(jù)庫連接池
假設(shè)網(wǎng)站一天有很大的訪問量，數(shù)據(jù)庫服務器就需要為每次連接創(chuàng)建一次數(shù)據(jù)庫連接，極大的浪費數(shù)據(jù)庫的資源，并且極易造成數(shù)據(jù)庫服務器內(nèi)存溢出、拓機。
數(shù)據(jù)庫連接是一種關(guān)鍵的有限的昂貴的資源,這一點在多用戶的網(wǎng)頁應用程序中體現(xiàn)的尤為突出.對數(shù)據(jù)庫連接的管理能顯著影響到整個應用程序的伸縮性和健壯性,影響到程序的性能指標.數(shù)據(jù)庫連接池正式針對這個問題提出來的.數(shù)據(jù)庫連接池負責分配,管理和釋放數(shù)據(jù)庫連接,它允許應用程序重復使用一個現(xiàn)有的數(shù)據(jù)庫連接,而不是重新建立一個。

數(shù)據(jù)庫連接池在初始化時將創(chuàng)建一定數(shù)量的數(shù)據(jù)庫連接放到連接池中, 這些數(shù)據(jù)庫連接的數(shù)量是由最小數(shù)據(jù)庫連接數(shù)來設(shè)定的.無論這些數(shù)據(jù)庫連接是否被使用,連接池都將一直保證至少擁有這么多的連接數(shù)量.連接池的最大數(shù)據(jù)庫連接數(shù)量限定了這個連接池能占有的最大連接數(shù),當應用程序向連接池請求的連接數(shù)超過最大連接數(shù)量時,這些請求將被加入到等待隊列中.

      數(shù)據(jù)庫連接池的最小連接數(shù)和最大連接數(shù)的設(shè)置要考慮到以下幾個因素:

　　1, 最小連接數(shù):是連接池一直保持的數(shù)據(jù)庫連接,所以如果應用程序?qū)?shù)據(jù)庫連接的使用量不大,將會有大量的數(shù)據(jù)庫連接資源被浪費.
　　2, 最大連接數(shù):是連接池能申請的最大連接數(shù),如果數(shù)據(jù)庫連接請求超過次數(shù),后面的數(shù)據(jù)庫連接請求將被加入到等待隊列中,這會影響以后的數(shù)據(jù)庫操作
　　3, 如果最小連接數(shù)與最大連接數(shù)相差很大:那么最先連接請求將會獲利,之后超過最小連接數(shù)量的連接請求等價于建立一個新的數(shù)據(jù)庫連接.不過,這些大于最小連接數(shù)的數(shù)據(jù)庫連接在使用完不會馬上被釋放,他將被           放到連接池中等待重復使用或是空間超時后被釋放.

二、使用數(shù)據(jù)庫連接池的關(guān)鍵點

1、并發(fā)問題

　　為了使連接管理服務具有最大的通用性，必須考慮多線程環(huán)境，即并發(fā)問題。這個問題相對比較好解決，因為各個語言自身提供了對并發(fā)管理的支持像java,c#等等，使用synchronized(java)lock(C#)關(guān)鍵字即可確保線程是同步的。使用方法可以參考，相關(guān)文獻。

２、事務處理

DB連接池必須要確保某一時間內(nèi)一個 conn 只能分配給一個線程。不同 conn 的事務是相互獨立的。 

　　我們知道，事務具有原子性，此時要求對數(shù)據(jù)庫的操作符合“ALL-ALL-NOTHING”原則,即對于一組SQL語句要么全做，要么全不做。 
　　我們知道當２個線程共用一個連接Connection對象，而且各自都有自己的事務要處理時候，對于連接池是一個很頭疼的問題，因為即使Connection類提供了相應的事務支持，可是我們?nèi)匀徊荒艽_定那個數(shù)據(jù)庫操作是對應那個事務的，這是由于我們有２個線程都在進行事務操作而引起的。為此我們可以使用每一個事務獨占一個連接來實現(xiàn)，雖然這種方法有點浪費連接池資源但是可以大大降低事務管理的復雜性。 

３、連接池的分配與釋放

　　連接池的分配與釋放，對系統(tǒng)的性能有很大的影響。合理的分配與釋放，可以提高連接的復用度，從而降低建立新連接的開銷，同時還可以加快用戶的訪問速度。 
　　對于連接的管理可使用一個List。即把已經(jīng)創(chuàng)建的連接都放入List中去統(tǒng)一管理。每當用戶請求一個連接時，系統(tǒng)檢查這個List中有沒有可以分配的連接。如果有就把那個最合適的連接分配給他（如何能找到最合適的連接文章將在關(guān)鍵議題中指出）；如果沒有就拋出一個異常給用戶，List中連接是否可以被分配由一個線程來專門管理捎后我會介紹這個線程的具體實現(xiàn)。

４、連接池的配置與維護

　　連接池中到底應該放置多少連接，才能使系統(tǒng)的性能最佳？系統(tǒng)可采取設(shè)置最小連接數(shù)（minConnection）和最大連接數(shù)（maxConnection）等參數(shù)來控制連接池中的連接。比方說，最小連接數(shù)是系統(tǒng)啟動時連接池所創(chuàng)建的連接數(shù)。如果創(chuàng)建過多，則系統(tǒng)啟動就慢，但創(chuàng)建后系統(tǒng)的響應速度會很快；如果創(chuàng)建過少，則系統(tǒng)啟動的很快，響應起來卻慢。這樣，可以在開發(fā)時，設(shè)置較小的最小連接數(shù)，開發(fā)起來會快，而在系統(tǒng)實際使用時設(shè)置較大的，因為這樣對訪問客戶來說速度會快些。最大連接數(shù)是連接池中允許連接的最大數(shù)目，具體設(shè)置多少，要看系統(tǒng)的訪問量，可通過軟件需求上得到。 
　　如何確保連接池中的最小連接數(shù)呢？有動態(tài)和靜態(tài)兩種策略。動態(tài)即每隔一定時間就對連接池進行檢測，如果發(fā)現(xiàn)連接數(shù)量小于最小連接數(shù)，則補充相應數(shù)量的新連接,以保證連接池的正常運轉(zhuǎn)。靜態(tài)是發(fā)現(xiàn)空閑連接不夠時再去檢查。

三、使用數(shù)據(jù)庫連接池的優(yōu)勢和其工作原理

1、連接池的優(yōu)勢

連接池用于創(chuàng)建和管理數(shù)據(jù)庫連接的緩沖池技術(shù)，緩沖池中的連接可以被任何需要他們的線程使用。當一個線程需要用JDBC對一個數(shù)據(jù)庫操作時，將從池中請求一個連接。當這個連接使用完畢后，將返回到連接池中，等待為其他的線程服務。

連接池的主要優(yōu)點有以下三個方面。

第一、減少連接創(chuàng)建時間。連接池中的連接是已準備好的、可重復使用的，獲取后可以直接訪問數(shù)據(jù)庫，因此減少了連接創(chuàng)建的次數(shù)和時間。

第二、簡化的編程模式。當使用連接池時，每一個單獨的線程能夠像創(chuàng)建一個自己的JDBC連接一樣操作，允許用戶直接使用JDBC編程技術(shù)。

第三、控制資源的使用。如果不使用連接池，每次訪問數(shù)據(jù)庫都需要創(chuàng)建一個連接，這樣系統(tǒng)的穩(wěn)定性受系統(tǒng)連接需求影響很大，很容易產(chǎn)生資源浪費和高負載異常。連接池能夠使性能最大化，將資源利用控制在一定的水平之下。連接池能控制池中的連接數(shù)量，增強了系統(tǒng)在大量用戶應用時的穩(wěn)定性。

2、連接池的工作原理

下面，簡單的闡述下連接池的工作原理。

連接池技術(shù)的核心思想是連接復用，通過建立一個數(shù)據(jù)庫連接池以及一套連接使用、分配和管理策略，使得該連接池中的連接可以得到高效、安全的復用，避免了數(shù)據(jù)庫連接頻繁建立、關(guān)閉的開銷。

連接池的工作原理主要由三部分組成，分別為連接池的建立、連接池中連接的使用管理、連接池的關(guān)閉。

第一、連接池的建立。一般在系統(tǒng)初始化時，連接池會根據(jù)系統(tǒng)配置建立，并在池中創(chuàng)建了幾個連接對象，以便使用時能從連接池中獲取。連接池中的連接不能隨意創(chuàng)建和關(guān)閉，這樣避免了連接隨意建立和關(guān)閉造成的系統(tǒng)開銷。Java中提供了很多容器類可以方便的構(gòu)建連接池，例如Vector、Stack等。

第二、連接池的管理。連接池管理策略是連接池機制的核心，連接池內(nèi)連接的分配和釋放對系統(tǒng)的性能有很大的影響。其管理策略是：

• 當客戶請求數(shù)據(jù)庫連接時，首先查看連接池中是否有空閑連接，如果存在空閑連接，則將連接分配給客戶使用；如果沒有空閑連接，則查看當前所開的連接數(shù)是否已經(jīng)達到最大連接數(shù)，如果沒達到就重新創(chuàng)建一個連接給請求的客戶；如果達到就按設(shè)定的最大等待時間進行等待，如果超出最大等待時間，則拋出異常給客戶。

• 當客戶釋放數(shù)據(jù)庫連接時，先判斷該連接的引用次數(shù)是否超過了規(guī)定值，如果超過就從連接池中刪除該連接，否則保留為其他客戶服務。

  該策略保證了數(shù)據(jù)庫連接的有效復用，避免頻繁的建立、釋放連接所帶來的系統(tǒng)資源開銷。

第三、連接池的關(guān)閉。當應用程序退出時，關(guān)閉連接池中所有的連接，釋放連接池相關(guān)的資源，該過程正好與創(chuàng)建相反。

 3、常用的連接池：

     (1) dbcp
dbcp可能是使用最多的開源連接池，原因大概是因為配置方便，而且很多開源和tomcat應用例子都是使用的這個連接池吧。
這個連接池可以設(shè)置最大和最小連接，連接等待時間等，基本功能都有。這個連接池的配置參見附件壓縮包中的:dbcp.xml
使用評價：在具體項目應用中，發(fā)現(xiàn)此連接池的持續(xù)運行的穩(wěn)定性還是可以，不過速度稍慢，在大并發(fā)量的壓力下穩(wěn)定性
有所下降，此外不提供連接池監(jiān)控

常用的參數(shù)(阿里面試問常用的參數(shù))：  

我們來看DBCP 的例子, 然后根據(jù)例子來分析:

#連接設(shè)置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/day14
username=root
password=abc

#<!-- 初始化連接 -->
initialSize=10

#最大連接數(shù)量
maxActive=50

#<!-- 最大空閑連接 -->
maxIdle=20

#<!-- 最小空閑連接 -->
minIdle=5

#<!-- 超時等待時間以毫秒為單位 60000毫秒/1000等于60秒 -->
maxWait=60000

#JDBC驅(qū)動建立連接時附帶的連接屬性屬性的格式必須為這樣：[屬性名=property;]
#注意：“user” 與 “password” 兩個屬性會被明確地傳遞，因此這里不需要包含他們。
connectionProperties=useUnicode=true;characterEncoding=utf8

#指定由連接池所創(chuàng)建的連接的自動提交（auto-commit）狀態(tài)。
defaultAutoCommit=true

#driver default 指定由連接池所創(chuàng)建的連接的只讀（read-only）狀態(tài)。
#如果沒有設(shè)置該值，則“setReadOnly”方法將不被調(diào)用。（某些驅(qū)動并不支持只讀模式，如：Informix）
defaultReadOnly=

#driver default 指定由連接池所創(chuàng)建的連接的事務級別（TransactionIsolation）。
#可用值為下列之一：（詳情可見javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=REPEATABLE_READ

DBCP配置文件

配置參數(shù)詳解：

MaxActive，連接池的最大數(shù)據(jù)庫連接數(shù)。設(shè)為0表示無限制。maxActive是最大激活連接數(shù)，這里取值為20，表示同時最多有20個數(shù)據(jù)庫連　
maxIdle 連接池中最多可空閑maxIdle個連接,maxIdle是最大的空閑連接數(shù)，這里取值為20，表示即使沒有數(shù)據(jù)庫連接時依然可以保持20空閑的連接，而不被清除，隨時處于待命狀態(tài)
minIdle 連接池中最少空閑maxIdle個連接 
initialSize 初始化連接數(shù)目 
maxWait 連接池中連接用完時,新的請求等待時間,毫秒 MaxWait是最大等待秒鐘數(shù)，這里取值-1，表示無限等待，直到超時為止，也可取值9000，表示9秒后超時。
maxIdle，最大空閑數(shù)，數(shù)據(jù)庫連接的最大空閑時間。超過空閑時間，數(shù)據(jù)庫連
接將被標記為不可用，然后被釋放。設(shè)為0表示無限制。

   (2) c3p0
c3p0是另外一個開源的連接池，在業(yè)界也是比較有名的，這個連接池可以設(shè)置最大和最小連接，連接等待時間等，基本功能都有。
這個連接池的配置參見附件壓縮包中的:c3p0.xml。
使用評價：在具體項目應用中，發(fā)現(xiàn)此連接池的持續(xù)運行的穩(wěn)定性相當不錯，在大并發(fā)量的壓力下穩(wěn)定性也有一定保證，
          此外不提供連接池監(jiān)控。          

   1.Apache commons-dbcp 連接池

        下載：http://commons.apache.org/proper/commons-dbcp/ 

       2.c3p0 數(shù)據(jù)庫連接池

        下載：http://sourceforge.net/projects/c3p0/

程序開發(fā)過程中，存在很多問題：

首先，每一次web請求都要建立一次數(shù)據(jù)庫連接。建立連接是一個費時的活動，每次都得花費0.05s～1s的時間，而且系統(tǒng)還要分配內(nèi)存資源。這個時間對于一次或幾次數(shù)據(jù)庫操作，或許感覺不出系統(tǒng)有多大的開銷。

可是對于現(xiàn)在的web應用，尤其是大型電子商務網(wǎng)站，同時有幾百人甚至幾千人在線是很正常的事。在這種情況下，頻繁的進行數(shù)據(jù)庫連接操作勢必占用很多的系統(tǒng)資源，網(wǎng)站的響應速度必定下降，嚴重的甚至會造成服務器的崩潰。不是危言聳聽，這就是制約某些電子商務網(wǎng)站發(fā)展的技術(shù)瓶頸問題。其次，對于每一次數(shù)據(jù)庫連接，使用完后都得斷開。否則，如果程序出現(xiàn)異常而未能關(guān)閉，將會導致數(shù)據(jù)庫系統(tǒng)中的內(nèi)存泄漏，最終將不得不重啟數(shù)據(jù)庫

     通過上面的分析，我們可以看出來，“數(shù)據(jù)庫連接”是一種稀缺的資源，為了保障網(wǎng)站的正常使用，應該對其進行妥善管理。其實我們查詢完數(shù)據(jù)庫后，如果不關(guān)閉連接，而是暫時存放起來，當別人使用時，把這個連接給他們使用。就避免了一次建立數(shù)據(jù)庫連接和斷開的操作時間消耗。

數(shù)據(jù)庫連接池的基本思想：就是為數(shù)據(jù)庫連接建立一個“緩沖池”。預先在緩沖池中放入一定數(shù)量的連接，當需要建立數(shù)據(jù)庫連接時，只需從“緩沖池”中取出一個，使用完畢之后再放回去。我們可以通過設(shè)定連接池最大連接數(shù)來防止系統(tǒng)無盡的與數(shù)據(jù)庫連接

創(chuàng)建數(shù)據(jù)庫連接池大概有3個步驟：

① 創(chuàng)建ConnectionPool實例，并初始化創(chuàng)建10個連接，保存在Vector中（線程安全）單例模式實現(xiàn)
② 實現(xiàn)getConnection()從連接庫中獲取一個可用的連接
③ returnConnection(conn) 提供將連接放回連接池中方法

　　連接池的實現(xiàn)

　　1、連接池模型

　　本文討論的連接池包括一個連接池類（DBConnectionPool）和一個連接池管理類（DBConnetionPoolManager）。連接池類是對某一數(shù)據(jù)庫所有連接的“緩沖池”，主要實現(xiàn)以下功能：①從連接池獲取或創(chuàng)建可用連接；②使用完畢之后，把連接返還給連接池；③在系統(tǒng)關(guān)閉前，斷開所有連接并釋放連接占用的系統(tǒng)資源；④還能夠處理無效連接（原來登記為可用的連接，由于某種原因不再可用，如超時，通訊問題），并能夠限制連接池中的連接總數(shù)不低于某個預定值和不超過某個預定值。

　　連接池管理類是連接池類的外覆類（wrapper）,符合單例模式，即系統(tǒng)中只能有一個連接池管理類的實例。其主要用于對多個連接池對象的管理，具有以下功能：①裝載并注冊特定數(shù)據(jù)庫的JDBC驅(qū)動程序；②根據(jù)屬性文件給定的信息，創(chuàng)建連接池對象；③為方便管理多個連接池對象，為每一個連接池對象取一個名字，實現(xiàn)連接池名字與其實例之間的映射；④跟蹤客戶使用連接情況，以便需要是關(guān)閉連接釋放資源。連接池管理類的引入主要是為了方便對多個連接池的使用和管理，如系統(tǒng)需要連接不同的數(shù)據(jù)庫，或連接相同的數(shù)據(jù)庫但由于安全性問題，需要不同的用戶使用不同的名稱和密碼。

連接池源碼：

ConnectionPool.Java 

[java] view plain copy print?
 數(shù)據(jù)庫連接池類 ConnectionPool.java   

/
這個例子是根據(jù)POSTGRESQL數(shù)據(jù)庫寫的，
請用的時候根據(jù)實際的數(shù)據(jù)庫調(diào)整。
調(diào)用方法如下：
①　ConnectionPool connPool
= new ConnectionPool(“com.microsoft.jdbc.sqlserver.SQLServerDriver”
,“jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=MyDataForTest”
,“Username”
,“Password”);
②　connPool .createPool();
Connection conn = connPool .getConnection();
connPool.returnConnection(conn);
connPool.refreshConnections();
connPool.closeConnectionPool();
/
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Enumeration;
import java.util.Vector;

public class ConnectionPool {
private String jdbcDriver = “”; // 數(shù)據(jù)庫驅(qū)動
private String dbUrl = “”; // 數(shù)據(jù) URL
private String dbUsername = “”; // 數(shù)據(jù)庫用戶名
private String dbPassword = “”; // 數(shù)據(jù)庫用戶密碼
private String testTable = “”; // 測試連接是否可用的測試表名，默認沒有測試表

<span style="color: #0000ff;">private</span> <span style="color: #0000ff;">int</span> initialConnections = 10; <span style="color: #008000;">//</span><span style="color: #008000;"> 連接池的初始大小  </span>
<span style="color: #0000ff;">private</span> <span style="color: #0000ff;">int</span> incrementalConnections = 5;<span style="color: #008000;">//</span><span style="color: #008000;"> 連接池自動增加的大小  </span>
<span style="color: #0000ff;">private</span> <span style="color: #0000ff;">int</span> maxConnections = 50; <span style="color: #008000;">//</span><span style="color: #008000;"> 連接池最大的大小  </span>
<span style="color: #0000ff;">private</span> Vector connections = <span style="color: #0000ff;">null</span>; <span style="color: #008000;">//</span><span style="color: #008000;"> 存放連接池中數(shù)據(jù)庫連接的向量 , 初始時為 null  
</span><span style="color: #008000;">//</span><span style="color: #008000;"> 它中存放的對象為 PooledConnection 型  </span>

<span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 構(gòu)造函數(shù) 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> jdbcDriver 
 *            String JDBC 驅(qū)動類串 
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> dbUrl 
 *            String 數(shù)據(jù)庫 URL 
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> dbUsername 
 *            String 連接數(shù)據(jù)庫用戶名 
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> dbPassword 
 *            String 連接數(shù)據(jù)庫用戶的密碼 
 *  
 </span><span style="color: #008000;">*/</span>  
<span style="color: #0000ff;">public</span><span style="color: #000000;"> ConnectionPool(String jdbcDriver, String dbUrl, String dbUsername,  
        String dbPassword) {  
    </span><span style="color: #0000ff;">this</span>.jdbcDriver =<span style="color: #000000;"> jdbcDriver;  
    </span><span style="color: #0000ff;">this</span>.dbUrl =<span style="color: #000000;"> dbUrl;  
    </span><span style="color: #0000ff;">this</span>.dbUsername =<span style="color: #000000;"> dbUsername;  
    </span><span style="color: #0000ff;">this</span>.dbPassword =<span style="color: #000000;"> dbPassword;  
}  

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 返回連接池的初始大小 
 *  
 * </span><span style="color: #808080;">@return</span><span style="color: #008000;"> 初始連接池中可獲得的連接數(shù)量 
 </span><span style="color: #008000;">*/</span>  
<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">int</span><span style="color: #000000;"> getInitialConnections() {  
    </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">this</span><span style="color: #000000;">.initialConnections;  
}  
</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 設(shè)置連接池的初始大小 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> 用于設(shè)置初始連接池中連接的數(shù)量 
 </span><span style="color: #008000;">*/</span>  
<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span> setInitialConnections(<span style="color: #0000ff;">int</span><span style="color: #000000;"> initialConnections) {  
    </span><span style="color: #0000ff;">this</span>.initialConnections =<span style="color: #000000;"> initialConnections;  
}  
</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 返回連接池自動增加的大小 、 
 *  
 * </span><span style="color: #808080;">@return</span><span style="color: #008000;"> 連接池自動增加的大小 
 </span><span style="color: #008000;">*/</span>  
<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">int</span><span style="color: #000000;"> getIncrementalConnections() {  
    </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">this</span><span style="color: #000000;">.incrementalConnections;  
}  
</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 設(shè)置連接池自動增加的大小 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> 連接池自動增加的大小 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span> setIncrementalConnections(<span style="color: #0000ff;">int</span><span style="color: #000000;"> incrementalConnections) {  
    </span><span style="color: #0000ff;">this</span>.incrementalConnections =<span style="color: #000000;"> incrementalConnections;  
}  
</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 返回連接池中最大的可用連接數(shù)量 
 *  
 * </span><span style="color: #808080;">@return</span><span style="color: #008000;"> 連接池中最大的可用連接數(shù)量 
 </span><span style="color: #008000;">*/</span>  
<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">int</span><span style="color: #000000;"> getMaxConnections() {  
    </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">this</span><span style="color: #000000;">.maxConnections;  
}  
</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 設(shè)置連接池中最大可用的連接數(shù)量 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> 設(shè)置連接池中最大可用的連接數(shù)量值 
 </span><span style="color: #008000;">*/</span>  
<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span> setMaxConnections(<span style="color: #0000ff;">int</span><span style="color: #000000;"> maxConnections) {  
    </span><span style="color: #0000ff;">this</span>.maxConnections =<span style="color: #000000;"> maxConnections;  
}  

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 獲取測試數(shù)據(jù)庫表的名字 
 *  
 * </span><span style="color: #808080;">@return</span><span style="color: #008000;"> 測試數(shù)據(jù)庫表的名字 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">public</span><span style="color: #000000;"> String getTestTable() {  
    </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">this</span><span style="color: #000000;">.testTable;  
}  

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 設(shè)置測試表的名字 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> testTable 
 *            String 測試表的名字 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span><span style="color: #000000;"> setTestTable(String testTable) {  
    </span><span style="color: #0000ff;">this</span>.testTable =<span style="color: #000000;"> testTable;  
}  

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 *  
 * 創(chuàng)建一個數(shù)據(jù)庫連接池，連接池中的可用連接的數(shù)量采用類成員 initialConnections 中設(shè)置的值 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">synchronized</span> <span style="color: #0000ff;">void</span> createPool() <span style="color: #0000ff;">throws</span><span style="color: #000000;"> Exception {  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 確保連接池沒有創(chuàng)建  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果連接池己經(jīng)創(chuàng)建了，保存連接的向量 connections 不會為空  </span>
    <span style="color: #0000ff;">if</span> (connections != <span style="color: #0000ff;">null</span><span style="color: #000000;">) {  
        </span><span style="color: #0000ff;">return</span>; <span style="color: #008000;">//</span><span style="color: #008000;"> 如果己經(jīng)創(chuàng)建，則返回  </span>

}
// 實例化 JDBC Driver 中指定的驅(qū)動類實例
Driver driver = (Driver) (Class.forName(this.jdbcDriver).newInstance());
DriverManager.registerDriver(driver); // 注冊 JDBC 驅(qū)動程序
// 創(chuàng)建保存連接的向量 , 初始時有 0 個元素
connections = new Vector();
// 根據(jù) initialConnections 中設(shè)置的值，創(chuàng)建連接。
createConnections(this.initialConnections);
// System.out.println(" 數(shù)據(jù)庫連接池創(chuàng)建成功！ ");
}

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 創(chuàng)建由 numConnections 指定數(shù)目的數(shù)據(jù)庫連接 , 并把這些連接 放入 connections 向量中 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> numConnections 
 *            要創(chuàng)建的數(shù)據(jù)庫連接的數(shù)目 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">private</span> <span style="color: #0000ff;">void</span> createConnections(<span style="color: #0000ff;">int</span> numConnections) <span style="color: #0000ff;">throws</span><span style="color: #000000;"> SQLException {  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 循環(huán)創(chuàng)建指定數(shù)目的數(shù)據(jù)庫連接  </span>
    <span style="color: #0000ff;">for</span> (<span style="color: #0000ff;">int</span> x = 0; x &lt; numConnections; x++<span style="color: #000000;">) {  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 是否連接池中的數(shù)據(jù)庫連接的數(shù)量己經(jīng)達到最大？最大值由類成員 maxConnections  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 指出，如果 maxConnections 為 0 或負數(shù)，表示連接數(shù)量沒有限制。  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果連接數(shù)己經(jīng)達到最大，即退出。  </span>
        <span style="color: #0000ff;">if</span> (<span style="color: #0000ff;">this</span>.maxConnections &gt; 0  
                &amp;&amp; <span style="color: #0000ff;">this</span>.connections.size() &gt;= <span style="color: #0000ff;">this</span><span style="color: #000000;">.maxConnections) {  
            </span><span style="color: #0000ff;">break</span><span style="color: #000000;">;  
        }  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> add a new PooledConnection object to connections vector  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 增加一個連接到連接池中（向量 connections 中）  </span>
        <span style="color: #0000ff;">try</span><span style="color: #000000;"> {  
            connections.addElement(</span><span style="color: #0000ff;">new</span><span style="color: #000000;"> PooledConnection(newConnection()));  
        } </span><span style="color: #0000ff;">catch</span><span style="color: #000000;"> (SQLException e) {  
            System.out.println(</span>" 創(chuàng)建數(shù)據(jù)庫連接失敗！ " +<span style="color: #000000;"> e.getMessage());  
            </span><span style="color: #0000ff;">throw</span> <span style="color: #0000ff;">new</span><span style="color: #000000;"> SQLException();  
        }  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> System.out.println(" 數(shù)據(jù)庫連接己創(chuàng)建 ......");  </span>

}
}
/**
* 創(chuàng)建一個新的數(shù)據(jù)庫連接并返回它
*
* @return 返回一個新創(chuàng)建的數(shù)據(jù)庫連接
*/
private Connection newConnection() throws SQLException {
// 創(chuàng)建一個數(shù)據(jù)庫連接
Connection conn = DriverManager.getConnection(dbUrl, dbUsername,
dbPassword);
// 如果這是第一次創(chuàng)建數(shù)據(jù)庫連接，即檢查數(shù)據(jù)庫，獲得此數(shù)據(jù)庫允許支持的
// 最大客戶連接數(shù)目
// connections.size()==0 表示目前沒有連接己被創(chuàng)建
if (connections.size() == 0) {
DatabaseMetaData metaData = conn.getMetaData();
int driverMaxConnections = metaData.getMaxConnections();
// 數(shù)據(jù)庫返回的 driverMaxConnections 若為 0 ，表示此數(shù)據(jù)庫沒有最大
// 連接限制，或數(shù)據(jù)庫的最大連接限制不知道
// driverMaxConnections 為返回的一個整數(shù)，表示此數(shù)據(jù)庫允許客戶連接的數(shù)目
// 如果連接池中設(shè)置的最大連接數(shù)量大于數(shù)據(jù)庫允許的連接數(shù)目 , 則置連接池的最大
// 連接數(shù)目為數(shù)據(jù)庫允許的最大數(shù)目
if (driverMaxConnections > 0
&& this.maxConnections > driverMaxConnections) {
this.maxConnections = driverMaxConnections;
}
}
return conn; // 返回創(chuàng)建的新的數(shù)據(jù)庫連接
}

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 通過調(diào)用 getFreeConnection() 函數(shù)返回一個可用的數(shù)據(jù)庫連接 , 如果當前沒有可用的數(shù)據(jù)庫連接，并且更多的數(shù)據(jù)庫連接不能創(chuàng) 
 * 建（如連接池大小的限制），此函數(shù)等待一會再嘗試獲取。 
 *  
 * </span><span style="color: #808080;">@return</span><span style="color: #008000;"> 返回一個可用的數(shù)據(jù)庫連接對象 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">synchronized</span> Connection getConnection() <span style="color: #0000ff;">throws</span><span style="color: #000000;"> SQLException {  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 確保連接池己被創(chuàng)建  </span>
    <span style="color: #0000ff;">if</span> (connections == <span style="color: #0000ff;">null</span><span style="color: #000000;">) {  
        </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">null</span>; <span style="color: #008000;">//</span><span style="color: #008000;"> 連接池還沒創(chuàng)建，則返回 null  </span>

}
Connection conn = getFreeConnection(); // 獲得一個可用的數(shù)據(jù)庫連接
// 如果目前沒有可以使用的連接，即所有的連接都在使用中
while (conn == null) {
// 等一會再試
// System.out.println(“Wait”);
wait(250);
conn = getFreeConnection(); // 重新再試，直到獲得可用的連接，如果
// getFreeConnection() 返回的為 null
// 則表明創(chuàng)建一批連接后也不可獲得可用連接
}
return conn;// 返回獲得的可用的連接
}

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 本函數(shù)從連接池向量 connections 中返回一個可用的的數(shù)據(jù)庫連接，如果 當前沒有可用的數(shù)據(jù)庫連接，本函數(shù)則根據(jù) 
 * incrementalConnections 設(shè)置 的值創(chuàng)建幾個數(shù)據(jù)庫連接，并放入連接池中。 如果創(chuàng)建后，所有的連接仍都在使用中，則返回 null 
 *  
 * </span><span style="color: #808080;">@return</span><span style="color: #008000;"> 返回一個可用的數(shù)據(jù)庫連接 
 </span><span style="color: #008000;">*/</span>  
<span style="color: #0000ff;">private</span> Connection getFreeConnection() <span style="color: #0000ff;">throws</span><span style="color: #000000;"> SQLException {  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 從連接池中獲得一個可用的數(shù)據(jù)庫連接  </span>
    Connection conn =<span style="color: #000000;"> findFreeConnection();  
    </span><span style="color: #0000ff;">if</span> (conn == <span style="color: #0000ff;">null</span><span style="color: #000000;">) {  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果目前連接池中沒有可用的連接  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 創(chuàng)建一些連接  </span>

createConnections(incrementalConnections);
// 重新從池中查找是否有可用連接
conn = findFreeConnection();
if (conn == null) {
// 如果創(chuàng)建連接后仍獲得不到可用的連接，則返回 null
return null;
}
}
return conn;
}

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 查找連接池中所有的連接，查找一個可用的數(shù)據(jù)庫連接， 如果沒有可用的連接，返回 null 
 *  
 * </span><span style="color: #808080;">@return</span><span style="color: #008000;"> 返回一個可用的數(shù)據(jù)庫連接 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">private</span> Connection findFreeConnection() <span style="color: #0000ff;">throws</span><span style="color: #000000;"> SQLException {  
    Connection conn </span>= <span style="color: #0000ff;">null</span><span style="color: #000000;">;  
    PooledConnection pConn </span>= <span style="color: #0000ff;">null</span><span style="color: #000000;">;  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 獲得連接池向量中所有的對象  </span>
    Enumeration enumerate =<span style="color: #000000;"> connections.elements();  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 遍歷所有的對象，看是否有可用的連接  </span>
    <span style="color: #0000ff;">while</span><span style="color: #000000;"> (enumerate.hasMoreElements()) {  
        pConn </span>=<span style="color: #000000;"> (PooledConnection) enumerate.nextElement();  
        </span><span style="color: #0000ff;">if</span> (!<span style="color: #000000;">pConn.isBusy()) {  
            </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果此對象不忙，則獲得它的數(shù)據(jù)庫連接并把它設(shè)為忙  </span>
            conn =<span style="color: #000000;"> pConn.getConnection();  
            pConn.setBusy(</span><span style="color: #0000ff;">true</span><span style="color: #000000;">);  
            </span><span style="color: #008000;">//</span><span style="color: #008000;"> 測試此連接是否可用  </span>
            <span style="color: #0000ff;">if</span> (!<span style="color: #000000;">testConnection(conn)) {  
                </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果此連接不可再用了，則創(chuàng)建一個新的連接，  
                </span><span style="color: #008000;">//</span><span style="color: #008000;"> 并替換此不可用的連接對象，如果創(chuàng)建失敗，返回 null  </span>
                <span style="color: #0000ff;">try</span><span style="color: #000000;"> {  
                    conn </span>=<span style="color: #000000;"> newConnection();  
                } </span><span style="color: #0000ff;">catch</span><span style="color: #000000;"> (SQLException e) {  
                    System.out.println(</span>" 創(chuàng)建數(shù)據(jù)庫連接失敗！ " +<span style="color: #000000;"> e.getMessage());  
                    </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">null</span><span style="color: #000000;">;  
                }  
                pConn.setConnection(conn);  
            }  
            </span><span style="color: #0000ff;">break</span>; <span style="color: #008000;">//</span><span style="color: #008000;"> 己經(jīng)找到一個可用的連接，退出  </span>

}
}
return conn;// 返回找到到的可用連接
}

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 測試一個連接是否可用，如果不可用，關(guān)掉它并返回 false 否則可用返回 true 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> conn 
 *            需要測試的數(shù)據(jù)庫連接 
 * </span><span style="color: #808080;">@return</span><span style="color: #008000;"> 返回 true 表示此連接可用， false 表示不可用 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">private</span> <span style="color: #0000ff;">boolean</span><span style="color: #000000;"> testConnection(Connection conn) {  
    </span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 判斷測試表是否存在  </span>
        <span style="color: #0000ff;">if</span> (testTable.equals(""<span style="color: #000000;">)) {  
            </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果測試表為空，試著使用此連接的 setAutoCommit() 方法  
            </span><span style="color: #008000;">//</span><span style="color: #008000;"> 來判斷連接否可用（此方法只在部分數(shù)據(jù)庫可用，如果不可用 ,  
            </span><span style="color: #008000;">//</span><span style="color: #008000;"> 拋出異常）。注意：使用測試表的方法更可靠  </span>
            conn.setAutoCommit(<span style="color: #0000ff;">true</span><span style="color: #000000;">);  
        } </span><span style="color: #0000ff;">else</span> {<span style="color: #008000;">//</span><span style="color: #008000;"> 有測試表的時候使用測試表測試  
            </span><span style="color: #008000;">//</span><span style="color: #008000;"> check if this connection is valid  </span>
            Statement stmt =<span style="color: #000000;"> conn.createStatement();  
            stmt.execute(</span>"select count(*) from " +<span style="color: #000000;"> testTable);  
        }  
    } </span><span style="color: #0000ff;">catch</span><span style="color: #000000;"> (SQLException e) {  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 上面拋出異常，此連接己不可用，關(guān)閉它，并返回 false;  </span>

closeConnection(conn);
return false;
}
// 連接可用，返回 true
return true;
}

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 此函數(shù)返回一個數(shù)據(jù)庫連接到連接池中，并把此連接置為空閑。 所有使用連接池獲得的數(shù)據(jù)庫連接均應在不使用此連接時返回它。 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> 需返回到連接池中的連接對象 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span><span style="color: #000000;"> returnConnection(Connection conn) {  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 確保連接池存在，如果連接沒有創(chuàng)建（不存在），直接返回  </span>
    <span style="color: #0000ff;">if</span> (connections == <span style="color: #0000ff;">null</span><span style="color: #000000;">) {  
        System.out.println(</span>" 連接池不存在，無法返回此連接到連接池中 !"<span style="color: #000000;">);  
        </span><span style="color: #0000ff;">return</span><span style="color: #000000;">;  
    }  
    PooledConnection pConn </span>= <span style="color: #0000ff;">null</span><span style="color: #000000;">;  
    Enumeration enumerate </span>=<span style="color: #000000;"> connections.elements();  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 遍歷連接池中的所有連接，找到這個要返回的連接對象  </span>
    <span style="color: #0000ff;">while</span><span style="color: #000000;"> (enumerate.hasMoreElements()) {  
        pConn </span>=<span style="color: #000000;"> (PooledConnection) enumerate.nextElement();  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 先找到連接池中的要返回的連接對象  </span>
        <span style="color: #0000ff;">if</span> (conn ==<span style="color: #000000;"> pConn.getConnection()) {  
            </span><span style="color: #008000;">//</span><span style="color: #008000;"> 找到了 , 設(shè)置此連接為空閑狀態(tài)  </span>
            pConn.setBusy(<span style="color: #0000ff;">false</span><span style="color: #000000;">);  
            </span><span style="color: #0000ff;">break</span><span style="color: #000000;">;  
        }  
    }  
}  

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 刷新連接池中所有的連接對象 
 *  
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">synchronized</span> <span style="color: #0000ff;">void</span> refreshConnections() <span style="color: #0000ff;">throws</span><span style="color: #000000;"> SQLException {  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 確保連接池己創(chuàng)新存在  </span>
    <span style="color: #0000ff;">if</span> (connections == <span style="color: #0000ff;">null</span><span style="color: #000000;">) {  
        System.out.println(</span>" 連接池不存在，無法刷新 !"<span style="color: #000000;">);  
        </span><span style="color: #0000ff;">return</span><span style="color: #000000;">;  
    }  
    PooledConnection pConn </span>= <span style="color: #0000ff;">null</span><span style="color: #000000;">;  
    Enumeration enumerate </span>=<span style="color: #000000;"> connections.elements();  
    </span><span style="color: #0000ff;">while</span><span style="color: #000000;"> (enumerate.hasMoreElements()) {  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 獲得一個連接對象  </span>
        pConn =<span style="color: #000000;"> (PooledConnection) enumerate.nextElement();  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果對象忙則等 5 秒 ,5 秒后直接刷新  </span>
        <span style="color: #0000ff;">if</span><span style="color: #000000;"> (pConn.isBusy()) {  
            wait(</span>5000); <span style="color: #008000;">//</span><span style="color: #008000;"> 等 5 秒  </span>

}
// 關(guān)閉此連接，用一個新的連接代替它。
closeConnection(pConn.getConnection());
pConn.setConnection(newConnection());
pConn.setBusy(false);
}
}

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 關(guān)閉連接池中所有的連接，并清空連接池。 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">synchronized</span> <span style="color: #0000ff;">void</span> closeConnectionPool() <span style="color: #0000ff;">throws</span><span style="color: #000000;"> SQLException {  
    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 確保連接池存在，如果不存在，返回  </span>
    <span style="color: #0000ff;">if</span> (connections == <span style="color: #0000ff;">null</span><span style="color: #000000;">) {  
        System.out.println(</span>" 連接池不存在，無法關(guān)閉 !"<span style="color: #000000;">);  
        </span><span style="color: #0000ff;">return</span><span style="color: #000000;">;  
    }  
    PooledConnection pConn </span>= <span style="color: #0000ff;">null</span><span style="color: #000000;">;  
    Enumeration enumerate </span>=<span style="color: #000000;"> connections.elements();  
    </span><span style="color: #0000ff;">while</span><span style="color: #000000;"> (enumerate.hasMoreElements()) {  
        pConn </span>=<span style="color: #000000;"> (PooledConnection) enumerate.nextElement();  
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果忙，等 5 秒  </span>
        <span style="color: #0000ff;">if</span><span style="color: #000000;"> (pConn.isBusy()) {  
            wait(</span>5000); <span style="color: #008000;">//</span><span style="color: #008000;"> 等 5 秒  </span>

}
// 5 秒后直接關(guān)閉它
closeConnection(pConn.getConnection());
// 從連接池向量中刪除它
connections.removeElement(pConn);
}
// 置連接池為空
connections = null;
}

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 關(guān)閉一個數(shù)據(jù)庫連接 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> 需要關(guān)閉的數(shù)據(jù)庫連接 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">private</span> <span style="color: #0000ff;">void</span><span style="color: #000000;"> closeConnection(Connection conn) {  
    </span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {  
        conn.close();  
    } </span><span style="color: #0000ff;">catch</span><span style="color: #000000;"> (SQLException e) {  
        System.out.println(</span>" 關(guān)閉數(shù)據(jù)庫連接出錯： " +<span style="color: #000000;"> e.getMessage());  
    }  
}  
</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * 使程序等待給定的毫秒數(shù) 
 *  
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> 給定的毫秒數(shù) 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">private</span> <span style="color: #0000ff;">void</span> wait(<span style="color: #0000ff;">int</span><span style="color: #000000;"> mSeconds) {  
    </span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {  
        Thread.sleep(mSeconds);  
    } </span><span style="color: #0000ff;">catch</span><span style="color: #000000;"> (InterruptedException e) {  
    }  
}  
</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 *  
 * 內(nèi)部使用的用于保存連接池中連接對象的類 此類中有兩個成員，一個是數(shù)據(jù)庫的連接，另一個是指示此連接是否 正在使用的標志。 
 </span><span style="color: #008000;">*/</span>  

<span style="color: #0000ff;">class</span><span style="color: #000000;"> PooledConnection {  
    Connection connection </span>= <span style="color: #0000ff;">null</span>;<span style="color: #008000;">//</span><span style="color: #008000;"> 數(shù)據(jù)庫連接  </span>
    <span style="color: #0000ff;">boolean</span> busy = <span style="color: #0000ff;">false</span>; <span style="color: #008000;">//</span><span style="color: #008000;"> 此連接是否正在使用的標志，默認沒有正在使用  

    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 構(gòu)造函數(shù)，根據(jù)一個 Connection 構(gòu)告一個 PooledConnection 對象  </span>
    <span style="color: #0000ff;">public</span><span style="color: #000000;"> PooledConnection(Connection connection) {  
        </span><span style="color: #0000ff;">this</span>.connection =<span style="color: #000000;"> connection;  
    }  

    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 返回此對象中的連接  </span>
    <span style="color: #0000ff;">public</span><span style="color: #000000;"> Connection getConnection() {  
        </span><span style="color: #0000ff;">return</span><span style="color: #000000;"> connection;  
    }  

    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 設(shè)置此對象的，連接  </span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span><span style="color: #000000;"> setConnection(Connection connection) {  
        </span><span style="color: #0000ff;">this</span>.connection =<span style="color: #000000;"> connection;  
    }  

    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 獲得對象連接是否忙  </span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">boolean</span><span style="color: #000000;"> isBusy() {  
        </span><span style="color: #0000ff;">return</span><span style="color: #000000;"> busy;  
    }  

    </span><span style="color: #008000;">//</span><span style="color: #008000;"> 設(shè)置對象的連接正在忙  </span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span> setBusy(<span style="color: #0000ff;">boolean</span><span style="color: #000000;"> busy) {  
        </span><span style="color: #0000ff;">this</span>.busy =<span style="color: #000000;"> busy;  
    }  
}  

}

ConnectionPoolUtils.java

/*連接池工具類，返回唯一的一個數(shù)據(jù)庫連接池對象,單例模式*/  
public class ConnectionPoolUtils {  
    private ConnectionPoolUtils(){};//私有靜態(tài)方法  
    private static ConnectionPool poolInstance = null;  
    public static ConnectionPool GetPoolInstance(){  
        if(poolInstance == null) {  
            poolInstance = new ConnectionPool(                     
                    "com.mysql.jdbc.Driver",                   
                    "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8",                
                    "root", "123456");  
            try {  
                poolInstance.createPool();  
            } catch (Exception e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            }  
        }  
        return poolInstance;  
    }  
}  

ConnectionPoolTest.java 

import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.SQLException;  
import java.sql.Statement;  

public class ConnectionTest {

</span><span style="color: #008000;">/**</span><span style="color: #008000;"> 
 * </span><span style="color: #808080;">@param</span><span style="color: #008000;"> args 
 * </span><span style="color: #808080;">@throws</span><span style="color: #008000;"> Exception  
 </span><span style="color: #008000;">*/</span>  
<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">static</span> <span style="color: #0000ff;">void</span> main(String[] args) <span style="color: #0000ff;">throws</span><span style="color: #000000;"> Exception {  
     </span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {  
              </span><span style="color: #008000;">/*</span><span style="color: #008000;">使用連接池創(chuàng)建100個連接的時間</span><span style="color: #008000;">*/</span>   
               <span style="color: #008000;">/*</span><span style="color: #008000;">// 創(chuàng)建數(shù)據(jù)庫連接庫對象 
               ConnectionPool connPool = new ConnectionPool("com.mysql.jdbc.Driver","jdbc:mysql://localhost:3306/test", "root", "123456"); 
               // 新建數(shù)據(jù)庫連接庫 
               connPool.createPool();</span><span style="color: #008000;">*/</span><span style="color: #000000;">  
           
              ConnectionPool  connPool</span>=ConnectionPoolUtils.GetPoolInstance();<span style="color: #008000;">//</span><span style="color: #008000;">單例模式創(chuàng)建連接池對象  
                </span><span style="color: #008000;">//</span><span style="color: #008000;"> SQL測試語句  </span>
               String sql = "Select * from pet"<span style="color: #000000;">;  
               </span><span style="color: #008000;">//</span><span style="color: #008000;"> 設(shè)定程序運行起始時間  </span>
               <span style="color: #0000ff;">long</span> start =<span style="color: #000000;"> System.currentTimeMillis();  
                     </span><span style="color: #008000;">//</span><span style="color: #008000;"> 循環(huán)測試100次數(shù)據(jù)庫連接  </span>
                      <span style="color: #0000ff;">for</span> (<span style="color: #0000ff;">int</span> i = 0; i &lt; 100; i++<span style="color: #000000;">) {  
                          Connection conn </span>= connPool.getConnection(); <span style="color: #008000;">//</span><span style="color: #008000;"> 從連接庫中獲取一個可用的連接  </span>
                          Statement stmt =<span style="color: #000000;"> conn.createStatement();  
                          ResultSet rs </span>=<span style="color: #000000;"> stmt.executeQuery(sql);  
                          </span><span style="color: #0000ff;">while</span><span style="color: #000000;"> (rs.next()) {  
                              String name </span>= rs.getString("name"<span style="color: #000000;">);  
                           </span><span style="color: #008000;">//</span><span style="color: #008000;">  System.out.println("查詢結(jié)果" + name);  </span>

}
rs.close();
stmt.close();
connPool.returnConnection(conn);// 連接使用完后釋放連接到連接池
}
System.out.println(“經(jīng)過100次的循環(huán)調(diào)用，使用連接池花費的時間:”+ (System.currentTimeMillis() - start) + “ms”);
// connPool.refreshConnections();//刷新數(shù)據(jù)庫連接池中所有連接，即不管連接是否正在運行，都把所有連接都釋放并放回到連接池。注意：這個耗時比較大。
connPool.closeConnectionPool();// 關(guān)閉數(shù)據(jù)庫連接池。注意：這個耗時比較大。
// 設(shè)定程序運行起始時間
start = System.currentTimeMillis();

                      </span><span style="color: #008000;">/*</span><span style="color: #008000;">不使用連接池創(chuàng)建100個連接的時間</span><span style="color: #008000;">*/</span>  
                     <span style="color: #008000;">//</span><span style="color: #008000;"> 導入驅(qū)動  </span>
                      Class.forName("com.mysql.jdbc.Driver"<span style="color: #000000;">);  
                      </span><span style="color: #0000ff;">for</span> (<span style="color: #0000ff;">int</span> i = 0; i &lt; 100; i++<span style="color: #000000;">) {  
                          </span><span style="color: #008000;">//</span><span style="color: #008000;"> 創(chuàng)建連接  </span>
                         Connection conn =<span style="color: #000000;"> DriverManager.getConnection(  
                                  </span>"jdbc:mysql://localhost:3306/test", "root", "123456"<span style="color: #000000;">);  
                          Statement stmt </span>=<span style="color: #000000;"> conn.createStatement();  
                          ResultSet rs </span>=<span style="color: #000000;"> stmt.executeQuery(sql);  
                         </span><span style="color: #0000ff;">while</span><span style="color: #000000;"> (rs.next()) {  
                          }  
                         rs.close();  
                         stmt.close();  
                         conn.close();</span><span style="color: #008000;">//</span><span style="color: #008000;"> 關(guān)閉連接  </span>

}
System.out.println(“經(jīng)過100次的循環(huán)調(diào)用，不使用連接池花費的時間:”
+ (System.currentTimeMillis() - start) + “ms”);
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}

DBCPUtils:

public class DBCPUtils {
    private static DataSource ds;//定義一個連接池對象
    static{
        try {
            Properties pro = new Properties();
            pro.load(DBCPUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties"));
            ds = BasicDataSourceFactory.createDataSource(pro);//得到一個連接池對象
        } catch (Exception e) {
            throw new ExceptionInInitializerError("初始化連接錯誤，請檢查配置文件！");
        }
    }
    //從池中獲取一個連接
    public static Connection getConnection() throws SQLException{
        return ds.getConnection();
    }
</span><span style="color: #0000ff;">public</span> <span style="color: #0000ff;">static</span> <span style="color: #0000ff;">void</span><span style="color: #000000;"> closeAll(ResultSet rs,Statement stmt,Connection conn){
    </span><span style="color: #0000ff;">if</span>(rs!=<span style="color: #0000ff;">null</span><span style="color: #000000;">){
        </span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
            rs.close();
        } </span><span style="color: #0000ff;">catch</span><span style="color: #000000;"> (SQLException e) {
            e.printStackTrace();
        }
    }
    
    </span><span style="color: #0000ff;">if</span>(stmt!=<span style="color: #0000ff;">null</span><span style="color: #000000;">){
        </span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
            stmt.close();
        } </span><span style="color: #0000ff;">catch</span><span style="color: #000000;"> (SQLException e) {
            e.printStackTrace();
        }
    }
    
    </span><span style="color: #0000ff;">if</span>(conn!=<span style="color: #0000ff;">null</span><span style="color: #000000;">){
        </span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
            conn.close();</span><span style="color: #008000;">//</span><span style="color: #008000;">關(guān)閉</span>
        } <span style="color: #0000ff;">catch</span><span style="color: #000000;"> (SQLException e) {
            e.printStackTrace();
        }
    }
}

}

6.導入的jar包

commons-dbcp.jar：DBCP實現(xiàn)要導入的jar

commons-pool.jar： 連接池實現(xiàn)的依賴類

commons-collections.jar ：連接池實現(xiàn)的集合類

參考：MySql數(shù)據(jù)庫連接池

參考：數(shù)據(jù)庫連接池的理解

參考：數(shù)據(jù)庫連接池原理

參考：Java數(shù)據(jù)庫連接池實現(xiàn)原理

參考：Java數(shù)據(jù)庫連接池--DBCP淺析.

<div id="blog_post_info">

好文要頂 關(guān)注我 收藏該文

aspirant
關(guān)注 - 20
粉絲 - 455

+加關(guān)注

<div class="clear"></div>
<div id="post_next_prev">

<a href="http://www.rzrgm.cn/aspirant/p/6740556.html" class="p_n_p_prefix">? </a> 上一篇：    <a href="http://www.rzrgm.cn/aspirant/p/6740556.html" title="發(fā)布于 2017-04-20 20:04">linux 負載均衡配置 keepalive lvs 使用nginx轉(zhuǎn)發(fā)   CentOS7 搭建LVS+keepalived負載均衡</a>
<br>
<a href="http://www.rzrgm.cn/aspirant/p/6788998.html" class="p_n_p_prefix">? </a> 下一篇：    <a href="http://www.rzrgm.cn/aspirant/p/6788998.html" title="發(fā)布于 2017-04-30 10:40">一道面試題：StringBuffer a=new StringBuffer ("A"); StringBuffer b=new StringBuffer (StringBuffer線程安全 StringBuilder線程不安全)</a>