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