快捷導(dǎo)航

mysql數(shù)據(jù)庫(kù)連接池配置教程

更新時(shí)間：2012年11月26日 10:29:28 作者：

在與數(shù)據(jù)庫(kù)進(jìn)行連接的時(shí)候，會(huì)牽扯到數(shù)據(jù)庫(kù)連接池的配置,本文將詳細(xì)介紹mysql數(shù)據(jù)庫(kù)連接池配置,需要了解跟多的朋友可以參考下

第一步：寫javabean

復(fù)制代碼代碼如下:

 
package withouttears.jdbc.db; 
import java.util.HashMap; 
import java.sql.*; 
//JNDI有兩個(gè)核心接口Context和DirContext， 
//Context中包含了基本的名字操作，而DirContext則將這些操作擴(kuò)展到目錄服務(wù)。 
import javax.naming.Context; 
import javax.naming.InitialContext; 
//數(shù)據(jù)庫(kù)資源的連接工廠是javax.sql.DataSource對(duì)象， 
//它可以創(chuàng)建java.sql.Connection數(shù)據(jù)庫(kù)連接對(duì)象。 
import javax.sql.DataSource; 
//目前您可以從Java開發(fā)者連接（http://java.sun.com/products/jdbc/download.html#rowsetcobundle1_0） 
//下載CachedRowSet的實(shí)現(xiàn)。下載并解壓縮安裝文件后，將"rowset.jar"文件放到您的類目錄下。 
//CachedRowSet在sun.jdbc.rowset包中。 
import sun.jdbc.rowset.CachedRowSet; 
/** 
* 作者：wiThouTTears 
* 時(shí)間：2006-12-13 
* */ 
public class Database { 
/**************************************************************/ 
/* 函數(shù)：localhost 
* 功能：建立連接池 
* */ 
private static DataSource localhost(){ 
DataSource ds=null; 
//在HashMap中通過(guò)get()來(lái)獲取value，通過(guò)put()來(lái)插入value， 
//ContainsKey()則用來(lái)檢驗(yàn)對(duì)象是否已經(jīng)存在 
HashMap<Object,Object> cachedDs=new HashMap<Object,Object> (); 
if(cachedDs.containsKey("ds"))//取出空閑狀態(tài)的數(shù)據(jù)庫(kù)連接 
{ 
/* 在DataSource中事先建立了多個(gè)數(shù)據(jù)庫(kù)連接， 
* 這些數(shù)據(jù)庫(kù)連接保存在連接池(Connect Pool)中。 
* Java程序訪問(wèn)數(shù)據(jù)庫(kù)時(shí)，只需要從連接池中取出空閑狀態(tài)的數(shù)據(jù)庫(kù)連接； 
* 當(dāng)程序訪問(wèn)數(shù)據(jù)庫(kù)結(jié)束，再將數(shù)據(jù)庫(kù)連接放回連接池。 
* */ 
ds = (DataSource)cachedDs.get("ds"); 
} 
else 
try 
{ 
/*在javax.naming包中提供了Context接口， 
* 該接口提供了將對(duì)象和名字綁定，以及通過(guò)名字檢索對(duì)象的方法。 
* */ 
Context initCtx = new InitialContext(); 
//lookup(String name)：返回與指定的名字綁定的對(duì)象,獲得數(shù)據(jù)庫(kù)連接工廠 
ds = (DataSource)initCtx.lookup("java:comp/env/jdbc/testdb"); 
cachedDs.put("ds", ds); 
} 
catch(Exception e) 
{ 
e.printStackTrace(); 
} 
return ds; 
} 
/**************************************************************/ 
/* 函數(shù)：getConnection 
* 功能：庫(kù)的連接 
* */ 
private static Connection getConnection(){ 
Connection conn = null; 
try 
{ 
DataSource ds = localhost(); 
conn = ds.getConnection(); 
} 
catch(Exception e) 
{ 
e.printStackTrace(); 
} 
return conn; 
} 
/**************************************************************/ 
/* 函數(shù)：close 
* 功能：關(guān)閉連接 
* */ 
private static void close(Connection conn) 
{ 
try 
{ 
if(conn != null) 
conn.close(); 
} 
catch(SQLException e) 
{ 
e.printStackTrace(); 
} 
} 
/**************************************************************/ 
/* 函數(shù)：executeQuery 
* 功能：數(shù)據(jù)查詢 
* */ 
public static CachedRowSet executeQuery(String sql) 
{ 
Connection conn=null; 
CachedRowSet rs=null; 
try{ 
rs=new CachedRowSet(); 
conn=getConnection(); 
Statement stmt=conn.createStatement(); 
ResultSet rs1=stmt.executeQuery(sql); 
rs.populate(rs1); 
} 
catch(Exception e) 
{ 
//System.out.println(e.toString()); 
} 
finally{ 
try 
{ 
conn.close(); 
} 
catch(Exception ex) 
{} 
} return rs; 
} 
/**************************************************************/ 
/* 函數(shù)：executeUpdate 
* 功能：數(shù)據(jù)更新（添加/更改/刪除） 
* */ 
public static boolean executeUpdate(String sql) 
{ 
boolean bl; 
bl = false; 
Connection conn = getConnection(); 
try 
{ 
Statement stmt = conn.createStatement(); 
if(stmt.executeUpdate(sql) > 0) 
stmt.close(); 
bl = true; 
} 
catch(SQLException e) 
{ 
} 
finally 
{ 
close(conn); 
} 
return bl; 
} 
/**************************************************************/ 
} 

