usermn.java

一本书中的原代码,有用多例子,很好用

package org.pan.web;

import java.sql.*;
import java.util.Vector;
import org.pan.util.*;
import javax.servlet.http.HttpServletRequest;
import org.pan.web.book.shopuser;
import org.pan.web.book.books;
import java.util.*;

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;				//初始页面总数为0
    private long recordCount =0;			//初始查询的记录总数为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("ISO8859-1"));
        } catch (Exception e) {
            return str;
        }
    }
    
    //将页面表单传来的资料分解
    public boolean getRequest(javax.servlet.http.HttpServletRequest newrequest) {
        boolean flag = false;
        try {
            request = newrequest;
            String ID = request.getParameter("userid");//获取userid参数
            if (ID!=null ) {
                userid = 0;
                try {
                    userid = Long.parseLong(ID);
                    user.setId(userid);
                } catch (Exception e) {
                    message = message + "你要修改的用户号出错！";
                }
            }
            
            username = request.getParameter("username");//获取username参数
            if (username==null || username.equals("")) {
                username = "";
                message = message + "用户名为空!";
            }
            user.setUserName(getGbk(username));
            String password = request.getParameter("passwd");//获取passwd参数
            if (password==null || password.equals("")) {
                password = "";
                message = message + "密码为空!";
            }
            String pwdconfirm = request.getParameter("passconfirm");//获取passconfirm参数
            if (!password.equals(pwdconfirm)) {
                message = message + "确认密码不相同!";
            }
            user.setPassWord(getGbk(password));
            String names = request.getParameter("names");;//获取names参数
            if (names==null) {
                names = "";
            }
            user.setNames(getGbk(names));//转化格式
            String sex = request.getParameter("sex");
            user.setSex(getGbk(sex));
            String address = request.getParameter("address");//获取address参数
            if (address == null) {
                address = "";
            }
            user.setAddress(getGbk(address));
            String post = request.getParameter("post");//获取post参数
            if (post == null) {
                post = "";
            }
            user.setPost(getGbk(post));
            String phone = request.getParameter("phone");//获取phone参数
            if (phone== null) {
                phone = "";
            }
            user.setPhone(phone);
            String email = request.getParameter("email");//获取email参数
            if (email == null) {
                email = "";
            }
            user.setEmail(getGbk(email));//转化格式
            String IP = request.getRemoteAddr();//利用getRemoteAddr()函数取得用户IP
            user.setRegIpAddress(IP);
            if (message.equals("")) {
                flag = true;
            }
            return flag;
        } catch (Exception e) {
            return flag;
        }
    }
    
    public String getSql() {
        sqlStr = "select * from my_users order by id";//取出记录所有字段
        return sqlStr;
    }
    
    
    public boolean execute() throws Exception {
        sqlStr = "select count(*) from my_users";    //取出 my_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;
        }
       
        if (recordCount < 1)//如果记录数小于1
            pageCount = 0;//页数为0
        else
            pageCount = (int)(recordCount - 1) / pageSize + 1;//调整页数为整数
        //核实要查看的页面数是否在范围内
        if (page < 1)
            page = 1;
        else if (page > pageCount)
            page = pageCount;
        
        rscount = (int) recordCount % pageSize;	 // 最后一页记录数
        
        //取出符合查询条件的所有记录结果集按Id 降序排列
        sqlStr = "select * from My_users ";
        if (page == 1) {
            sqlStr = sqlStr + " order by Id desc";
        } else {
            sqlStr = sqlStr + " where Id not in ( select Id from My_users ORDER BY id) and Id in " +
                    "(select Id from My_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) {
            System.out.println(e);
            return false;
        }
        
        
    }
    
    public boolean insert(HttpServletRequest req) throws Exception {
        if (getRequest(req)) {
            sqlStr = "select * from My_users where username = '" + user.getUserName() +"'";//取出符合username字段要求的记录
            rs = stmt.executeQuery(sqlStr);//执行SQL语句
            if (rs.next()) {
                message = message + "该用户名已存在!";
                rs.close();
                return false;
            }
            sqlStr = "insert into my_users (username,password,Names,sex,Address,Phone,Post,Email,RegTime,RegIpaddress) values ('";
            sqlStr = sqlStr + strFormat.toSql(user.getUserName()) + "','";
            sqlStr = sqlStr + strFormat.toSql(user.getPassWord()) + "','";
            sqlStr = sqlStr + strFormat.toSql(user.getNames()) + "','";
            sqlStr = sqlStr + strFormat.toSql(user.getSex()) + "','";
            sqlStr = sqlStr + strFormat.toSql(user.getAddress()) + "','";
            sqlStr = sqlStr + strFormat.toSql(user.getPhone()) + "','";
            sqlStr = sqlStr + strFormat.toSql(user.getPost()) + "','";
            sqlStr = sqlStr + strFormat.toSql(user.getEmail()) + "',getdate(),'";//使用getdate()函数获取系统当前时间
            sqlStr = sqlStr + user.getRegIpAddress() + "')";
          
              try {
                stmt.execute(sqlStr);
                sqlStr = "select max(id) from My_users where username = '" +user.getUserName()+ "'";
                rs = stmt.executeQuery(sqlStr);
                while (rs.next()) {
                    userid = rs.getLong(1);
                }
                rs.close();
                return true;
            } catch (SQLException sqle) {
                System.out.println(sqle.toString());
                return false;
            }
        } else	{
            return false;
        }
        
    }
    
    public boolean update(HttpServletRequest req) throws Exception {
        if (getRequest(req)){
            sqlStr = "update my_users set ";
            sqlStr = sqlStr + "username = '" + strFormat.toSql(user.getUserName()) + "',";
            sqlStr = sqlStr + "password = '" + strFormat.toSql(user.getPassWord()) + "',";
            sqlStr = sqlStr + "Names = '" + strFormat.toSql(user.getNames()) + "',";
            sqlStr = sqlStr + "sex = '" + strFormat.toSql(user.getSex()) + "',";
            sqlStr = sqlStr + "address = '" + strFormat.toSql(user.getAddress()) + "',";
            sqlStr = sqlStr + "phone = '" + strFormat.toSql(user.getPhone()) + "',";
            sqlStr = sqlStr + "post = '" + strFormat.toSql(user.getPost()) + "',";
            sqlStr = sqlStr + "Email = '" + strFormat.toSql(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 My_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 My_users where Id = " + newid ;//根据newid取出符合查询条件的记录
            rs = stmt.executeQuery(sqlStr);//执行sql语句
            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;
    }
};