mysqluserdao.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.UserDAO;
import lightningboard.bean.UserBean;

public class MysqlUserDAO implements UserDAO   {
  private DBConnectionManager dbcm = DBConnectionManager.getInstance();

  public UserBean execute(int u_id)throws ActionException{
    Connection connection=null;
    try {
      UserBean userBean=new UserBean();
      connection=dbcm.getConnection();
      DBAccess dba=new DBAccess(connection);
      String sql="SELECT u_name,u_avatar_id,u_password,u_email,u_regtime"
                +",u_address,u_sign,u_post,u_lasttime,u_lastip FROM lb_user"
                +"  WHERE u_id=" + u_id;
      ResultSet rs=dba.openSelect(sql);
//check result
      if (!rs.next()){
        rs.close();
        dba.closeSelect();
        return null;
      }
      rs.beforeFirst();
      while (rs.next()){
        userBean.setU_id(u_id);
        userBean.setU_name(rs.getString("u_name"));
        userBean.setU_avatar_id(rs.getInt("u_avatar_id"));
        userBean.setU_password(rs.getString("u_password"));
        userBean.setU_email(rs.getString("u_email"));
        userBean.setU_regtime(rs.getTimestamp("u_regtime"));
        userBean.setU_address(rs.getString("u_address"));
        userBean.setU_sign(rs.getString("u_sign"));
        userBean.setU_post(rs.getInt("u_post"));
        userBean.setU_lasttime(rs.getTimestamp("u_lasttime"));
        userBean.setU_lastip(rs.getString("u_lastip"));
      }
      rs.close();
      dba.closeSelect();
      return userBean;
    } catch (Exception ex) {
      throw new ActionException(ex);
    }finally{
      try {
        dbcm.freeConnection(connection);
      } catch (SQLException ex) {
        //
      }
    }
  }
}