usermn.java

jsp开发常用信息管理系统适合初学者学习 网上购物

package ch09.web;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Vector;

import javax.servlet.http.HttpServletRequest;


import ch09.util.strFormat;
import ch09.web.book.shopuser;

/**
 * @author <a href='[e-mail]'>chengwei</a>
 * 网站用户类列表
 */

public class usermn extends DataBase {
    
	private shopuser user = new shopuser();	//新的用户对象
	private javax.servlet.http.HttpServletRequest request; //建立页面请求
	private Vector userlist;				//显示用户列表向量数组
	private int page = 1;					//显示的页码
	private int pageSize=8;					//每页显示的图书数
	private int pageCount =0;				//页面总数
	private long recordCount =0;			//查询的记录总数
	private String message = "";			//出错信息提示
	private String username = "";			//注册后返回的用户名
	private long userid = 0;				//注册后返回的用户ID

	
	public usermn() throws Exception{
		super();
	}

	public Vector getUserlist() {
		return userlist;
	}

	public String getGbk( String str) {
		try
		{
			return new String(str.getBytes("GB2312"));
		}
		catch (Exception e)
		{
			return str;
		}
	}
	
	//将页面表单传来的资料分解
	public boolean getRequest(HttpServletRequest newrequest) {
		boolean flag = false;
		try
		{
			request = newrequest;
			String ID = request.getParameter("userid");
			if (ID!=null )
			{
				userid = 0;
				try
				{
					userid = Long.parseLong(ID);
					user.setId(userid);
				}
				catch (Exception e)
				{
					message = message + "你要修改的用户号出错！";
				}
			}			
			
			username = request.getParameter("username");
			if (username==null || username.equals(""))
			{
				username = "";
				message = message + "用户名为空!";
			}
			user.setUserName(getGbk(username)); 
			String password = request.getParameter("passwd");
			if (password==null || password.equals(""))
			{	
				password = "";
				message = message + "密码为空!";
			}
			String pwdconfirm = request.getParameter("passconfirm");
			if (!password.equals(pwdconfirm))
			{
				message = message + "确认密码不相同!";
			}
			user.setPassWord(getGbk(password));
			String names = request.getParameter("names");;
			if (names==null)
			{
				names = "";
			}
			user.setNames(getGbk(names));
			String sex = request.getParameter("sex");				
			user.setSex(getGbk(sex));
			String address = request.getParameter("address");
			if (address == null)
			{
				address = "";
			}
			user.setAddress(getGbk(address));
			String post = request.getParameter("post");
			if (post == null)
			{
				post = "";
			}
			user.setPost(getGbk(post));
			String phone = request.getParameter("phone");
			if (phone== null)
			{
				phone = "";
			}
			user.setPhone(phone);
			String email = request.getParameter("email");
			if (email == null)
			{	
				email = "";
			}
			user.setEmail(getGbk(email));
			String IP = request.getRemoteAddr();
			user.setRegIpAddress(IP);
			if (message.equals(""))
			{
				flag = true;
			}
			return flag;					
		}
		catch (Exception e)
		{
			return flag;
		}
	}

	public String getSql() {
		sqlStr = "select * from Users order by id";
		return sqlStr;
	}


	public boolean execute() throws Exception {
		sqlStr = "select count(*) from Users";    //取出记录数
		int rscount = pageSize;
		try
		{
			ResultSet rs1 = stmt.executeQuery(sqlStr);
			if (rs1.next()) recordCount = rs1.getInt(1);				
			rs1.close();
		}
		catch (SQLException e)
		{
			close();
			return false;
		}
		//设定有多少pageCount
		if (recordCount < 1)
            pageCount = 0;
        else
            pageCount = (int)(recordCount - 1) / pageSize + 1;
		//检查查看的页面数是否在范围内
		if (page < 1)  
            page = 1;
        else if (page > pageCount)
            page = pageCount;
		
		rscount = (int) recordCount % pageSize;	 // 最后一页记录数        

		//倒序取值
		sqlStr = "select Top " + pageSize + " * from Users ";
		if (page == 1)
		{
			sqlStr = sqlStr + " order by Id desc";
		} else {
			sqlStr = sqlStr + " where Id not in ( select TOP " + (recordCount-pageSize * page ) + " Id from users ORDER BY id) and Id in " +
			"(select TOP " + (recordCount - pageSize * (page-1)) + " Id from Users ORDER BY Id) " + " order by Id desc";
		}
		try
		{
			rs = stmt.executeQuery(sqlStr);
			userlist = new Vector();
			while (rs.next()){
				shopuser user = new shopuser();
				user.setId(rs.getLong("id"));
				user.setUserName(rs.getString("username"));
				user.setPassWord(rs.getString("password"));
				user.setNames(rs.getString("names"));
				user.setSex(rs.getString("sex"));
				user.setAddress(rs.getString("address"));
				user.setPhone(rs.getString("Phone"));
				user.setPost(rs.getString("post"));
				user.setEmail(rs.getString("email"));
				user.setRegTime(rs.getString("regtime"));
				user.setRegIpAddress(rs.getString("RegIpaddress"));
				userlist.addElement(user);			
			}
			rs.close();
			return true;
		}
		catch (SQLException e)
		{
			return false;
		}
		

	}

