userdao.java

网上购物系统

package eshopsys.user.model;

import java.sql.*;
import java.util.*;
import eshopsys.tools.base.BaseDao;
import eshopsys.tools.base.BaseEntity;
import eshopsys.tools.database.DataBaseTool;
import eshopsys.user.model.*;

public class UserDao extends BaseDao {
//////////////////////////////////////////////////////////////////////////
	protected BaseEntity[] pack(ResultSet resultset) throws SQLException {
		 ArrayList result = new ArrayList();
		 UserEntity[] users = null;
		    while (resultset.next()) {
		      UserEntity user = new UserEntity();
		      user.setUserId(resultset.getInt("userid"));
		      user.setUserName(resultset.getString("username"));
		      user.setUserSex(resultset.getString("usersex"));
		      user.setUserCity(resultset.getString("usercity"));
		      user.setUserAddress(resultset.getString("useraddress"));
		      user.setUserZipCode(resultset.getString("userzipcode"));
		      user.setUserTelephone(resultset.getString("usertelephone"));
		      user.setUserEmail(resultset.getString("useremail"));
		      user.setUserAccount(resultset.getString("useraccount"));
		      user.setUserPassword(resultset.getString("userpassword"));
		      result.add(user);
		    }
		    if (result.size() > 0) {
		    	users= new UserEntity[result.size()];
		      result.toArray(users);
		    }
		    return users;

	}
//////////////////////////////////////////////////////////////////////////	
	public void insert( UserEntity user) throws
    SQLException {
    PreparedStatement ps = null;
    StringBuffer buffer = new StringBuffer();
    try {
    //构造添加sql语句
    	
    buffer.append("INSERT INTO tbl_user(userid,username,usersex,usercity,useraddress,userzipcode,usertelephone,useremail,useraccount,userpassword)");
    buffer.append(" VALUES(?,?,?,?,?,?,?,?,?,?)");

    ps = con.prepareStatement(buffer.toString());
    //设置sql语句的参数
    int index = 1;
    int currentId=getMaxPrimaryId("tbl_user","userid");
    ps.setInt(index++,currentId);
    ps.setString(index++,user.getUserName());
    ps.setString(index++,user.getUserSex());
    ps.setString(index++,user.getUserCity());
    ps.setString(index++,user.getUserAddress());
    ps.setString(index++,user.getUserZipCode());
    ps.setString(index++,user.getUserTelephone());
    ps.setString(index++,user.getUserEmail());
    ps.setString(index++,user.getUserAccount());
    ps.setString(index++,user.getUserPassword());

    
    //执行sql语句
    ps.executeUpdate();
  }
  catch (Exception e) {
    throw new SQLException("向表(tbl_user)中插入数据发生异常 ： " + e.getMessage());
  }
  finally {
    DataBaseTool.close(ps);
  }
 }
//////////////////////////////////////////////////////////////////////////
	//更新一条会员记录
	  public void update( UserEntity user) throws     
	 SQLException {
	    PreparedStatement ps = null;
	    StringBuffer buffer = new StringBuffer();
	    try {
	      //构造更新sql语句
	      buffer.append("UPDATE tbl_user SET ");
	      buffer.append("userid=?,username=?,usersex=?,usercity=?,useraddress=?,userzipcode=?,usertelephone=?,useremail=?,useraccount=?,userpassword=?");
	      buffer.append(" WHERE userid = ?");
	      ps = con.prepareStatement(buffer.toString());

	      //设置参数
	      int index = 1;
	      ps.setInt(index++,user.getUserId());
	      ps.setString(index++,user.getUserName());
	      ps.setString(index++,user.getUserSex());
	      ps.setString(index++,user.getUserCity());
	      ps.setString(index++,user.getUserAddress());
	      ps.setString(index++,user.getUserZipCode());
	      ps.setString(index++,user.getUserTelephone());
	      ps.setString(index++,user.getUserEmail());
	      ps.setString(index++,user.getUserAccount());
	      ps.setString(index++,user.getUserPassword());
	      ps.setInt(index++,user.getUserId());
	      //执行
	      ps.executeUpdate();
	    }
	    catch (Exception e) {
	      throw new SQLException("更新表(tbl_user)时发生异常 : " + e.getMessage());
	    }
	    finally {
	      DataBaseTool.close(ps);
	    }
	  }
//////////////////////////////////////////////////////////////////////////
	//管理员登录测试
		  public boolean UserLoginTest(String useraccount,String userpassword) throws 
		  SQLException{
			  Connection con=DataBaseTool.getConnection();
			  boolean loginFlag=false;
			  PreparedStatement ps = con.prepareStatement("select * from tbl_user where useraccount=? and userpassword=?");
			  ps.setString(1, useraccount.trim());
			  ps.setString(2,userpassword.trim());
			  ResultSet rs=ps.executeQuery();
			  if(rs.next())
				  loginFlag=true;
			  
			  return loginFlag;
		  }
}