import java.sql.*; 
public class QueryBean 
{ 
  public String query_statement; /*定義sql語句*/ 
  public String param[]; /*查詢條件*/ 
  public ResultSet result=null; /*查詢結果*/
  public Connection conn; 
  //設置查詢參數
  public void setParam(String[] param) 
  { 
    this.param=param; 
  } 
  //設置SQL查詢語句
  public void setQuerystatement(String query_statement) 
  { 
    this.query_statement=query_statement; 
  } 
  //設置連接參數
  public void setConnection(String driverName,String jdbcURL,String username,String passwd) throws Exception 
  { 
    Connection conn1; 
    Class.forName(driverName); 
    conn1=DriverManager.getConnection(jdbcURL,username,passwd); 
    conn1.setAutoCommit(false); 
    this.conn = conn1; 
  } 
  /*獲取查詢結果*/ 
  public ResultSet getResult() 
  { 
    try 
    { 
      PreparedStatement select_stm=conn.prepareStatement(query_statement,java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY); 
      if (param!=null) 
        for(int i=0;i<param.length;i++) 
         select_stm.setString(i+1,param[i]); 
      result=select_stm.executeQuery(); 
    }catch(Exception e){System.out.println(e);} 
    return result; 
  } 
  /*對數據庫進行增加記錄操作*/ 
  public void insertRecord() throws SQLException,java.io.UnsupportedEncodingException 
  { 
    try 
    { 
      PreparedStatement insert_stm=conn.prepareStatement(query_statement); 
      if (param!=null) 
        for(int i=0;i<param.length;i++) 
           insert_stm.setString(i+1,param[i]); 
      insert_stm.executeUpdate(); 
      insert_stm.close(); 
      conn.commit(); 
    } 
    catch(Exception e) 
    { 
      System.out.println(e); 
      conn.rollback(); 
    } 
  } 
  /*對數據記錄進行更新操作*/ 
  public void updateRecord() throws SQLException,java.io.UnsupportedEncodingException 
  { 
    try 
    { 
      PreparedStatement update_stm=conn.prepareStatement(query_statement); 
      if (param!=null) 
        for (int i=0;i<param.length;i++) 
          update_stm.setString(i+1,param[i]); 
      update_stm.executeUpdate(); 
      update_stm.close(); 
      conn.commit(); 
     } 
     catch(Exception e) 
     { 
       System.out.println(e); 
       conn.rollback(); 
     } 
  } 
  /*刪除數據記錄*/ 
  public void deleteRecord() throws SQLException,java.io.UnsupportedEncodingException 
  { 
    try 
    { 
      PreparedStatement delete_stm=conn.prepareStatement(query_statement); 
      if (param!=null) 
        for (int i=0;i<param.length;i++) 
          delete_stm.setString(i+1,param[i]); 
      delete_stm.executeUpdate(); 
      delete_stm.close(); 
      conn.commit(); 
    } 
    catch(Exception e) 
    { 
      System.out.println(e); 
      conn.rollback(); 
    } 
   } 
}