baseconn.java

jsp +javabean +sql 2000的在线聊天系统 ,实现私聊、群聊、管理员T人等功能

package net.chat;
import java.sql.*;
import java.lang.ClassNotFoundException;
public class BaseConn{
    private Connection conn=null;
    private Statement stmt=null;
    private PreparedStatement ps=null;
    private ResultSet rs=null;
/**************************************************************************************
  *BaseConn的构造函数，在这里完成数据库的初始化操作，即连接数据库操作
 **************************************************************************************/
    public BaseConn()throws SQLException,ClassNotFoundException{
	try
	{
	  String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=ChatRoom;
	  SelectMethod=Cursor";
	  Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
    	  conn=DriverManager.getConnection(url,"sa","abcd1234");
	  stmt=conn.createStatement();
	}
	catch(SQL Exception e)
	{
	  System.out.println("Error occured when Connect DataBase:"+e);
	  throw e;
	}
	catch(ClassNotFoundException e)
	{
	  System.out.println("Error occured when Connect DataBase:"+e);
	  throw e;
	}
/*************************************************************************************
  *初始化预编译的SQL语句的对象
************************************************************************************/
	public PreparedStatement prepaedStatement(String sql)throws SQLException
	{
	  try
	  {
	     ps=conn.prepareStatement(sql);
	     return ps;
	  }catch(SQLException e)
	  {
	     System.out.println("Error occured when create preparedStatement:"+e);
             throw e;
          }
	}
/*************************************************************************************
  *执行静态SQL查询语句并返回它所生成结果的对象
************************************************************************************/
	public ResultSet ececuteQuery(String sql)throws SQLException
	{
	   rs=null;
	   try{
	     rs=stmt.executeQuery(Sql);
           }
	   catch(SQLException ex){
	     System.out.println("Error occured when query database:"+ex);
	     throw ex;
           }
	   return rs;
	}
/*************************************************************************************
  *执行静态SQL查询语句并返回影响数据的条数
************************************************************************************/
	public int executeUpadate(String sql)throws SQLException
	{
	   try{
		conn.setAutoCommit(false);
	int re=stmt.executeUpdate(sql);
	conn.commit();
	return re;
	}
	catch(SQL Exception e){
	   conn.rollback();
	   System.out.println("Error occured when update database:"+e);
	   throw e;	
	}
      }
/*************************************************************************************
  *执行预先SQL查询语句
************************************************************************************/
      public ResultSet executeQuery() throws SQLException
      {
	try{
	   return ps.executeQuery();
	}
	catch(SQLException e){
	  System.out.println("Error occured when query database:"+e);
	  throw e;
	}
       }
/*************************************************************************************
  *执行预编译的SQL更新语句
************************************************************************************/
      public int executeUpdate() throws SQLException
      {
	try{
	 conn.setAutoCommit(false);
	 int r=ps.executeUpdate();
	 conn.commit();
	 return r;
      }
      catch(SQLException e){
	conn.rollback();
	System.out.println("Error occured when updata database:"+e);
      }
     }
/*************************************************************************************
  *数据库关闭操作
************************************************************************************/			       public boolean closeDB() throws SQLException
       {
	  try{
	     if(this.rs!=null)
	       rs.close();
	     if(this.stmt!=null)
	       this.stmt.close();
	     if(this.ps!=null)
		this.ps.close();
	     if(this.conn!=null)
	         conn.close();
	     return true;
	   }
	catch (SQLException e){
	  System.out.println("Error occured when close database:"+e);
	  throw e;
	 }
	}
    }