op_user.java~77~

基于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

        private 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 id, username, password, names, sex, ";
          sqlStr += " address, Phone, post, email, regtime, RegIpaddress ";
          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;

          //     }
        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);