日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
快速創(chuàng)建高效的數(shù)據(jù)庫連接池(c創(chuàng)建數(shù)據(jù)庫連接池)

隨著互聯(lián)網(wǎng)技術(shù)的不斷發(fā)展和普及,數(shù)據(jù)庫扮演了越來越重要的角色,而數(shù)據(jù)庫連接池,則是提高數(shù)據(jù)庫性能的關(guān)鍵之一。它允許應(yīng)用程序重復(fù)使用已經(jīng)創(chuàng)建好的數(shù)據(jù)庫連接,減少了數(shù)據(jù)庫連接的創(chuàng)建和銷毀開銷,提高了數(shù)據(jù)庫的訪問效率。本文將介紹如何快速地創(chuàng)建高效的數(shù)據(jù)庫連接池。

成都創(chuàng)新互聯(lián)擁有一支富有激情的企業(yè)網(wǎng)站制作團隊,在互聯(lián)網(wǎng)網(wǎng)站建設(shè)行業(yè)深耕十載,專業(yè)且經(jīng)驗豐富。十載網(wǎng)站優(yōu)化營銷經(jīng)驗,我們已為上1000+中小企業(yè)提供了網(wǎng)站制作、成都網(wǎng)站設(shè)計解決方案,按需求定制制作,設(shè)計滿意,售后服務(wù)無憂。所有客戶皆提供一年免費網(wǎng)站維護!

一、概述

數(shù)據(jù)庫連接池一般由多個數(shù)據(jù)庫連接組成,允許多個應(yīng)用程序同時使用同一個數(shù)據(jù)庫連接。通常,連接池會提前創(chuàng)建一定數(shù)量的數(shù)據(jù)庫連接并緩存起來,應(yīng)用程序需要連接數(shù)據(jù)庫時,可以直接從連接池中取出數(shù)據(jù)庫連接使用,使用完畢后再將連接放回連接池中,以供其他應(yīng)用程序使用。這樣可以避免每次連接數(shù)據(jù)庫時重新創(chuàng)建數(shù)據(jù)庫連接的開銷,提高數(shù)據(jù)庫訪問效率。

二、連接池的設(shè)定

一個高效的數(shù)據(jù)庫連接池應(yīng)該具備以下特點:

1.充分利用數(shù)據(jù)庫連接

一個好的連接池應(yīng)該能夠更大程度地利用已經(jīng)創(chuàng)建的數(shù)據(jù)庫連接,避免過多的創(chuàng)建和銷毀連接的開銷。

2.最小化連接開銷

連接池應(yīng)該盡可能地最小化創(chuàng)建和銷毀連接的開銷。對于一些高級的連接池實現(xiàn),他們提供了預(yù)創(chuàng)建連接功能,并允許設(shè)置連接超時時間,這樣可以避免連接池中的連接長時間閑置。

3.最多支持的連接數(shù)

根據(jù)實際的應(yīng)用場景和硬件情況,合理設(shè)置連接池中的連接數(shù)量,以避免連接池中的連接被耗盡,導(dǎo)致應(yīng)用程序出現(xiàn)請求超時的情況。

4.連接池的獲取和釋放

連接池的獲取和釋放過程應(yīng)該盡可能地快速,避免等待時間過長。在程序中,應(yīng)該注意及時釋放連接,避免連接池中的連接被耗盡。

三、創(chuàng)建連接池

在Java語言中,常用的連接池實現(xiàn)有:DBCP、C0、Druid等。這些連接池實現(xiàn)可以集成在Java Web應(yīng)用程序中,方便開發(fā)者使用。

以C0為例,以下是創(chuàng)建連接池的一些基本步驟:

1.導(dǎo)入c3p0.jar包

在Java Web項目中,將c3p0.jar包復(fù)制到WEB-INF/lib目錄下。

2.創(chuàng)建配置文件

在WEB-INF/classes下創(chuàng)建c3p0-config.xml文件,內(nèi)容如下:

“`

com.mysql.jdbc.Driver

jdbc:mysql://localhost:3306/test_db

root

password

5

5

20

5

0

60

“`

3.獲取數(shù)據(jù)源

在Java Web項目中,可以使用以下代碼獲取數(shù)據(jù)源:

“`

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class DBUtil {

private ComboPooledDataSource dataSource;

public DBUtil() {

try {

dataSource = new ComboPooledDataSource();

dataSource.setDriverClass(“com.mysql.jdbc.Driver”);

dataSource.setJdbcUrl(“jdbc:mysql://localhost:3306/test_db”);

dataSource.setUser(“root”);

dataSource.setPassword(“password”);

} catch (Exception ex) {

ex.printStackTrace();

}

}

public Connection getConnection() throws SQLException{

return dataSource.getConnection();

}

public void releaseConnection(Connection connection) {

if(connection != null){

try {

connection.setAutoCommit(true);

connection.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

}

“`

4.使用連接池

