package com.xinnuo.jdbc;

import java.io.*;
import java.sql.*;
import java.util.*;
import java.util.Date;

?/*
? * 該類(lèi)只能創(chuàng)建一個(gè)實(shí)例，其它對(duì)象能夠調(diào)用其靜態(tài)方法（也稱(chēng)為類(lèi)方法）獲得該唯一實(shí)例的引用。
? * DBConnectionManager類(lèi)的建構(gòu)函數(shù)是私有的，這是為了避免其它對(duì)象創(chuàng)建該類(lèi)的實(shí)例.
? * DBConnectionManager類(lèi)的客戶(hù)程序可以調(diào)用getInstance()方法獲得對(duì)該類(lèi)唯一實(shí)例的引用。
? * 類(lèi)的唯一實(shí)例在getInstance()方法第一次被調(diào)用期間創(chuàng)建，此后其引用就一直保存在靜態(tài)變量
? * instance中。每次調(diào)用getInstance()都增加一個(gè)DBConnectionManager的客戶(hù)程序計(jì)數(shù)。
? * 即，該計(jì)數(shù)代表引用DBConnectionManager唯一實(shí)例的客戶(hù)程序總數(shù)，它將被用于控制連接池的
? * 關(guān)閉操作。 該類(lèi)實(shí)例的初始化工作私有方法init()完成。其中 getResourceAsStream()方法
? * 用于定位并打開(kāi)外部文件。外部文件的定位方法依賴(lài)于類(lèi)裝載器的實(shí)現(xiàn)。標(biāo)準(zhǔn)的本地類(lèi)裝載器查找操
? * 作總是開(kāi)始于類(lèi)文件所在路徑，也能夠搜索CLASSPATH中聲明的路徑。db.properties是一個(gè)屬性
? * 文件，它包含定義連接池的鍵-值對(duì)。可供定義的公用屬性如下：
? * ??drivers 以空格分隔的JDBC驅(qū)動(dòng)程序類(lèi)列表\\
? * ??logfile 日志文件的絕對(duì)路徑
? *??其它的屬性和特定連接池相關(guān)，其屬性名字前應(yīng)加上連接池名字：
? *??< poolname>.url 數(shù)據(jù)庫(kù)的 JDBC URL
? *??< poolname>.maxconn 允許建立的最大連接數(shù)，0表示沒(méi)有限制
? *??< poolname>.user 用于該連接池的數(shù)據(jù)庫(kù)帳號(hào)
? *??< poolname>.password 相應(yīng)的密碼\\
? *?其中url屬性是必需的，而其它屬性則是可選的。數(shù)據(jù)庫(kù)帳號(hào)和密碼必須合法。用于Windows平臺(tái)的
? *?db.properties文件示例如下：
? *??drivers=com.microsoft.jdbc.sqlserver.SQLServerDriver
? *??logfile=D:\\log.txt
? *??access.maxconn=20
? *??access.url=jdbc:microsoft:sqlserver://localhost:1433;databasename=web
? *??access.user=sa
? *??access.password=sa?
? *?注意在Windows路徑中的反斜杠必須輸入2個(gè)，這是由于屬性文件中的反斜杠同時(shí)也是一個(gè)轉(zhuǎn)義字符。
? *?init()方法在創(chuàng)建屬性對(duì)象并讀取db.properties文件之后，就開(kāi)始檢查logfile屬性。如果屬
? *?性文件中沒(méi)有指定日志文件，則默認(rèn)為當(dāng)前目錄下的DBConnectionManager.log文件。如日志文
? *?件無(wú)法使用，則向System.err輸出日志記錄。裝載和注冊(cè)所有在drivers屬性中指定的JDBC驅(qū)動(dòng)
? *?程序loadDrivers()方法實(shí)現(xiàn)。該方法先用StringTokenizer將drivers屬性值分割為對(duì)應(yīng)于驅(qū)
? *?動(dòng)程序名稱(chēng)的字符串，然后依次裝載這些類(lèi)并創(chuàng)建其實(shí)例，最后在DriverManager中注冊(cè)該實(shí)例并把
? *?它加入到一個(gè)私有的向量drivers。向量drivers將用于關(guān)閉服務(wù)時(shí)從DriverManager取消所有
? *?JDBC 驅(qū)動(dòng)程序的注冊(cè)。init()方法的最后一個(gè)任務(wù)是調(diào)用私有方法createPools()創(chuàng)建連接池對(duì)
? *?象。createPools()方法先創(chuàng)建所有屬性名字的枚舉對(duì)象（即Enumeration對(duì)象，該對(duì)象可以想象
? *?為一個(gè)元素系列，逐次調(diào)用其nextElement()方法將順序返回各元素），然后在其中搜索名字以“.url”
? *?結(jié)尾的屬性。對(duì)于每一個(gè)符合條件的屬性，先提取其連接池名字部分，進(jìn)而讀取所有屬于該連接池的屬性，
? *?最后創(chuàng)建連接池對(duì)象并把它保存在實(shí)例變量pools中。散列表（Hashtable類(lèi) ）pools實(shí)現(xiàn)連接池名字
? *?到連接池對(duì)象之間的映射，此處以連接池名字為鍵，連接池對(duì)象為值。 為便于客戶(hù)程序從指定連接池獲
? *?得可用連接或?qū)⑦B接返回給連接池，類(lèi)DBConnectionManager提供了方法getConnection()和
? *?freeConnection()。所有這些方法都要求在參數(shù)中指定連接池名字，具體的連接獲取或返回操作則調(diào)
? *?用對(duì)應(yīng)的連接池對(duì)象完成。為實(shí)現(xiàn)連接池的安全關(guān)閉，DBConnectionManager提供了方法release()。
? *?在上面我們已經(jīng)提到，所有DBConnectionManager的客戶(hù)程序都應(yīng)該調(diào)用靜態(tài)方法getInstance()
? *?以獲得該管理器的引用，此調(diào)用將增加客戶(hù)程序計(jì)數(shù)。客戶(hù)程序在關(guān)閉時(shí)調(diào)用release()可以遞減該計(jì)數(shù)。
? *?當(dāng)最后一個(gè)客戶(hù)程序調(diào)用release()，遞減后的引用計(jì)數(shù)為0，就可以調(diào)用各個(gè)連接池的release()方法
? *?關(guān)閉所有連接了。管理類(lèi)release()方法最后的任務(wù)是撤銷(xiāo)所有JDBC驅(qū)動(dòng)程序的注冊(cè)。
? */

