小菜毛毛技術(shù)分享

          與大家共同成長

            BlogJava :: 首頁 :: 聯(lián)系 :: 聚合  :: 管理
            164 Posts :: 141 Stories :: 94 Comments :: 0 Trackbacks
          在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)該能返回個可用的連接。但如此簡單的連接在一個項目中使用,是遠遠達不到效果的。我們可以在這個數(shù)據(jù)庫連接類中加入更多的功能,如連接池等等。下面我就把該數(shù)據(jù)庫連接類的代碼詳細的列出來,大家可以參考參考。

          /*
          * @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);
          }
          }
          }
          posted on 2010-02-23 15:40 小菜毛毛 閱讀(783) 評論(0)  編輯  收藏 所屬分類: J2EE相關(guān)技術(shù)與框架
          主站蜘蛛池模板: 额济纳旗| 潍坊市| 兴化市| 阿拉善右旗| 射阳县| 滦南县| 喜德县| 刚察县| 大厂| 伊宁县| 佛学| 察哈| 留坝县| 武安市| 福海县| 五常市| 岢岚县| 万荣县| 加查县| 岚皋县| 西峡县| 福安市| 中宁县| 娄底市| 绥化市| 澄江县| 赣州市| 华亭县| 灵宝市| 会泽县| 高阳县| 胶州市| 南充市| 石景山区| 咸宁市| 文山县| 福贡县| 都匀市| 酒泉市| 定结县| 丰顺县|