	public boolean insert(HttpServletRequest req) throws Exception {
		if (getRequest(req)) {
			sqlStr = "select * from Users where username = '" + user.getUserName() +"'";
			rs = stmt.executeQuery(sqlStr);
			if (rs.next())
			{
				message = message + "该用户名已存在!";
				rs.close();
				return false;
			}
			sqlStr = "insert into Users (UserName,PassWord,Names,Sex,Address,Phone,Post,Email,RegTime,RegIpAddress) values ('";
			sqlStr = sqlStr + strFormat.formatSql(user.getUserName()) + "','";
			sqlStr = sqlStr + strFormat.formatSql(user.getPassWord()) + "','";
			sqlStr = sqlStr + strFormat.formatSql(user.getNames()) + "','";
			sqlStr = sqlStr + strFormat.formatSql(user.getSex()) + "','";
			sqlStr = sqlStr + strFormat.formatSql(user.getAddress()) + "','";
			sqlStr = sqlStr + strFormat.formatSql(user.getPhone()) + "','";
			sqlStr = sqlStr + strFormat.formatSql(user.getPost()) + "','";
			sqlStr = sqlStr + strFormat.formatSql(user.getEmail()) + "',getdate(),'";
			sqlStr = sqlStr + user.getRegIpAddress() + "')";
			try
			{
				stmt.execute(sqlStr);
				sqlStr = "select max(id) from Users where UserName = '" +user.getUserName()+ "'";
				rs = stmt.executeQuery(sqlStr);
				while (rs.next())
				{
					userid = rs.getLong(1);
				}
				rs.close();
				return true;
			}
			catch (SQLException sqle)
			{
				return false;
			}
		} else	{
			return false;
		}
		
	}

	public boolean update(HttpServletRequest req) throws Exception {
		if (getRequest(req)){
			sqlStr = "update Users set ";
			sqlStr = sqlStr + "UserName = '" + strFormat.formatSql(user.getUserName()) + "',";
			sqlStr = sqlStr + "PassWord = '" + strFormat.formatSql(user.getPassWord()) + "',";
			sqlStr = sqlStr + "Names = '" + strFormat.formatSql(user.getNames()) + "',";
			sqlStr = sqlStr + "Sex = '" + strFormat.formatSql(user.getSex()) + "',";
			sqlStr = sqlStr + "Address = '" + strFormat.formatSql(user.getAddress()) + "',";
			sqlStr = sqlStr + "Phone = '" + strFormat.formatSql(user.getPhone()) + "',";
			sqlStr = sqlStr + "Post = '" + strFormat.formatSql(user.getPost()) + "',";
			sqlStr = sqlStr + "Email = '" + strFormat.formatSql(user.getEmail()) + "' ";
			sqlStr = sqlStr + " where Id = '" + user.getId() + "'";
			try
			{
				stmt.execute(sqlStr);
				return true;
			}
			catch (SQLException e)
			{
				return false;
			}
		} else {
			return false;
		}
	}

	public boolean delete( long aid ) throws Exception {

		sqlStr = "delete from Users where Id = "  + aid ;
		try
		{
			stmt.execute(sqlStr);
			return true;
		}
		catch (SQLException e)
		{
			System.out.println(e);
			return false;
		}
	}

	public boolean getUserinfo(long newid ) throws Exception {
		try
		{
			sqlStr="select  * from Users where Id = " + newid ;
			rs = stmt.executeQuery(sqlStr);			
			userlist = new Vector();
			while (rs.next()){
				user.setId(rs.getLong("Id"));
				user.setUserName(rs.getString("UserName"));
				user.setPassWord(rs.getString("PassWord"));
				user.setNames(rs.getString("Names"));
				user.setSex(rs.getString("Sex"));
				user.setAddress(rs.getString("Address"));
				user.setPhone(rs.getString("Phone"));
				user.setPost(rs.getString("Post"));
				user.setEmail(rs.getString("Email"));
				user.setRegTime(rs.getString("RegTime"));
				user.setRegIpAddress(rs.getString("RegIpAddress"));
				userlist.addElement(user);			
			}
			rs.close();
			return true;
		}
		catch (SQLException e)
		{
			return false;
		}
		
	}
	//显示的页码
	public int getPage() {
		return page;
	}
	public void setPage(int newpage) {
		page = newpage;
	}

	public int getPageSize(){			//每页显示的图书数
		return pageSize;
	}
	public void setPageSize(int newpsize) {
		pageSize = newpsize;
	}

	public int getPageCount() {				//页面总数
		return pageCount;
	}
	public void setPageCount(int newpcount) {
		pageCount = newpcount;
	}

	public long getRecordCount() {
		return recordCount;
	}
	public void setRecordCount(long newrcount) {
		recordCount= newrcount;
	}
	
	public String getMessage() {
		return message;
	}

	public void setMessage(String msg) {
		message = msg;
	}

	public void setUserid(long uid) {
		userid = uid;
	}
	public long getUserid() {
		return userid;
	}

	public void setUserName(String uName) {
		username = uName;
	}

	public String getUserName() {
		return username;
	}
}