/**
?* 管理類(lèi)DBConnectionManager支持對(duì)一個(gè)或多個(gè)由屬性文件定義的數(shù)據(jù)庫(kù)連接
?* 池的訪(fǎng)問(wèn).客戶(hù)程序可以調(diào)用getInstance()方法訪(fǎng)問(wèn)本類(lèi)的唯一實(shí)例.
?*/
public class DBConnectionManager {
?static private DBConnectionManager instance; // 唯一實(shí)例

?static private int clients;

?private Vector drivers = new Vector();

?private PrintWriter log;

?private Hashtable pools = new Hashtable();

?/**
? * 返回唯一實(shí)例.如果是第一次調(diào)用此方法,則創(chuàng)建實(shí)例
? * @return DBConnectionManager 唯一實(shí)例
? */
?static synchronized public DBConnectionManager getInstance() {
??if (instance == null) {
???instance = new DBConnectionManager();
??}
??clients++;
??return instance;
?}

?/**
? * 建構(gòu)函數(shù)私有以防止其它對(duì)象創(chuàng)建本類(lèi)實(shí)例
? */
?private DBConnectionManager() {
??init();
?}

?/**
? * * 將連接對(duì)象返回給由名字指定的連接池
? * @param name在屬性文件中定義的連接池名字
? * @param con連接對(duì)象\\\\r
? */
?public void freeConnection(String name, Connection con) {
??DBConnectionPool pool = (DBConnectionPool) pools.get(name);
??if (pool != null) {
???pool.freeConnection(con);
??}
?}

?/**
? * 獲得一個(gè)可用的(空閑的)連接.如果沒(méi)有可用連接,且已有連接數(shù)小于最大連接數(shù) 053 * 限制,則創(chuàng)建并返回新連
? * @param name在屬性文件中定義的連接池名字 056 *
? * @return Connection 可用連接或null 057
? */
?public Connection getConnection(String name) {
??DBConnectionPool pool = (DBConnectionPool) pools.get(name);
??if (pool != null) {
???return pool.getConnection();
??}
??return null;
?}

?/**
? * 獲得一個(gè)可用連接.若沒(méi)有可用連接,且已有連接數(shù)小于最大連接數(shù)限制,
? * 則創(chuàng)建并返回新連接.否則,在指定的時(shí)間內(nèi)等待其它線(xiàn)程釋放連接.
? * @param name 連接池名字 071 *
? * @param time以毫秒計(jì)的等待時(shí)間\\\\r
? * @return Connection 可用連接或null
? */
?public Connection getConnection(String name, long time) {
??DBConnectionPool pool = (DBConnectionPool) pools.get(name);
??if (pool != null) {
???return pool.getConnection(time);
??}
??return null;
?}

?/**
? * 關(guān)閉所有連接,撤銷(xiāo)驅(qū)動(dòng)程序的注冊(cè)\\\\r
? */
?public synchronized void release() {
??// 等待直到最后一個(gè)客戶(hù)程序調(diào)用
??if (--clients != 0) {
???return;
??}

??Enumeration allPools = pools.elements();
??while (allPools.hasMoreElements()) {
???DBConnectionPool pool = (DBConnectionPool) allPools.nextElement();
???pool.release();
??}
??Enumeration allDrivers = drivers.elements();
??while (allDrivers.hasMoreElements()) {
???Driver driver = (Driver) allDrivers.nextElement();
???try {
????DriverManager.deregisterDriver(driver);
????log("撤銷(xiāo)JDBC驅(qū)動(dòng)程序 " + driver.getClass().getName() + "的注冊(cè)");
???} catch (SQLException e) {
????log(e, "無(wú)法撤銷(xiāo)下列JDBC驅(qū)動(dòng)程序的注冊(cè): " + driver.getClass().getName());
???}
??}
?}

?/**
? * 根據(jù)指定屬性創(chuàng)建連接池實(shí)例.
? * @param props 連接池屬性 113
? */
?private void createPools(Properties props) {
??Enumeration propNames = props.propertyNames();
??while (propNames.hasMoreElements()) {
???String name = (String) propNames.nextElement();
???if (name.endsWith(".url")) {
????String poolName = name.substring(0, name.lastIndexOf("."));
????String url = props.getProperty(poolName + ".url");
????if (url == null) {
?????log("沒(méi)有為連接池" + poolName + "指定URL");
?????continue;
????}
????String user = props.getProperty(poolName + ".user");
????String password = props.getProperty(poolName + ".password");
????String maxconn = props.getProperty(poolName + ".maxconn", "0");
????int max;
????try {
?????max = Integer.valueOf(maxconn).intValue();
????} catch (NumberFormatException e) {
?????log("錯(cuò)誤的最大連接數(shù)限制: " + maxconn + " .連接池: " + poolName);
?????max = 0;
????}
????DBConnectionPool pool = new DBConnectionPool(poolName, url,
??????user, password, max);
????pools.put(poolName, pool);
????log("成功創(chuàng)建連接池" + poolName);
???}
??}
?}

?/**
? * 讀取屬性完成初始化
? */
?private void init() {
??InputStream is = getClass().getResourceAsStream("/db.properties");
??Properties dbProps = new Properties();
??try {
???dbProps.load(is);
??} catch (Exception e) {
???System.err.println("不能讀取屬性文件. "+"請(qǐng)確保db.properties在CLASSPATH指定的路徑中");
???return;
??}
??String logFile = dbProps.getProperty("logfile","DBConnectionManager.log");
??try {
???log = new PrintWriter(new FileWriter(logFile, true), true);
??} catch (IOException e) {
???System.err.println("無(wú)法打開(kāi)日志文件: " + logFile);
???log = new PrintWriter(System.err);
??}
??loadDrivers(dbProps);
??createPools(dbProps);
?}

?/**
? * 裝載和注冊(cè)所有JDBC驅(qū)動(dòng)程序
? * @param props屬性
? */
?private void loadDrivers(Properties props) {
??String driverClasses = props.getProperty("drivers");
??StringTokenizer st = new StringTokenizer(driverClasses);
??while (st.hasMoreElements()) {
???String driverClassName = st.nextToken().trim();
???try {
????Driver driver = (Driver) Class.forName(driverClassName).newInstance();
????DriverManager.registerDriver(driver);
????drivers.addElement(driver);
????log("成功注冊(cè)JDBC驅(qū)動(dòng)程序" + driverClassName);
???} catch (Exception e) {
????e.printStackTrace();
????log("無(wú)法注冊(cè)JDBC驅(qū)動(dòng)程序: " + driverClassName + ", 錯(cuò)誤: " + e);
???}
??}
?}

?/**
? * 將文本信息寫(xiě)入日志文件
? */
?private void log(String msg) {
??log.println(new Date() + ": " + msg);
?}

?/**
? * 將文本信息與異常寫(xiě)入日志文件
? */
?private void log(Throwable e, String msg) {
??log.println(new Date() + ": " + msg);
??e.printStackTrace(log);
?}

?// ///////////////////////////////////////////////////////////////////////////////////////////////////////
?// ///////////////////////////////////////////////////////////////////////////////////////////////////////
?/*
? * DBConnectionPool實(shí)現(xiàn)，它表示指向某個(gè)數(shù)據(jù)庫(kù)的連接池。數(shù)據(jù)庫(kù)由JDBC URL標(biāo)識(shí)。一個(gè)JDBCURL由三部分組成：協(xié)議標(biāo)識(shí)（總是jdbc），
? * 驅(qū)動(dòng)程序標(biāo)識(shí)（如odbc、idb、oracle等），數(shù)據(jù)庫(kù)標(biāo)識(shí)（其格式依賴(lài)于驅(qū)動(dòng)程序）。例如，jdbc:odbc:demo，即是一個(gè)指向demo數(shù)據(jù)
? * 庫(kù)的JDBCURL，而且訪(fǎng)問(wèn)該數(shù)據(jù)庫(kù)要使用JDBC-ODBC驅(qū)動(dòng)程序。每個(gè)連接池都有一個(gè)供客戶(hù)程序使用的名字以及可選的用戶(hù)帳號(hào)、密碼、最
? * 大連接數(shù)限制。如果Web應(yīng)用程序所支持的某些數(shù)據(jù)庫(kù)操作可以被所有用戶(hù)執(zhí)行，而其它一些操作應(yīng)由特別許可的用戶(hù)執(zhí)行，則可以為兩類(lèi)操作
? * 分別定義連接池，兩個(gè)連接池使用相同的JDBC URL，但使用不同的帳號(hào)和密碼。類(lèi)DBConnectionPool的建構(gòu)函數(shù)需要上述所有數(shù)據(jù)作為其
? * 參數(shù)。客戶(hù)程序可以使用DBConnectionPool
? * 類(lèi)提供的兩個(gè)方法獲取可用連接。兩者的共同之處在于：如連接池中存在可用連接，則直接返回，否則創(chuàng)建新的連接并返回。如果沒(méi)有可用連接
? * 且已有連接總數(shù)等于最大限制數(shù)，第一個(gè)方法將直接返回null，而第二個(gè)方法將等待直到有可用連接為止。所有的可用連接對(duì)象均登記在名為
? * freeConnections的向量（Vector）中。如果向量中有多于一個(gè)的連接，getConnection()總是選取第一個(gè)。同時(shí)，由于新的可用連接總
? * 是從尾部加入向量，從而使得數(shù)據(jù)庫(kù)連接由于長(zhǎng)時(shí)間閑置而被關(guān)閉的風(fēng)險(xiǎn)減低到最小程度。 第一個(gè)getConnection()在返回可用連接給客戶(hù)
? * 程序之前，調(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表示沒(méi)有限制。如果沒(méi)有指定最大連接數(shù)限制或當(dāng)前連接數(shù)小于該值，該方法嘗試創(chuàng)建
? * 新的連接。如創(chuàng)建成功，則增加已使用連接的計(jì)數(shù)并返回，否則返回空值。創(chuàng)建新連接由newConnection()方法實(shí)現(xiàn)。
? * 創(chuàng)建過(guò)程與是否已經(jīng)指定數(shù)據(jù)庫(kù)帳號(hào)、密碼有關(guān)。JDBC的DriverManager類(lèi)提供多個(gè)getConnection()方法，這些方法要用到JDBC URL
? * 與其它一些參數(shù)，如用戶(hù)帳號(hào)和密碼等。DriverManager將使用指定的JDBC URL確定適合于目標(biāo)數(shù)據(jù)庫(kù)的驅(qū)動(dòng)程序及建立連接。
? * 第二個(gè)getConnection()方法需要一個(gè)以毫秒為單位的時(shí)間參數(shù)，該參數(shù)表示客戶(hù)程序能夠等待的最長(zhǎng)時(shí)間。建立連接的具體操
? * 作仍舊由第一個(gè)getConnection()方法實(shí)現(xiàn)。該方法執(zhí)行時(shí)先將startTime初始化為當(dāng)前時(shí)間。在while循環(huán)中嘗試獲得一個(gè)連接。如果失
? * 敗，則以給定的時(shí)間值為參數(shù)調(diào)用wait()。wait()的返回可能是由于其它線(xiàn)程調(diào)用notify()或notifyAll()，也可能是由于預(yù)定時(shí)間已到。
? * 為找出wait()返回的真正原因，程序用當(dāng)前時(shí)間減開(kāi)始時(shí)間（startTime），如差值大于預(yù)定時(shí)間則返回空值，否則再次調(diào)用getConnection()。
? * 把空閑的連接登記到連接池由freeConnection()方法實(shí)現(xiàn)，它的參數(shù)為返回給連接池的連接對(duì)象。該對(duì)象被加入到freeConnections
? * 向量的末尾，然后減少已使用連接計(jì)數(shù)。調(diào)用notifyAll()是為了通知其它正在等待可用連接的線(xiàn)程。 許多Servlet引擎為實(shí)現(xiàn)安全關(guān)閉提供
? * 多種方法。數(shù)據(jù)庫(kù)連接池需要知道該事件以保證所有連接能夠正常關(guān)閉。DBConnectionManager類(lèi)負(fù)協(xié)調(diào)整個(gè)關(guān)閉過(guò)程，但關(guān)閉連接池中所有連
? * 接的任務(wù)則由DBConnectionPool類(lèi)負(fù)責(zé)。release()方法供DBConnectionManager調(diào)用。該方法遍歷freeConnections向量并關(guān)閉所有連接，
? * 然后從向量中刪除這些連接。
? */

?/**
? * 此內(nèi)部類(lèi)定義了一個(gè)連接池.它能夠根據(jù)要求創(chuàng)建新連接,直到預(yù)定的最\\\\r
? */
?class DBConnectionPool {
??private int checkedOut;

??private Vector freeConnections = new Vector();

??private int maxConn;

??private String name;

??private String password;

??private String URL;

??private String user;

??/**
?? * 創(chuàng)建新的連接池
?? * @param name連接池名字
?? * @param URL數(shù)據(jù)庫(kù)的JDBC URL
?? * @param user數(shù)據(jù)庫(kù)帳號(hào),或 null
?? * @param password密碼,或 null
?? * @param maxConn此連接池允許建立的最大連接數(shù)
?? */
??public DBConnectionPool(String name, String URL, String user,
????String password, int maxConn) {
???this.name = name;
???this.URL = URL;
???this.user = user;
???this.password = password;
???this.maxConn = maxConn;
??}

??/**
?? * 將不再使用的連接返回給連接池
?? * @param con客戶(hù)程序釋放的連接
?? */
??public synchronized void freeConnection(Connection con) {
???// 將指定連接加入到向量末尾
???freeConnections.addElement(con);
???checkedOut--;
???notifyAll();
??}

??/**
?? * 從連接池獲得一個(gè)可用連接.如沒(méi)有空閑的連接且當(dāng)前連接數(shù)小于最大連接 數(shù)限制,則創(chuàng)建新連接.
?? * 如原來(lái)登記為可用的連接不再有效,則從向量刪除之,
?? * 然后遞歸調(diào)用自己以嘗試新的可用連接.
?? */
??public synchronized Connection getConnection() {
???Connection con = null;
???if (freeConnections.size() > 0) {// 獲取向量中第一個(gè)可用連接
????con = (Connection) freeConnections.firstElement();
????freeConnections.removeElementAt(0);
????try {
?????if (con.isClosed()) {
??????log("從連接池" + name + "刪除一個(gè)無(wú)效連接");
??????// 遞歸調(diào)用自己,嘗試再次獲取可用連接
??????con = getConnection();
?????}
????} catch (SQLException e) {
?????log("從連接池" + name + "刪除一個(gè)無(wú)效連接");
?????// 遞歸調(diào)用自己,嘗試再次獲取可用連接
?????con = getConnection();
????}
???} else if (maxConn == 0 || checkedOut < maxConn) {
????con = newConnection();
???}
???if (con != null) {
????checkedOut++;
???}
???return con;
??}

??/**
?? * 從連接池獲取可用連接.可以指定客戶(hù)程序能夠等待的最長(zhǎng)時(shí)間 參見(jiàn)前一個(gè)getConnection()方法.
?? * @param timeout以毫秒計(jì)的等待時(shí)間限制
?? */
??public synchronized Connection getConnection(long timeout) {
???long startTime = new Date().getTime();
???Connection con;
???while ((con = getConnection()) == null) {
????try {
?????wait(timeout);
????} catch (InterruptedException e) {
?????e.printStackTrace();
????}
????if ((new Date().getTime() - startTime) >= timeout) {// wait()返回的原因是超時(shí)
?????return null;
????}
???}
???return con;
??}

??/**
?? * 關(guān)閉所有連接
?? */
??public synchronized void release() {
???Enumeration allConnections = freeConnections.elements();
???while (allConnections.hasMoreElements()) {
????Connection con = (Connection) allConnections.nextElement();
????try {
?????con.close();
?????log("關(guān)閉連接池" + name + "中的一個(gè)連接");
????} catch (SQLException e) {
?????log(e, "無(wú)法關(guān)閉連接池" + name + "中的連接");
?????e.printStackTrace();
????}
???}
???freeConnections.removeAllElements();
??}

??/**
?? * 創(chuàng)建新的連接
?? */
??private Connection newConnection() {
???Connection con = null;
???try {
????if (user==null||"".equals(user)) {
?????con = DriverManager.getConnection(URL);
????} else {
?????con = DriverManager.getConnection(URL, user, password);
????}
????log("連接池" + name + "創(chuàng)建一個(gè)新的連接");
???} catch (SQLException e) {
????log(e, "無(wú)法創(chuàng)建下列URL的連接: " + URL);
????return null;
???}
???return con;
??}
?}

?/////////////////////////////////////////////////////////////////////////////////////////////
?/////////////////////////////////////////////////////////////////////////////////////////////
}

在sqlserver2000，tomcat5.5驗(yàn)證通過(guò)

jwebee

我的個(gè)人網(wǎng)站