mysqlpostdao.java

雷霆论坛是用J2EE技术开发的功能强大、扩展性强、易于定制

package lightningboard.dao.mysql;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import lightningboard.db.DBConnectionManager;
import lightningboard.db.DBAccess;
import lightningboard.ActionException;
import lightningboard.dao.PostDAO;
import lightningboard.bean.PostBean;

public class MysqlPostDAO implements PostDAO {
  private DBConnectionManager dbcm = DBConnectionManager.getInstance();

  public PostBean post(int f_id)throws ActionException{
    Connection connection=null;
    try {
      connection=dbcm.getConnection();
      DBAccess dba=new DBAccess(connection);
      String sql="SELECT f_name FROM lb_forum  WHERE f_id=" + f_id;
      ResultSet rs=dba.openSelect(sql);
      //check result
      if (!rs.next()){
        rs.close();
       dba.closeSelect();
       return null;
      }
      rs.beforeFirst();
      PostBean postBean=new PostBean();
      while (rs.next()){
        postBean.setF_id(f_id);
        postBean.setF_name(rs.getString("f_name"));
      }
      rs.close();
      dba.closeSelect();
      return postBean;
    } catch (Exception ex) {
      throw new ActionException(ex);
    }finally{
      try {
        dbcm.freeConnection(connection);
      } catch (SQLException ex) {
        //
      }
    }
  }
  public PostBean reply(int t_id)throws ActionException{
    Connection connection=null;
    try {
      connection=dbcm.getConnection();
      DBAccess dba=new DBAccess(connection);
      String sql="SELECT t_f_id,f_name,t_name,t_locked FROM lb_forum,lb_topic"
                +"  WHERE t_f_id=f_id AND t_id=" + t_id;
      ResultSet rs=dba.openSelect(sql);
      //check result
      if (!rs.next()){
        rs.close();
       dba.closeSelect();
       return null;
      }
      rs.beforeFirst();
      PostBean postBean=new PostBean();
      while (rs.next()){
         postBean.setF_id(rs.getInt("t_f_id"));
         postBean.setF_name(rs.getString("f_name"));
         postBean.setT_id(t_id);
         postBean.setT_name(rs.getString("t_name"));
         postBean.setT_locked(rs.getInt("t_locked"));
      }
      rs.close();
      dba.closeSelect();
      return postBean;
    } catch (Exception ex) {
      throw new ActionException(ex);
    }finally{
      try {
        dbcm.freeConnection(connection);
      } catch (SQLException ex) {
        //
      }
    }
  }
}