connoracle.java

基于JAVAJSP的网上书店系统需要的下载 希望对大家有用

package com.timer.db;

/**
 *  Connect Oracle
 *  ConnOracle.java
 */

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
//import javax.sql.DataSource;
//import javax.naming.Context;
//import javax.naming.InitialContext;
//import javax.naming.NamingException;
import java.lang.ClassNotFoundException;
import java.sql.DriverManager;

public class ConnOracle {
  // DataSource dataSource = null;
  Connection conn = null;
  ResultSet resultSet = null;
  
  // connection Access
  private String sDriver = "sun.jdbc.odbc.JdbcOdbcDriver";
  private String sUrl = "jdbc:odbc:fns";
  
  public ConnOracle() {
    // 获得连接池
   /** try {
      Context ctx = new InitialContext();
      Context initCtx = (Context)ctx.lookup("java:comp/env");
      dataSource = (DataSource)initCtx.lookup("jdbc/oracle");
    } catch(NamingException ne) {
      System.out.println("Datasource Exception: " + ne.getMessage());
    } */
    
    try {
    	  Class.forName(sDriver);
    	} catch (ClassNotFoundException cnfe) {
    		System.out.println("Class not found " + cnfe.getMessage());
    	}
  }

  // 查询数据方法executeQuery()
  public ResultSet executeQuery(String sql) {
    try {
      //conn = dataSource.getConnection();
      conn = DriverManager.getConnection(sUrl); 
      PreparedStatement pStatement = conn.prepareStatement(sql);

      resultSet = pStatement.executeQuery();
    } catch(SQLException sqle) {
      System.out.println("Query Exception: " + sqle.getMessage());
    } 
    return resultSet;
  }

  // 更新数据方法executeUpdate()
  public int executeUpdate(String sql) {
    int iResult = 0;
    try {
      //conn = dataSource.getConnection();
      conn = DriverManager.getConnection(sUrl); 
      PreparedStatement pStatement = conn.prepareStatement(sql);
      iResult = pStatement.executeUpdate();
    } catch(SQLException sqle) {
      System.out.println("Update Exception: " + sqle.getMessage());
    }
    return iResult;
  }

  // 关闭连接池
  public void closeConnection() {
    try {
      if(resultSet!=null) {
        resultSet.close();
      }
    } catch (SQLException sqle) {
      System.out.println("Close ResultSet Exception: "+sqle.getMessage());
    }
    try {
      if(conn!=null) {
        conn.close();
      }
    } catch (SQLException sqle) {
      System.out.println("Close Connection Exception: "+sqle.getMessage());
    }
  }
}