学步园

package com.bay.db;

import java.sql.*;

public class DBConn {
 private final String DB_DRIVER_NAME = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
 private final String CONN_STR="jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=shoping";
 private final String DB_USER = "sa";
 private final String DB_PWD = "0";

 Connection conn = null;
 Statement stmt = null;
 ResultSet rs = null;
 
 String errorMsg;

 public DBConn() throws Exception {
  Class.forName(DB_DRIVER_NAME);// 加载数据库驱动程序
  this.conn = DriverManager.getConnection(CONN_STR,DB_USER,DB_PWD);
  this.stmt = this.conn.createStatement();
 }

 /**
  * 执行查询操作
  * @param sql
  * @return
  */
 public ResultSet executeQuery(String sql) throws Exception {
   
  if(stmt==null){
   errorMsg="连接句柄无效。";
   return null;
  }
   
  this.rs = stmt.executeQuery(sql);
  return this.rs;
 }

 /**
  * 执行数据的插入、删除、修改操作
  * @param sql
  * @return
  */
 public boolean executeUpdate(String sql) throws Exception {
  if(stmt==null){
   errorMsg="连接句柄无效。";
   return false;
  }
  
  if (this.stmt.executeUpdate(sql) == 0)
   return false;
  else
   return true;

 }

 public ResultSet getRS(){
  return this.rs;
 }
 
 
 public void closers(){
  try{
   if (rs!=null){
    rs.close();
    rs=null;
   }
  }catch(Exception e){
   e.printStackTrace();
   errorMsg=e.getMessage();
  }
 }
 
 public void closestmt(){
  try{
   if(stmt!=null){
    stmt.close();
    stmt=null;
   }
  }catch(SQLException e) {
   e.printStackTrace();
   errorMsg=e.getMessage();
  }
 }
 
 public void closeconn(){
  try{
   if(conn!=null){
    conn.close();
    conn=null;
   }
  }
  catch(SQLException e) {
   e.printStackTrace();
   errorMsg=e.getMessage();
  }
 }
}