dbbean.java

j2ee实现简单的bbs功能

package BeanLink;   //说明该Bean所在的包为BeanLink
import java.sql.*;//引入bean中将要使用的类或者包

//class是类的标识，bean也是一个类，DBBean是该类的名字，这两部分是声明一个类必须的
public class DBBean  
{
   String sDBDriver="";    //数据库驱动
   String sConnStr="";     //数据库连接
   String suser="";        //用户名
   String spass="";        //密码
   String sHint="";        //提示信息

   //以下3个对象实现对数据库的操作
   Connection conn=null;   //定义连接对象，用于数据库和java程序之间的连接 
   Statement stmt=null;    //该对象能够执行特定的SQL语句
   
   public DBBean(){}
   //返回提示信息
   public String getHint()
   {
      return sHint;
   }
   //设置数据库驱动
   public void setDBDriver(String s)
   {
      sDBDriver=""+s;
   }
   //返回数据库驱动
   public String getDBDriver()
   {
      return sDBDriver;
   }
   //设置数据库连接
   public void setConnStr(String s)
   {
      sConnStr=""+s;
   }
   public String getConnStr()
   {
      return sConnStr;
   }

   //初始化数据库
   public boolean openConn(String dbDriver,String dbConn,String user,String pass)
   {
      //设置驱动，连接，用户及密码的值
      sDBDriver=dbDriver;
      sConnStr=dbConn;
      suser=user;
      spass=pass;
      try
      {
         Class.forName(sDBDriver);  //加载待访问数据库的驱动程序
      }
      catch(ClassNotFoundException e)
      {
         sHint="Initialization :"+e.getMessage();
         return false;
      }
      try
      {
         conn=DriverManager.getConnection(sConnStr,suser,spass); //建立与数据库之间的连接
         sHint="Connect successfully";
         return true;
      }
      catch(SQLException e)
      {
         sHint="Connect :"+e.getMessage();
         return false;
      }
   }
   //执行SQL语句，返回一个数据集
   public ResultSet executeQuery(String sql)
   {
      ResultSet rs=null;      //结果数据集
      try
      {
         stmt=conn.createStatement();    //生成sql的容器，可以理解为建立stmt与conn之间的关系
         rs=stmt.executeQuery(sql);  //执行SQL语句，把结果集赋给rs
      }catch(SQLException ex)
      {
         sHint="executeQuery:"+ex.getMessage();
      }
      return rs;
   }
   //另一个执行SQL语句操作，但不返回数据集
   public boolean executeUpdate(String sql)
   {
      try
      {
         stmt=conn.createStatement();
         stmt.executeUpdate(sql);
         return true;
      }
      catch(SQLException ex)
      {
         sHint="executeUpdate:"+ex.getMessage();
         return false;
      }
   }
   //关闭所有的连接
   public boolean closeConn()
   {
      try
      {
         if(stmt!=null)
            stmt.close();
         if(conn!=null)
            conn.close();
         return true;
      }catch(SQLException ex)
      {
         sHint="closeConn:"+ex.getMessage();
         return false;
      }
   }
}