在應(yīng)用程序中,可以使用以下代碼使用連接池:

“`

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

public class Test {

public static void mn(String[] args) {

Connection con = null;

PreparedStatement ps = null;

ResultSet rs = null;

try {

DBUtil dbutil = new DBUtil();

con = dbutil.getConnection();

ps = con.prepareStatement(“select * from user”);

rs = ps.executeQuery();

while (rs.next()) {

System.out.println(“Id: ” + rs.getInt(“id”) + “, Name: ” + rs.getString(“name”));

}

} catch (SQLException ex) {

ex.printStackTrace();

} finally {

if(rs != null){

try {

rs.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

if(ps != null){

try {

ps.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

if(con != null){

try {

dbutil.releaseConnection(con);

} catch (Exception e) {

e.printStackTrace();

}

}

}

}

}

“`

四、

連接池可以極大地提高應(yīng)用程序的數(shù)據(jù)庫訪問效率,避免重復(fù)創(chuàng)建和銷毀連接的開銷。本文介紹了如何快速創(chuàng)建一個高效的數(shù)據(jù)庫連接池,以及如何在Java Web應(yīng)用程序中使用連接池。在實際開發(fā)中,應(yīng)該根據(jù)具體的應(yīng)用場景和硬件情況,選擇適合自己的連接池實現(xiàn),并合理設(shè)置連接池參數(shù)。這樣才能保證應(yīng)用程序的穩(wěn)定性和高效性。

成都網(wǎng)站建設(shè)公司-創(chuàng)新互聯(lián)為您提供網(wǎng)站建設(shè)、網(wǎng)站制作、網(wǎng)頁設(shè)計及定制高端網(wǎng)站建設(shè)服務(wù)!

[高分]java方面的問題:請教高手db.properties連接池的用法

Tomcat5.0 與 5.5的配置有些不同,下面是5.5的配置.

1、配置庫文件:

將連接數(shù)據(jù)庫所要的jar文件拷貝到如下目錄:

${TOMCAT_HOME}$\common\lib

2、server.xml:

在Server.xml中加入以下內(nèi)容:

3、程序調(diào)用:

1、初始化命名空間上下文 ——> 2、(tomcat)查找J2EE的資源定位上下文(世廳java:comp/env)—檔告—> 3、查找在tomcat下的命名資源 ——> 4、DataSource ——> 5、Connection ——> 實例化Statement

過JNDI Datasource方式可以實現(xiàn)此功能,實現(xiàn)之后,只要鍵值不變則數(shù)據(jù)庫可以任意改變,而不用更改程序。

/*

連接數(shù)據(jù)庫,關(guān)閉數(shù)據(jù)庫

*/

package org.lxh.orm.db;

import java.sql.Connection;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.sql.DataSource;

public class DataBaseConnection {

// Tomcat連接

private final String CTXNAME = “java:comp/env”;

private final String JNDINAME = “jdbc/mssql”;

private Connection conn = null;

// 在構(gòu)造方法之中連接數(shù)據(jù)庫

public DataBaseConnection() {

try {

Context ctx = new InitialContext() ;

ctx = (Context)ctx.lookup(CTXNAME) ;

DataSource ds = (DataSource)ctx.lookup(JNDINAME) ;

conn = ds.getConnection() ;

} catch (Exception e) {

System.out.println(e);

}

}

// 取得連接

public Connection getConnection() {

return this.conn;

}

// 關(guān)閉連接

public void closeConnection() {

try {

this.conn.close();

} catch (Exception e) {

}

}

}

連接池用法JDBC

Java Servlet作為首選的服務(wù)器端數(shù)據(jù)處理技術(shù),正在迅速取代CGI腳本。Servlet超越CGI的優(yōu)勢之一在于,不僅多個請求可以共享公用資源,而且還可以在不同用戶請求之間保留持續(xù)數(shù)據(jù)。本文介紹一種充分發(fā)揮該特色的實用技術(shù),即數(shù)據(jù)庫連接池。

一、實現(xiàn)連接池的意義

動態(tài)Web站點往往用數(shù)據(jù)庫存儲的信息生成Web頁面,每一個頁面請求導(dǎo)致一次數(shù)據(jù)庫訪問。連接數(shù)據(jù)庫不僅要開銷一定的通訊和內(nèi)存資源,還必須完成用戶驗證、安全上下文配置這類任務(wù),因而往往成為最為耗時的操作。當(dāng)然,實際的連接時間開銷千變?nèi)f化,但1到2秒延遲并非不常見。如果某個基于數(shù)據(jù)庫的Web應(yīng)用只需建立一次初始連接,不同頁面請求能夠共享同一連接,就能獲得顯著的性能改善。