編譯得到withouttears/db/Database.class并放到E:/MyWorkSpace/test/WEB-INF/classes下，即E:/MyWorkSpace/test/WEB-INF/classes/withouttears/db/Database.class,注意別弄錯(cuò)了。
第二步：配置Tomcat（我用是Tomcat 5.5.7）
1. 在C:/Program Files/Tomcat 5.5.7/conf/Catalina/localhost下新建一個(gè)test.xml,內(nèi)容如下： <Context docBase="E:/MyWorkSpace/test" path="/test"></Context>
注：docBase為你的web文件所在地，我用的是E:/MyWorkSpace/test。path可寫可不寫，但在Linux下必須寫上，Windows下不寫我測(cè)試可以用，最好寫上。這里的test.xml指定的文件夾不像我們平時(shí)用的那樣在C:/Program Files/Tomcat 5.5.7/webapps/test,不過(guò)目的一樣都是表示用http://localhost:8080/test/來(lái)訪問(wèn)，相當(dāng)于IIS下的虛擬目錄，可以是任意的。
2. 在C:/Program Files/Tomcat 5.5.7/conf/下建立context.xml，在E:/MyWorkSpace/test下新建WEB-INF/web.xml。
context.xml

復(fù)制代碼代碼如下:

 
<!-- The contents of this file will be loaded for each web application --> 
<Context> 
<!-- Default set of monitored resources --> 
<WatchedResource>WEB-INF/web.xml</WatchedResource> 
<WatchedResource>META-INF/context.xml</WatchedResource> 
<!-- Uncomment this to disable session persistence across Tomcat restarts --> 
<!-- 
<Manager pathname="" /> 
--> 
<Resource name="jdbc/testdb" 
auth="Container" 
type="javax.sql.DataSource" 
driverClassName="com.mysql.jdbc.Driver" 
url="jdbc:mysql://localhost/mytestdb" 
username="root" 
password="157744375" 
maxActive="100" 
maxIdle="30" 
maxWait="10000" 
/> 
</Context> 

注: 鏈接池配置文件,這樣我們就可以用第一步寫的Javabean類Database中的localhost()函數(shù)來(lái)讀取這個(gè)content.xml中的jdbc/testdb名稱
web.xml

復(fù)制代碼代碼如下:

 
<?xml version="1.0" encoding="gbk"?> 
<web-app id="WebApp_ID" version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd"> 
<display-name> 
test</display-name> 
<welcome-file-list> 
<welcome-file>test.jsp</welcome-file> 
</welcome-file-list> 
<!-- JSPC servlet mappings start --> 
<!-- JSPC servlet mappings end --> 
</web-app> 

注: web.xml放web的默認(rèn)主頁(yè)(如:test.jsp或者index.jsp)和程序中要用到servlet的映射,不管它我們這里用不到。
第三步：寫test.jsp

復(fù)制代碼代碼如下:

 
<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%> 
<%@page import="java.sql.*"%> 
<%@page import="withouttears.jdbc.db.*"%> 
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"> 
<html> 
<head> 
<meta http-equiv="Content-Type" content="text/html; charset=gbk"> 
<title>Insert title</title> 
</head> 
<body> 
<% 
String sql=null; 
sql="select * from table_test"; 
ResultSet rs=Database.executeQuery(sql); 
try{ 
while(rs.next()){ 
%> 
姓名：<%=rs.getString("name")%><br> 
電話：<%=rs.getString("mobile")%><br> 
<%}}catch(Exception e){} %> 
</body> 
</html> 