在JSP中連接到Oracle一般有2種方式：
1、Oracle JDBC的oci8方式
2、Oracle JDBC的thin方式
我比較喜歡第2種，因?yàn)閃EB發(fā)布服務(wù)器與數(shù)據(jù)庫(kù)服務(wù)器一般都不會(huì)放在同一臺(tái)電腦中，而在使用thin方式連接時(shí)，WEB服務(wù)器端無(wú)須安裝oracle的客戶端。
在動(dòng)手先代碼之前，我們先把環(huán)境配置妥善。先從安裝了Oracle的數(shù)據(jù)庫(kù)服務(wù)器中，找到Oracle安裝目錄，然后將該目錄下的jdbc\lib\classes12.jar文件拷貝到WEB發(fā)布服務(wù)器的某個(gè)目錄。假設(shè)就直接放在C:\根目錄下吧，然后把該路徑添加到‘系統(tǒng)--高級(jí)--環(huán)境變量’中變量名為‘CLASSPATH’的值中，如：D:\Program Files\SQLLIB\java\db2java.zip;D:\Program Files\SQLLIB\java\runtime.zip;c:classes12.jar; 也就是讓java能夠找到這個(gè)包。
配置好環(huán)境后，我們就開(kāi)始開(kāi)始動(dòng)手寫(xiě)代碼了。關(guān)于數(shù)據(jù)庫(kù)連接的代碼，應(yīng)該寫(xiě)個(gè)專門(mén)的連接類來(lái)調(diào)用，沒(méi)必要想網(wǎng)絡(luò)上有些文章那樣，直接寫(xiě)到JSP的代碼中。
關(guān)于連接的代碼很簡(jiǎn)單
private Connection newConnection(String user,String password) {
Connection con = null;
try {
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
con = DriverManager.getConnection (“jdbc:oracle:thin:@192.168.96.1:1521:oracle9i”,user,password);
}
catch (SQLException e) {
return null;
}
return con;
} |
如果帳號(hào)密碼沒(méi)有錯(cuò)，那這個(gè)函數(shù)就應(yīng)該能返回個(gè)可用的連接。但如此簡(jiǎn)單的連接在一個(gè)項(xiàng)目中使用，是遠(yuǎn)遠(yuǎn)達(dá)不到效果的。我們可以在這個(gè)數(shù)據(jù)庫(kù)連接類中加入更多的功能，如連接池等等。下面我就把該數(shù)據(jù)庫(kù)連接類的代碼詳細(xì)的列出來(lái)，大家可以參考參考。
/*
* @Title 公司網(wǎng)站
* @Author: zf
* @Version 1.0
* @Memo:定義數(shù)據(jù)庫(kù)連接及其數(shù)據(jù)庫(kù)連接池等
*/
package com.kingson.db;
import java.io.*;
import java.sql.*;
import java.util.*;
import java.util.Date;
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)建本類實(shí)例
*/
private DBConnectionManager() {
init();
}
/**
* 將連接對(duì)象返回給由名字指定的連接池
*
* @param name 在屬性文件中定義的連接池名字
* @param con 連接對(duì)象
*/
public void freeConnection(String name, Connection con) {
DBConnectionPool pool = (DBConnectionPool) pools.get(name);
if (pool != null) {
pool.freeConnection(con);
}
}
/**
* 獲得一個(gè)可用的(空閑的)連接.如果沒(méi)有可用連接,且已有連接數(shù)小于最大連接數(shù)
* 限制,則創(chuàng)建并返回新連接
*
* @param name 在屬性文件中定義的連接池名字
* @return Connection 可用連接或null
*/
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)等待其它線程釋放連接.
*
* @param name 連接池名字
* @param time 以毫秒計(jì)的等待時(shí)間
* @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è)
*/
public synchronized void release() {
// 等待直到最后一個(gè)客戶程序調(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 連接池屬性
*/
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 dbip = props.getProperty(poolName + ".db_ip", "192.168.96.1");
String dbport = props.getProperty(poolName + ".db_port", "1521");
String dbuid = props.getProperty(poolName + ".db_uid", "ORACLE9I");
String maxconn = props.getProperty(poolName + ".maxconn", "0");
//連接信息
String dbInfo = user + "/" + password + "@" + dbip + ":" + dbport + ":" + dbuid;
int max;
try {
max = Integer.valueOf(maxconn).intValue();
}
catch (NumberFormatException e) {
log("錯(cuò)誤的最大連接數(shù)限制: " + maxconn + " .連接池: " + poolName);
max = 0;
}
DBConnectionPool pool = new DBConnectionPool(poolName, url,dbInfo, max);
pools.put(poolName, pool);
log("成功創(chuàng)建連接池" + poolName);
}
}
}
|