mysqllogindao.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.LoginDAO;
import lightningboard.bean.LoginBean;

public class MysqlLoginDAO implements LoginDAO{

  private DBConnectionManager dbcm = DBConnectionManager.getInstance();

  public LoginBean execute(String u_name)throws ActionException{
    Connection connection=null;
    try {
      LoginBean loginBean=new LoginBean();
      connection=dbcm.getConnection();
      DBAccess dba=new DBAccess(connection);
      String sql="SELECT u_id,u_password,u_r_id FROM lb_user"
                +" WHERE u_name='"+u_name+"'";
      ResultSet rs=dba.openSelect(sql);
//check result
      if (!rs.next()){
        rs.close();
       dba.closeSelect();
       return null;
      }
      rs.beforeFirst();
      while (rs.next()){
        loginBean.setU_id(rs.getInt("u_id"));
        loginBean.setU_name(u_name);
        loginBean.setU_password(rs.getString("u_password"));
        loginBean.setU_r_id(rs.getInt("u_r_id"));
      }
      rs.close();
      dba.closeSelect();
      return loginBean;
    } catch (Exception ex) {
      throw new ActionException(ex);
    }finally{
      try {
        dbcm.freeConnection(connection);
      } catch (SQLException ex) {
        //
      }
    }
  }
}