op_user.java~27~

基于b/s的网上书店

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 op_user() {
  }
  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() +"'";
                          System.out.print("2222222222222");
                           System.out.print(sqlStr);
                          //rs = stmt.executeQuery(sqlStr);
                          System.out.print("333333333333");
                          /*if (rs.next())
                          {
                                  message = message + "该用户名已存在!";
                                  rs.close();
                                  return false;
                          }*/
                          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()) + "',now(),'";
                          sqlStr = sqlStr + user.getRegIpAddress() + "')";
                          try
                          {       System.out.print(sqlStr);
                                  stmt.executeUpdate(sqlStr);
                                  sqlStr = "select max(id) from shop_user where username = '" +user.getUserName()+ "'";
                                  System.out.print(sqlStr);
                                  rs = stmt.executeQuery(sqlStr);
                                  while (rs.next())
                                  {
                                          userid = rs.getLong(1);
                                  }
                                  rs.close();
                                  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;
                          System.out.print("11111111");
                          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 + "用户名为空!";
                                  }
                                  System.out.print(username);
                                  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 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 = stmt.executeQuery(sqlStr);
                                        if (rs1.next()) recordCount = rs1.getInt(1);
                                        rs1.close();
                                }
                                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)