package org.it315;
import java.sql.*;public class DBconnect
{
   Connection con=null;
   Statement  stmt=null;
   ResultSet  rs=null;
   
   public DBconnect()
   {
     try
      {
        Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver"); 
      }
     catch(ClassNotFoundException e) {System.out.println("Err: "+e.getMessage());} 
   }
   public ResultSet executeQuery(String sql)
   {
      rs=null;
      String user="sa"; 
      String password=""; 
      String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=OA"; // OA是数据库名
      try
      { 
        
        con=DriverManager.getConnection(url,user,password);
        stmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
        rs=stmt.executeQuery(sql);
      }catch(SQLException e1) {System.out.println("QuerySQLErr: "+e1.getMessage());}
      return rs;
   }
   public ResultSet executeUpdate(String sql)
   {
               
    String user="sa"; 
    String password=""; 
    String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=OA"; // OA是数据库名称
     try
     {
        con=DriverManager.getConnection(url,user,password);
        stmt=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
        stmt.executeUpdate(sql);
     }catch(SQLException e1) {System.out.println("UpdateSQLErr: "+e1.getMessage());}
     return rs;
    
   }
   
}