op_user.java~83~

基于JSP的网上书店.功能较为全面 开发环境:sql server2000+tomcat+jdk

package bookshop.run;

/**
* <p>Title: </p>
* <p>Description: </p>
* <p>Copyright: Copyright (c) 2004</p>
* <p>Company: </p>
* @author not attributable
* @version 1.0
*/
import java.sql.*;
import java.util.Vector;
import javax.servlet.http.HttpServletRequest;
import bookshop.util.*;
import bookshop.book.*;

public class op_user //extends DataBase
{
    private user user = new user();	                        //新的用户对象
    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 String sqlStr;
    private ResultSet rs;

    public op_user()
    {
        super();
    }

    public void finalize()
    {
        //super.finalize();
    }
    //添加新用户
    public boolean add(HttpServletRequest req) throws Exception
    {
        if (getRequest(req))
        {
            DataBase db = new DataBase();
            //db.connect();
            //stmt = db.conn.createStatement ();
            //sqlStr = "SELECT * FROM shop_user WHERE username = '" +
            //          user.getUserName() +"'";
            sqlStr = "insert into shop_user (username,password,Names,sex,"+
                "Address,Phone,Post,Email,RegTime,RegIpaddress) values ('";
            sqlStr = sqlStr + dataFormat.toSql(user.getUserName()) + "','";
            sqlStr = sqlStr + dataFormat.toSql(user.getPassWord()) + "','";
            sqlStr = sqlStr + dataFormat.toSql(user.getNames()) + "','";
            sqlStr = sqlStr + dataFormat.toSql(user.getSex()) + "','";
            sqlStr = sqlStr + dataFormat.toSql(user.getAddress()) + "','";
            sqlStr = sqlStr + dataFormat.toSql(user.getPhone()) + "','";
            sqlStr = sqlStr + dataFormat.toSql(user.getPost()) + "','";
            sqlStr = sqlStr + dataFormat.toSql(user.getEmail()) + "',GETDATE(),'";
            sqlStr = sqlStr + user.getRegIpAddress() + "')";
            try
            {
                db.stmt.executeUpdate(sqlStr);
                sqlStr = "SELECT max(id) FROM shop_user WHERE username = '" +
                    dataFormat.toSql(user.getUserName())+ "'";
                rs = db.stmt.executeQuery(sqlStr);
                while (rs.next())
                {
                    userid = rs.getLong(1);
                }
                rs.close();
                db.finalize();
                return true;
            }
            catch (Exception sqle)
            {
                System.out.print(sqle.getMessage());
                return false;
            }
        }
        else
        {
            return false;
        }

    }
    //分析页面转递的参数
    public boolean getRequest(javax.servlet.http.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((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((password));
            String names = request.getParameter("names");;
            if (names==null)
            {
                names = "";
            }
            user.setNames((names));
            String sex = request.getParameter("sex");
            user.setSex((sex));
            String address = request.getParameter("address");
            if (address == null)
            {
                address = "";
            }
            user.setAddress((address));
            String post = request.getParameter("post");
            if (post == null)
            {
                post = "";
            }
            user.setPost((post));
            String phone = request.getParameter("phone");
            if (phone== null)
            {
                phone = "";
            }
            user.setPhone(phone);
            String email = request.getParameter("email");
            if (email == null)
            {
                email = "";
            }
            user.setEmail((email));
            String IP = request.getRemoteAddr();
            user.setRegIpAddress(IP);
            if (message.equals(""))
            {
                flag = true;
            }
            return flag;
        }catch (Exception e)
        {
            return flag;
        }
    }
    //查询书店所有的用户
    public boolean get_alluser() throws Exception
    {
        sqlStr = "SELECT COUNT(*) FROM shop_user";    //取出记录数
        int rscount = pageSize;
        try
        {
            DataBase db = new DataBase();
            //db.connect();
            //stmt = db.conn.createStatement ();
            ResultSet rs1 = db.stmt.executeQuery(sqlStr);
            if ( rs1.next() )
            {
                recordCount = rs1.getInt(1);
            }
            rs1.close();
            db.finalize();
        }
        catch (SQLException e)
        {
            System.out.print("count:"+e.getMessage());
            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;	 // 最后一页记录数
        //sql为倒序取值
        sqlStr = "SELECT TOP " + (recordCount-pageSize * (page-1)) ;
        sqlStr = sqlStr + " id, username, password, names, sex, ";
        sqlStr += " address, Phone, post, email, regtime, RegIpaddress, userpoint ";
        sqlStr += " FROM shop_user ";
        //if (page == 1){
        //   sqlStr = sqlStr + " ORDER BY Id desc limit 0,"+pageSize;
        //   } else {
        //sqlStr = sqlStr + " ORDER BY Id desc limit "+(recordCount-pageSize*page) +","+(recordCount - pageSize * (page-1));
        //sqlStr = sqlStr + " ORDER BY Id desc limit " + pageSize * (page - 1) + "," + pageSize;
        sqlStr = sqlStr + " ORDER BY id ASC ";
        sqlStr = " SELECT TOP " + pageSize +  " * FROM ( " +  sqlStr + " ) myTable ORDER BY myTable.id DESC " ;

        //     }
        try
        {
            DataBase db = new DataBase();
            //db.connect();
            //stmt = db.conn.createStatement ();
            rs = db.stmt.executeQuery(sqlStr);
            userlist = new Vector();
            while (rs.next())
            {
                user user = new user();
                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"));
                user.setUserPoint(rs.getInt("userpoint"));
                userlist.addElement(user);
            }
            rs.close();
            db.finalize();
            return true;