mysqlregisterdao.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.util.DateTimeUtil;
import lightningboard.ActionException;
import lightningboard.dao.RegisterDAO;

public class MysqlRegisterDAO implements RegisterDAO {

  private DBConnectionManager dbcm = DBConnectionManager.getInstance();

  public int execute(String u_name,int u_avatar_id,String u_password
                     ,String u_email,String u_address,String u_sign
                     ,String u_lastip)throws ActionException{
    Connection connection=null;
    try {
      connection=dbcm.getConnection();
      DBAccess dba=new DBAccess(connection);
      String sql="SELECT 1 from lb_user WHERE "
                +"LOWER(u_email)='"+u_email.toLowerCase()+"'"
                +" OR LOWER(u_name)='"+u_name.toLowerCase()+"'";
      ResultSet rs=dba.openSelect(sql);
      if(rs.next()){
        rs.close();
        dba.closeSelect();
        return 0;
      }
      rs.close();
      dba.closeSelect();
      CommonDAO idGen=new CommonDAO();
      int u_id=idGen.getUserID(dba);
      String u_regtime=DateTimeUtil.getDateTime();
      sql="INSERT INTO lb_user (u_id,u_r_id,u_name,u_avatar_id,u_password"
         +",u_email,u_regtime,u_post,u_address,u_sign,u_lasttime,u_lastip)"
         +" VALUES ("+u_id+",0,'"+ u_name+ "',"+u_avatar_id+",'"+ u_password
         + "','"+ u_email+ "','"+ u_regtime+ "',0,'"+ u_address+ "','"+u_sign
         + "','"+ u_regtime+"','"+u_lastip+"')";
      dba.runSql(sql);
      return u_id;
    } catch (Exception ex) {
      throw new ActionException(ex);
    }finally{
      try {
        dbcm.freeConnection(connection);
      } catch (SQLException ex) {
        //
      }
    }
  }
}