Servlet是一個Java類。Servlet引擎(它可能是Web服務(wù)軟件的一部分,也可能是一個獨立的附加模塊)在系統(tǒng)穗改冊啟動或Servlet之一次被請殲禪求時將該類裝入Java虛擬機并創(chuàng)建它的一個實例。不同用戶請求由同一Servlet實例的多個獨立線程處理。那些要求在不同請求之間持續(xù)有效的數(shù)據(jù)既可以用Servlet的實例變量來保存,也可以保存在獨立的輔助對象中。

用JDBC訪問數(shù)據(jù)庫首先要創(chuàng)建與數(shù)據(jù)庫之間的連接,獲得一個連接對象(Connection),由連接對象提供執(zhí)行SQL語句的方法。本文介紹的數(shù)據(jù)庫連接池包括一個管理類DBConnectionManager,負責(zé)提供與多個連接池對象(DBConnectionPool類)之間的接口。每一個連接池對象管理一組JDBC連接對象,每一個連接對象可以被任意數(shù)量的Servlet共享。

類DBConnectionPool提供以下功能:

1) 從連接池獲?。ɑ騽?chuàng)建)可用連接。

2) 把連接返回給連接池。

3) 在系統(tǒng)關(guān)閉時釋放所有資源,關(guān)閉所有連接。

此外, DBConnectionPool類還能夠處理無效連接(原來登記為可用的連接,由于某種原因不再可用,如超時,通訊問題),并能夠限制連接池中的連接總數(shù)不超過某個預(yù)定值。

管理類DBConnectionManager用于管理多個連接池對象,它提供以下功能:

1) 裝載和注冊JDBC驅(qū)動程序。

2) 根據(jù)在屬性文件中定義的屬性創(chuàng)建連接池對象。

3) 實現(xiàn)連接池名字與其實例之間的映射。

4) 跟蹤客戶程序?qū)B接池的引用猜宏,保證在最后一個客戶程序結(jié)束時安全地關(guān)閉所有連接池。

本文余下部分將詳細說明這兩個類,最后給出一個示例演示Servlet使用連接池的一般過程。

二、具體實現(xiàn)

DBConnectionManager.java程序清單如下:

001 import java.io.*;

002 import java.sql.*;

003 import java.util.*;

004 import java.util.Date;

005

006 /**

007 * 管理類DBConnectionManager支持對一個或多個由屬性文件定義的數(shù)據(jù)庫連接

008 * 池的訪問.客戶程序可以調(diào)用getInstance()方法訪問本類的唯一實例.

009 */

