dbmanage.java

dwr框架以及spring框架的整合

package dao;
import java.sql.*;

public class DbManage {
  private Connection conn = null;
  private Statement stmt = null;
  private ResultSet rs = null;

  public static DbManage newInstance() {
    return new DbManage();
  }

  private void getStmt() {
    try {
      //加载驱动
      Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
      //创建连接
      String url = "jdbc:odbc:driver=sql server;server=(local);database=pubs" ;
      //String url="jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};DBQ=mydb.mdb";

      conn = DriverManager.getConnection(url);
      //创建语句对象
      stmt = conn.createStatement();
    }
    catch (Exception ex) {
      System.out.println(ex.getMessage());
    }
  }

  //******************************************
   //增删改方法
   public int exeSql(String sql) {
     int i = 0;
     try {
       this.getStmt();
       i = stmt.executeUpdate(sql);
       stmt.close();
       conn.close();
     }
     catch (Exception ex) {
       System.out.println(ex.getMessage());
     }
     return i;
   }

  //******************************************
   //查询方法(返回值为结果集)
   public ResultSet getRs(String sql) {
     try {
       this.getStmt();
       rs = stmt.executeQuery(sql);
     }
     catch (Exception ex) {
       System.out.println(ex.getMessage());
     }
     return rs;
   }

  //******************************************
   //关闭方法
   public void close(ResultSet rs, Statement stmt, Connection conn) {
     try {
       if (rs != null) {
         rs.close();
       }
       if (stmt != null) {
         stmt.close();
       }
       if (conn != null) {
         conn.close();
       }
     }
     catch (Exception ex) {
       System.out.println(ex.getMessage());
     }
   }
}