op_user.java~26~

基于b/s的网上书店

                            page = pageCount;

                                rscount = (int) recordCount % pageSize;	 // 最后一页记录数

                                //sql为倒序取值
                                sqlStr = "select  * 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));
                                }
                                try
                                {DataBase db = new DataBase();
                                db.connect();
                                stmt = db.conn.createStatement ();

                                        rs = 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"));
                                                userlist.addElement(user);
                                        }
                                        rs.close();
                                        return true;
                                }
                                catch (SQLException e)
                                {        System.out.print(e.getMessage());
                                        return false;
                                }


                        }
                  public boolean update(HttpServletRequest req) throws Exception {
                           if (getRequest(req)){
                                                sqlStr = "update shop_user set ";
                                                sqlStr = sqlStr + "username = '" + dataFormat.toSql(user.getUserName()) + "',";
                                                sqlStr = sqlStr + "password = '" + dataFormat.toSql(user.getPassWord()) + "',";
                                                sqlStr = sqlStr + "Names = '" + dataFormat.toSql(user.getNames()) + "',";
                                                sqlStr = sqlStr + "sex = '" + dataFormat.toSql(user.getSex()) + "',";
                                                sqlStr = sqlStr + "address = '" + dataFormat.toSql(user.getAddress()) + "',";
                                                sqlStr = sqlStr + "phone = '" + dataFormat.toSql(user.getPhone()) + "',";
                                                sqlStr = sqlStr + "post = '" + dataFormat.toSql(user.getPost()) + "',";
                                                sqlStr = sqlStr + "Email = '" + dataFormat.toSql(user.getEmail()) + "' ";
                                                sqlStr = sqlStr + " where id = '" + user.getId() + "'";
                                                try
                                                {	DataBase db = new DataBase();
                                                        db.connect();
                                                        stmt = db.conn.createStatement ();

                                                        stmt.execute(sqlStr);
                                                        return true;
                                                }
                                                catch (SQLException e)
                                                {
                                                        return false;
                                                }
                                        } else {
                                                return false;
                                        }

                                }

                                public boolean delete( long aid ) throws Exception {

                                        sqlStr = "delete from shop_user where id = "  + aid ;
                                        try
                                        {       DataBase db = new DataBase();
                                                db.connect();
                                                stmt = db.conn.createStatement ();

                                                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 shop_user where Id = " + newid ;
                                                DataBase db = new DataBase();
                                                db.connect();
                                                stmt = db.conn.createStatement ();

                                                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 String getGbk( String str) {
               try  {
                return new String(str.getBytes("ISO8859-1"));
                }catch (Exception e){
                  return str;
                  }
                }
                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;
                      }
                      public Vector getUserlist() {
                           return userlist;
                       }

              };