010 public class DBConnectionManager {

011 static private DBConnectionManager instance; // 唯一實例

012 static private int clients;

013

014 private Vector drivers = new Vector();

015 private PrintWriter log;

016 private Hashtable pools = new Hashtable();

017

018 /**

019 * 返回唯一實例.如果是之一次調(diào)用此方法,則創(chuàng)建實例

020 *

021 * @return DBConnectionManager 唯一實例

022 */

023 static synchronized public DBConnectionManager getInstance() {

024 if (instance == null) {

025 instance = new DBConnectionManager();

026 }

027 clients++;

028 return instance;

029 }

030

031 /**

032 * 建構(gòu)函數(shù)私有以防止其它對象創(chuàng)建本類實例

033 */

034 private DBConnectionManager() {

035 init();

036 }

037

038 /**

039 * 將連接對象返回給由名字指定的連接池

040 *

041 * @param name 在屬性文件中定義的連接池名字

042 * @param con 連接對象

043 */

044 public void freeConnection(String name, Connection con) {

045 DBConnectionPool pool = (DBConnectionPool) pools.get(name);

046 if (pool != null) {

047 pool.freeConnection(con);

048 }

049 }

050

051 /**

052 * 獲得一個可用的(空閑的)連接.如果沒有可用連接,且已有連接數(shù)小于更大連接數(shù)

053 * 限制,則創(chuàng)建并返回新連接

054 *

055 * @param name 在屬性文件中定義的連接池名字

056 * @return Connection 可用連接或null

057 */

058 public Connection getConnection(String name) {

059 DBConnectionPool pool = (DBConnectionPool) pools.get(name);

060 if (pool != null) {

061 return pool.getConnection();

062 }

063 return null;

064 }

065

066 /**

067 * 獲得一個可用連接.若沒有可用連接,且已有連接數(shù)小于更大連接數(shù)限制,

068 * 則創(chuàng)建并返回新連接.否則,在指定的時間內(nèi)等待其它線程釋放連接.

069 *

070 * @param name 連接池名字

071 * @param time 以毫秒計的等待時間

072 * @return Connection 可用連接或null

073 */

074 public Connection getConnection(String name, long time) {

075 DBConnectionPool pool = (DBConnectionPool) pools.get(name);

076 if (pool != null) {

077 return pool.getConnection(time);

078 }

079 return null;

080 }

081

082 /**

083 * 關(guān)閉所有連接,撤銷驅(qū)動程序的注冊

084 */

085 public synchronized void release() {

086 // 等待直到最后一個客戶程序調(diào)用

087 if (–clients != 0) {

088 return;

089 }

090

091 Enumeration allPools = pools.elements();

092 while (allPools.hasMoreElements()) {

093 DBConnectionPool pool = (DBConnectionPool) allPools.nextElement();

094 pool.release();

095 }

096 Enumeration allDrivers = drivers.elements();

097 while (allDrivers.hasMoreElements()) {

098 Driver driver = (Driver) allDrivers.nextElement();

099 try {

100 DriverManager.deregisterDriver(driver);

101 log(“撤銷JDBC驅(qū)動程序 ” + driver.getClass().getName()+”的注冊”);

102 }

103 catch (SQLException e) {

104 log(e, “無法撤銷下列JDBC驅(qū)動程序的注冊: ” + driver.getClass().getName());

105 }

106 }

107 }

108

109 /**

110 * 根據(jù)指定屬性創(chuàng)建連接池實例.

111 *

112 * @param props 連接池屬性

113 */

114 private void createPools(Properties props) {

115 Enumeration propNames = props.propertyNames();

116 while (propNames.hasMoreElements()) {

117 String name = (String) propNames.nextElement();

118 if (name.endsWith(“.url”)) {

119 String poolName = name.substring(0, name.lastIndexOf(“.”));

120 String url = props.getProperty(poolName + “.url”);

121 if (url == null) {

122 log(“沒有為連接池” + poolName + “指定URL”);

123 continue;

124 }

125 String user = props.getProperty(poolName + “.user”);

126 String password = props.getProperty(poolName + “.password”);

127 String maxconn = props.getProperty(poolName + “.maxconn”, “0”);

128 int max;

129 try {

130 max = Integer.valueOf(maxconn).intValue();

131 }

132 catch (NumberFormatException e) {

133 log(“錯誤的更大連接數(shù)限制: ” + maxconn + ” .連接池: ” + poolName);

134 max = 0;

135 }

136 DBConnectionPool pool =

137 new DBConnectionPool(poolName, url, user, password, max);

138 pools.put(poolName, pool);

139 log(“成功創(chuàng)建連接池” + poolName);

140 }

141 }

142 }

143

144 /**

145 * 讀取屬性完成初始化

146 */

147 private void init() {

148 InputStream is = getClass().getResourceAsStream(“/db.properties”);

149 Properties dbProps = new Properties();

150 try {

151 dbProps.load(is);

152 }

153 catch (Exception e) {

154 System.err.println(“不能讀取屬性文件. ” +

155 “請確保db.properties在CLASSPATH指定的路徑中”);

156 return;

157 }

158 String logFile = dbProps.getProperty(“l(fā)ogfile”, “DBConnectionManager.log”);

159 try {

160 log = new PrintWriter(new FileWriter(logFile, true), true);

161 }

162 catch (IOException e) {

163 System.err.println(“無法打開日志文件: ” + logFile);

164 log = new PrintWriter(System.err);

165 }

166 loadDrivers(dbProps);

167 createPools(dbProps);

168 }

169

170 /**

171 * 裝載和注冊所有JDBC驅(qū)動程序

172 *

173 * @param props 屬性

174 */

175 private void loadDrivers(Properties props) {

176 String driverClasses = props.getProperty(“drivers”);

177 StringTokenizer st = new StringTokenizer(driverClasses);

178 while (st.hasMoreElements()) {

179 String driverClassName = st.nextToken().trim();

180 try {

181 Driver driver = (Driver)

182 Class.forName(driverClassName).newInstance();

183 DriverManager.registerDriver(driver);

184 drivers.addElement(driver);

185 log(“成功注冊JDBC驅(qū)動程序” + driverClassName);

186 }

187 catch (Exception e) {

188 log(“無法注冊JDBC驅(qū)動程序: ” +

189 driverClassName + “, 錯誤: ” + e);

190 }

191 }

192 }

193

194 /**

195 * 將文本信息寫入日志文件

196 */

197 private void log(String msg) {

198 log.println(new Date() + “: ” + msg);

199 }

200

201 /**

202 * 將文本信息與異常寫入日志文件

203 */

204 private void log(Throwable e, String msg) {

205 log.println(new Date() + “: ” + msg);

206 e.printStackTrace(log);

207 }

208

209 /**

210 * 此內(nèi)部類定義了一個連接池.它能夠根據(jù)要求創(chuàng)建新連接,直到預(yù)定的最

211 * 大連接數(shù)為止.在返回連接給客戶程序之前,它能夠驗證連接的有效性.

212 */

213 class DBConnectionPool {

214 private int checkedOut;

215 private Vector freeConnections = new Vector();

216 private int maxConn;

217 private String name;

218 private String password;

219 private String URL;

220 private String user;

221

222 /**

223 * 創(chuàng)建新的連接池

224 *

225 * @param name 連接池名字

226 * @param URL 數(shù)據(jù)庫的JDBC URL

227 * @param user 數(shù)據(jù)庫帳號,或 null

228 * @param password 密碼,或 null

229 * @param maxConn 此連接池允許建立的更大連接數(shù)

230 */

231 public DBConnectionPool(String name, String URL, String user, String password,

232 int maxConn) {

233 this.name = name;

234 this.URL = URL;

235 this.user = user;

236 this.password = password;

237 this.maxConn = maxConn;

238 }

239

240 /**

241 * 將不再使用的連接返回給連接池

242 *

243 * @param con 客戶程序釋放的連接

244 */

245 public synchronized void freeConnection(Connection con) {

246 // 將指定連接加入到向量末尾

247 freeConnections.addElement(con);

248 checkedOut–;

249 notifyAll();

250 }

251

252 /**

253 * 從連接池獲得一個可用連接.如沒有空閑的連接且當(dāng)前連接數(shù)小于更大連接

254 * 數(shù)限制,則創(chuàng)建新連接.如原來登記為可用的連接不再有效,則從向量刪除之,

255 * 然后遞歸調(diào)用自己以嘗試新的可用連接.

256 */

257 public synchronized Connection getConnection() {

258 Connection con = null;

259 if (freeConnections.size() > 0) {

260 // 獲取向量中之一個可用連接

261 con = (Connection) freeConnections.firstElement();

262 freeConnections.removeElementAt(0);

263 try {

264 if (con.isClosed()) {

265 log(“從連接池” + name+”刪除一個無效連接”);

266 // 遞歸調(diào)用自己,嘗試再次獲取可用連接

267 con = getConnection();

268 }

269 }

270 catch (SQLException e) {

271 log(“從連接池” + name+”刪除一個無效連接”);

272 // 遞歸調(diào)用自己,嘗試再次獲取可用連接

273 con = getConnection();

274 }

275 }

276 else if (maxConn == 0 || checkedOut = timeout) {

300 // wait()返回的原因是超時

301 return null;

302 }

303 }

304 return con;

305 }

306

307 /**

308 * 關(guān)閉所有連接

309 */

310 public synchronized void release() {

311 Enumeration allConnections = freeConnections.elements();

312 while (allConnections.hasMoreElements()) {

313 Connection con = (Connection) allConnections.nextElement();

314 try {

315 con.close();

316 log(“關(guān)閉連接池” + name+”中的一個連接”);

317 }

318 catch (SQLException e) {

319 log(e, “無法關(guān)閉連接池” + name+”中的連接”);

320 }

321 }

322 freeConnections.removeAllElements();

323 }

324

325 /**

326 * 創(chuàng)建新的連接

327 */

328 private Connection newConnection() {

329 Connection con = null;

330 try {

331 if (user == null) {

332 con = DriverManager.getConnection(URL);

333 }

334 else {

335 con = DriverManager.getConnection(URL, user, password);

336 }

337 log(“連接池” + name+”創(chuàng)建一個新的連接”);

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行實現(xiàn),它表示指向某個數(shù)據(jù)庫的連接池。數(shù)據(jù)庫由JDBC URL標(biāo)識。一個JDBC URL由三部分組成:協(xié)議標(biāo)識(總是jdbc),驅(qū)動程序標(biāo)識(如 odbc、idb、oracle等),數(shù)據(jù)庫標(biāo)識(其格式依賴于驅(qū)動程序)。例如,jdbcdbc:demo,即是一個指向demo數(shù)據(jù)庫的JDBC URL,而且訪問該數(shù)據(jù)庫要使用JDBC-ODBC驅(qū)動程序。每個連接池都有一個供客戶程序使用的名字以及可選的用戶帳號、密碼、更大連接數(shù)限制。如果Web應(yīng)用程序所支持的某些數(shù)據(jù)庫操作可以被所有用戶執(zhí)行,而其它一些操作應(yīng)由特別許可的用戶執(zhí)行,則可以為兩類操作分別定義連接池,兩個連接池使用相同的JDBC URL,但使用不同的帳號和密碼。

類DBConnectionPool的建構(gòu)函數(shù)需要上述所有數(shù)據(jù)作為其參數(shù)。如222至238行所示,這些數(shù)據(jù)被保存為它的實例變量:

如252至283行、285至305行所示, 客戶程序可以使用DBConnectionPool類提供的兩個方法獲取可用連接。兩者的共同之處在于:如連接池中存在可用連接,則直接返回,否則創(chuàng)建新的連接并返回。如果沒有可用連接且已有連接總數(shù)等于更大限制數(shù),之一個方法將直接返回null,而第二個方法將等待直到有可用連接為止。

所有的可用連接對象均登記在名為freeConnections的向量(Vector)中。如果向量中有多于一個的連接,getConnection()總是選取之一個。同時,由于新的可用連接總是從尾部加入向量,從而使得數(shù)據(jù)庫連接由于長時間閑置而被關(guān)閉的風(fēng)險減低到最小程度。

之一個getConnection()在返回可用連接給客戶程序之前,調(diào)用了isClosed()方法驗證連接仍舊有效。如果該連接被關(guān)閉或觸發(fā)異常,getConnection()遞歸地調(diào)用自己以嘗試獲取另外的可用連接。如果在向量freeConnections中不存在任何可用連接,getConnection()方法檢查是否已經(jīng)指定更大連接數(shù)限制。如已經(jīng)指定,則檢查當(dāng)前連接數(shù)是否已經(jīng)到達極限。此處maxConn為0表示沒有限制。如果沒有指定更大連接數(shù)限制或當(dāng)前連接數(shù)小于該值,該方法嘗試創(chuàng)建新的連接。如創(chuàng)建成功,則增加已使用連接的計數(shù)并返回,否則返回空值。

如325至345行所示,創(chuàng)建新連接由newConnection()方法實現(xiàn)。創(chuàng)建過程與是否已經(jīng)指定數(shù)據(jù)庫帳號、密碼有關(guān)。

JDBC的DriverManager類提供多個getConnection()方法,這些方法要用到JDBC URL與其它一些參數(shù),如用戶帳號和密碼等。DriverManager將使用指定的JDBC URL確定適合于目標(biāo)數(shù)據(jù)庫的驅(qū)動程序及建立連接。

在285至305行實現(xiàn)的第二個getConnection()方法需要一個以毫秒為單位的時間參數(shù),該參數(shù)表示客戶程序能夠等待的最長時間。建立連接的具體操作仍舊由之一個getConnection()方法實現(xiàn)。

該方法執(zhí)行時先將startTime初始化為當(dāng)前時間。在while循環(huán)中嘗試獲得一個連接。如果失敗,則以給定的時間值為參數(shù)調(diào)用wait()。wait()的返回可能是由于其它線程調(diào)用notify()或notifyAll(),也可能是由于預(yù)定時間已到。為找出wait()返回的真正原因,程序用當(dāng)前時間減開始時間(startTime),如差值大于預(yù)定時間則返回空值,否則再次調(diào)用getConnection()。

把空閑的連接登記到連接池由240至250行的freeConnection()方法實現(xiàn),它的參數(shù)為返回給連接池的連接對象。該對象被加入到freeConnections向量的末尾,然后減少已使用連接計數(shù)。調(diào)用notifyAll()是為了通知其它正在等待可用連接的線程。

許多Servlet引擎為實現(xiàn)安全關(guān)閉提供多種方法。數(shù)據(jù)庫連接池需要知道該事件以保證所有連接能夠正常關(guān)閉。DBConnectionManager類負協(xié)調(diào)整個關(guān)閉過程,但關(guān)閉連接池中所有連接的任務(wù)則由DBConnectionPool類負責(zé)。在307至323行實現(xiàn)的release()方法供DBConnectionManager調(diào)用。該方法遍歷freeConnections向量并關(guān)閉所有連接,然后從向量中刪除這些連接。

四、類DBConnectionManager 說明

該類只能創(chuàng)建一個實例,其它對象能夠調(diào)用其靜態(tài)方法(也稱為類方法)獲得該唯一實例的引用。如031至036行所示,DBConnectionManager類的建構(gòu)函數(shù)是私有的,這是為了避免其它對象創(chuàng)建該類的實例。

DBConnectionManager類的客戶程序可以調(diào)用getInstance()方法獲得對該類唯一實例的引用。如018至029行所示,類的唯一實例在getInstance()方法之一次被調(diào)用期間創(chuàng)建,此后其引用就一直保存在靜態(tài)變量instance中。每次調(diào)用getInstance()都增加一個DBConnectionManager的客戶程序計數(shù)。即,該計數(shù)代表引用DBConnectionManager唯一實例的客戶程序總數(shù),它將被用于控制連接池的關(guān)閉操作。

該類實例的初始化工作由146至168行之間的私有方法init()完成。其中 getResourceAsStream()方法用于定位并打開外部文件。外部文件的定位方法依賴于類裝載器的實現(xiàn)。標(biāo)準(zhǔn)的本地類裝載器查找操作總是開始于類文件所在路徑,也能夠搜索CLASSPATH中聲明的路徑。db.properties是一個屬性文件,它包含定義連接池的鍵-值對??晒┒x的公用屬性如下:

drivers 以空格分隔的JDBC驅(qū)動程序類列表

logfile 日志文件的絕對路徑

其它的屬性和特定連接池相關(guān),其屬性名字前應(yīng)加上連接池名字:

.url 數(shù)據(jù)庫的 JDBC URL

.maxconn 允許建立的更大連接數(shù),0表示沒有限制

.user 用于該連接池的數(shù)據(jù)庫帳號

.password 相應(yīng)的密碼

其中url屬性是必需的,而其它屬性則是可選的。數(shù)據(jù)庫帳號和密碼必須合法。用于Windows平臺的db.properties文件示例如下:

drivers=sun.jdbc.odbc.JdbcOdbcDriver jdbc.idbDriver

logfile=D:\user\src\java\DBConnectionManager\log.txt

idb.url=jdbc:idb:c:\local\javawebserver1.1\db\db.prp

idb.maxconn=2

access.url=jdbcdbc:demo

access.user=demo

access.password=demopw

注意在Windows路徑中的反斜杠必須輸入2個,這是由于屬性文件中的反斜杠同時也是一個轉(zhuǎn)義字符。

init()方法在創(chuàng)建屬性對象并讀取db.properties文件之后,就開始檢查logfile屬性。如果屬性文件中沒有指定日志文件,則默認為當(dāng)前目錄下的DBConnectionManager.log文件。如日志文件無法使用,則向System.err輸出日志記錄。

裝載和注冊所有在drivers屬性中指定的JDBC驅(qū)動程序由170至192行之間的loadDrivers()方法實現(xiàn)。該方法先用StringTokenizer將drivers屬性值分割為對應(yīng)于驅(qū)動程序名稱的字符串,然后依次裝載這些類并創(chuàng)建其實例,最后在 DriverManager中注冊該實例并把它加入到一個私有的向量drivers。向量drivers將用于關(guān)閉服務(wù)時從DriverManager取消所有JDBC 驅(qū)動程序的注冊。

init()方法的最后一個任務(wù)是調(diào)用私有方法createPools()創(chuàng)建連接池對象。如109至142行所示,createPools()方法先創(chuàng)建所有屬性名字的枚舉對象(即Enumeration對象,該對象可以想象為一個元素系列,逐次調(diào)用其nextElement()方法將順序返回各元素),然后在其中搜索名字以“.url”結(jié)尾的屬性。對于每一個符合條件的屬性,先提取其連接池名字部分,進而讀取所有屬于該連接池的屬性,最后創(chuàng)建連接池對象并把它保存在實例變量pools中。散列表(Hashtable類 )pools實現(xiàn)連接池名字到連接池對象之間的映射,此處以連接池名字為鍵,連接池對象為值。

為便于客戶程序從指定連接池獲得可用連接或?qū)⑦B接返回給連接池,類DBConnectionManager提供了方法getConnection()和freeConnection()。所有這些方法都要求在參數(shù)中指定連接池名字,具體的連接獲取或返回操作則調(diào)用對應(yīng)的連接池對象完成。它們的實現(xiàn)分別在051至064行、066至080行、038至049行。

如082至107行所示,為實現(xiàn)連接池的安全關(guān)閉,DBConnectionManager提供了方法release()。在上面我們已經(jīng)提到,所有DBConnectionManager的客戶程序都應(yīng)該調(diào)用靜態(tài)方法getInstance()以獲得該管理器的引用,此調(diào)用將增加客戶程序計數(shù)??蛻舫绦蛟陉P(guān)閉時調(diào)用release()可以遞減該計數(shù)。當(dāng)最后一個客戶程序調(diào)用release(),遞減后的引用計數(shù)為0,就可以調(diào)用各個連接池的release()方法關(guān)閉所有連接了。管理類release()方法最后的任務(wù)是撤銷所有JDBC驅(qū)動程序的注冊。

五、Servlet使用連接池示例

Servlet API所定義的Servlet生命周期類如:

1) 創(chuàng)建并初始化Servlet(init()方法)。

2) 響應(yīng)客戶程序的服務(wù)請求(service()方法)。

