basicdbbean.java.bak

JSP、Servlet入门范例。实现留言版程序

package lyb;
import java.sql.*;

public class basicDBBean {

  private String sDBDriver = "com.sybase.jdbc2.jdbc.SybDriver";
  private String sConnStr = "jdbc:sybase:Tds:10.8.8.11:5000/info1000";
  private String oDBDriver = "oracle.jdbc.driver.OracleDriver";
  private String oConnStr = "jdbc:oracle:thin:@192.168.0.222:1521:drcom";
  private Connection oConn = null;
  private ResultSet rs = null;
  private Connection conn = null;

  public basicDBBean() {
  }

  public ResultSet executeQuery(String sql){
    String temp;
    if (oConn == null){
      //System.out.println("connect");
      temp=DBConnect2();
      //System.out.println(temp);
    }
    
    if (oConn== null){
      //System.out.println("conn is null");
      rs = null;
    }
    else{
      try{
        //System.out.println("createStatement");
        Statement s = oConn.createStatement();
        System.out.println(sql);
        rs = s.executeQuery(sql);
        System.out.println("Suceess to executeQuery");
      } catch (SQLException e){
      	System.out.println("Failed to executeQuery");
      	System.out.println(e.getMessage());
      }
    }
    return (rs);
  }

  public String DBConnect(){
    String strExc = "prepare";
    try{
      Class.forName(sDBDriver);
      conn = DriverManager.getConnection(sConnStr,"system","manager");
      strExc = "sybase";
    }
    catch(ClassNotFoundException e){
      strExc = e.toString();
    }
    catch(SQLException e){
      strExc = e.toString();
    }
    return strExc;
  }

  public String DBConnect2(){
   String strExc = "prepare";
   try{
     Class.forName(oDBDriver);
     oConn = DriverManager.getConnection(oConnStr,"drcom","drcom");
     strExc = "orcale";
   }
   catch(ClassNotFoundException e){
     strExc = e.toString();
   }
   catch(SQLException e){
     strExc = e.toString();
   }
   System.out.println(strExc);
   return strExc;
  }

  public void setConnStr(String ConnStr){
    sConnStr = ConnStr;
  }

  public void setDBDriver(String DBDriver){
    sDBDriver = DBDriver;
  }

  public void setConn(Connection c){
    conn = c ;
  }

  public String getConnStr(){
    return(sConnStr);
  }

  public String getDBDriver(){
    return(sDBDriver);
  }

  public ResultSet getRs(){
    return(rs);
  }

  public Connection getConn(){
    return(conn);
  }

  public ResultSet getPagedResult(int pageSize,int pageNumber,String sql){

    int concurType =ResultSet.CONCUR_READ_ONLY;
    int scrollType =ResultSet.TYPE_SCROLL_INSENSITIVE;

    String temp;
    if (oConn == null){
      temp=DBConnect2();
    }

    try{
      Statement s=oConn.createStatement(scrollType,concurType);
      s.setMaxRows(pageSize*pageNumber);
      rs = s.executeQuery(sql);
    } catch(SQLException e){
      return null;
    }
    int absoluteLocation = pageSize *(pageNumber-1);
    if(absoluteLocation != 0) {
      try{
        if(rs.absolute(absoluteLocation)==false) {
          return null;
        }
      } catch(SQLException e){
        return null;
      }
    }
    return rs;
  }
}