3) Servlet終止運行,釋放所有資源(destroy()方法)。

本例演示連接池應(yīng)用,上述關(guān)鍵步驟中的相關(guān)操作為:

1) 在init(),用實例變量connMgr 保存調(diào)用DBConnectionManager.getInstance()所返回的引用。

2) 在service(),調(diào)用getConnection(),執(zhí)行數(shù)據(jù)庫操作,用freeConnection()將連接返回給連接池。

3) 在destroy(),調(diào)用release()關(guān)閉所有連接,釋放所有資源。

示例程序清單如下:

import java.io.*;

import java.sql.*;

import javax.servlet.*;

import javax.servlet.http.*;

public class TestServlet extends HttpServlet {

private DBConnectionManager connMgr;

public void init(ServletConfig conf) throws ServletException {

super.init(conf);

connMgr = DBConnectionManager.getInstance();

}

public void service(HttpServletRequest req, HttpServletResponse res)

throws IOException {

res.setContentType(“text/html”);

PrintWriter out = res.getWriter();

Connection con = connMgr.getConnection(“idb”);

if (con == null) {

out.println(“不能獲取數(shù)據(jù)庫連接.”);

return;

}

ResultSet rs = null;

ResultSetMetaData md = null;

Statement stmt = null;

try {

stmt = con.createStatement();

rs = stmt.executeQuery(“SELECT * FROM EMPLOYEE”);

md = rs.getMetaData();

out.println(“職工數(shù)據(jù)”);

while (rs.next()) {

out.println(“”);

for (int i = 1; i

out.print(rs.getString(i) + “, “);

}

}

stmt.close();

rs.close();

}

catch (SQLException e) {

e.printStackTrace(out);

}

connMgr.freeConnection(“i

Properties文件,其實僅僅是鍵值對配置文件。下面介紹如何讀取properties文件以及如何用JDBC連接數(shù)據(jù)庫。

1.:

比如你的properties文件叫做mysql.properties,并且放在com.test包下:

java.net.URL url = Thread.currentThread().getContextClassLoader().getResource(“com/test/mysql.properties”);

注意路徑和包名一致,在你的提問中,我們知道是放在classes目錄下,則直接

…getResource(“mysql.properties”); 即可

Properties p = new Properties();

p.load(url.openStream()); //由URL載入配置文件

這樣你就得到一個Properties的實例

2. :

比如你要讀取drivers的值,只需:

String theDriver = p.get(“drivers”);

根據(jù)配置文件,這樣你就得到了”org.gjt.mm.mysql.Driver”

3.

首先你要保證你有MySQL的Jdbc驅(qū)動程序,即包含org.gjt.mm.mysql.Driver的jar包,并放在應(yīng)兆檔舉用的classpath里。你可以搜索一下,很多地方有下的:

mysql-connector-java-3.0.15-ga-bin.jar

然后用同樣的方法得到url, mysql.user, mysql.password的值,比如分別為

url, user, pass

然后建立連接:

Class.forName(“com.mysql.jdbc.Driver”);

java.sql.Connection conn = java.sql.DriverManager.getConnection(url, user, pass);

如果不出意外,你就得到連接數(shù)據(jù)庫的Connection了,注意用完了別忘了關(guān)啊。(conn.close();)

4.

properties文件只是一個鍵-值對的配置文件(而且鍵和值都是可以自己寫的,并沒有固定格式,要看程序需求),從它“本身”只能得到鍵對應(yīng)的值。具體這個值用來干什么,那是程序的事情。比如logfile和maxconn,我只能猜是用來處理log和建立連接池時標(biāo)記更大連接數(shù)的,具體怎么實現(xiàn),需要研究它的代碼族碧,因為并沒有固定寫法。(而上面用jdbc建立連接的寫法是固定的)。因為你只給了個properties文件,所以我只能寫一個jdbc的連接程序,但這并不是連接池的實現(xiàn)。

這里有個連接池的實現(xiàn),你可以參考下:

希望對你蠢戚有所幫助!

mysql.url=jdbc:

//數(shù)據(jù)庫為mysql 服務(wù)器 //默認談戚敗網(wǎng)頁編碼為GBK

useUnicode=true&characterEncoding =gbk

mysql.maxconn=1000 //更大連接數(shù)

mysql.user=root //數(shù)據(jù)庫帳號

mysql.password= //數(shù)據(jù)庫密碼

drivers=org.gjt.mm.mysql.Driver

//MySQL的驅(qū)含顫動文仔野件

在Windows路徑中的反斜杠必須輸消慧入2個,這是由于屬性文件中的反斜杠同時也是一個轉(zhuǎn)義字符。

init()方法在創(chuàng)建屬性對象并讀取db.properties文件之后,就開始檢查logfile屬性。如果屬性文件中沒有指定日志文件,則默認為當(dāng)前目錄下的DBConnectionManager.log文件。如日志文件無法使用,則向System.err輸出日志記錄。

裝載和注冊所有在者含drivers屬性中指定的JDBC驅(qū)動程序由170至192行之間的loadDrivers()方法實現(xiàn)。該方法先用StringTokenizer將drivers屬性值分割為對應(yīng)于驅(qū)動程序名稱的字符串,然后依次裝載這些類并創(chuàng)建其實例,最后在 DriverManager中注冊該實例并把它加入到一個私有的向量drivers。向量drivers將用于關(guān)閉服務(wù)時從DriverManager取消所有JDBC 驅(qū)動程序的注冊。

關(guān)于c 創(chuàng)建數(shù)據(jù)庫連接池的介紹到此就結(jié)束了,不知道你從中找到你需要的信息了嗎 ?如果你還想了解更多這方面的信息,記得收藏關(guān)注本站。

創(chuàng)新互聯(lián)(cdcxhl.com)提供穩(wěn)定的云服務(wù)器,香港云服務(wù)器,BGP云服務(wù)器,雙線云服務(wù)器,高防云服務(wù)器,成都云服務(wù)器,服務(wù)器托管。精選鉅惠,歡迎咨詢:028-86922220。


當(dāng)前題目:快速創(chuàng)建高效的數(shù)據(jù)庫連接池(c創(chuàng)建數(shù)據(jù)庫連接池)
URL鏈接:http://www.dlmjj.cn/article/cceooso.html