超市订单管理系统（7）-用户管理+分页功能

1.做用户查询的时候就不是单单的一条线了，因为我们要根据用户名查询用户，还要根据用户角色查询用户，还有就是一个分页的功能，只有当这三条线全部写完这个功能才能起来。

2.步骤：

　　（1）先将userlist.jsp、rollpage.jsp以及分页的工具类PageSupport.java导入到项目相应的位置。

　　（2）我们还是自底向上开发，先写根据用户名和用户角色查询用户这条线吧，还是熟悉的Dao-》service-》servlet

　　（3）Dao层接口和实现类的编写

　　　　①接口设计：因为要根据用户名和用户角色查询用户，所以接口中的参数肯定要有username和userRole两个参数，因为要进行数据库操作，所以还要有connection参数

    //根据用户名或者角色查询用户总数
    public int getUserCount(Connection connection,String username,int userRole)throws Exception;

    //获取用户列表
    public List<User> getUserList(Connection connection,String username,int userRole,int currentPageNo,int pageSize) throws Exception;

    //获取角色列表
    public List<Role> getRoleList(Connection connection) throws Exception;

　　　　②实现类编写：在Dao层实现类userDao中编写的时候，如果真的不知道从哪里开始，就先把执行sql的工具类所需的几个参数写出来，因为Dao是直接操作数据库的，所以肯定要执行sql，而工具类中已经写好了执行sql的两个方法，因为这个是要进行查询，所以我们先把connection，preparedstatement，resultset，sql，params这几个参数看看哪个没有就往里卡卡一顿干。代码的具体细节上的东西可以看注释

//查询用户
    @Override
    public int getUserCount(Connection connection, String username, int userRole)
            throws Exception {
        PreparedStatement pstm=null;
        ResultSet rs=null;
        int count=0;

        if (connection != null) {
            //因为这里我们不仅仅是单单的去查一个表，要进行多表查询，就是当我们要根据用户输入的用户名或者用户角色去查询
            //所以肯定要进行一个sql的拼接，所以用StringBuffer，因为StringBuffer里边有append方法可以实现字符串的追加
            StringBuffer sql=new StringBuffer();
            ArrayList<Object> list = new ArrayList<>();
            //首先先把不需要追加条件时候的sql写出来
            sql.append("select count(1) as count from smbms_user u,smbms_role r where u.userRole=r.id");
            //因为功能既可以通过用户名查出来用户，也可以通过用户角色查出来用户，他们是一个或的关系，所以要进行判断
            //当用户名不为空的时候，将用户名条件往sql里拼接
            if (!StringUtils.isNullOrEmpty(username)) {
                //like是进行模糊查询的
                sql.append(" and u.userName like ?");
                //这里like后面需要传递参数，肯定不能向以前那样，可以考虑使用ArrayList
                list.add("%"+username+"%");
            }
            if (userRole>0) {
                sql.append(" and u.userRole like ?");
                list.add(userRole);
            }

            //因为我们需要的params是object类型，这里是arraylist类型，所以要将其转为object数组
            Object[] params=list.toArray();
            System.out.println("第二次的练习："+sql.toString());

            //既然sql和传参都搞定了，那就是执行sql，处理查询结果集，关闭资源了
            rs=BaseDao.execute(connection,pstm,rs,sql.toString(),params);
            if (rs.next()) {
                //从结果集中获取用户数量，这个参数count就是sql语句中的取的那个别名count
                count=rs.getInt("count");
            }
            BaseDao.closeResource(null,pstm,rs);
        }
        return count;
    }

    //获取用户列表
    @Override
    public List<User> getUserList(Connection connection, String username, int userRole, int currentPageNo, int pageSize)
            throws Exception {
        PreparedStatement pstm=null;
        ResultSet rs=null;
        List<User> userList =new ArrayList<User>();

        if (connection != null) {
            StringBuffer sql=new StringBuffer();
            List<Object> list=new ArrayList<Object>();
            sql.append("select u.*,r.roleName as userRoleName from smbms_user u,smbms_role r where u.userRole = r.id");
            if (!StringUtils.isNullOrEmpty(username)) {
                sql.append(" and u.userName like ?");
                list.add("%"+username+"%");
            }
            if(userRole>0){
                sql.append(" and u.userRole like ?");
                list.add(userRole);
            }

            //在数据库中，分页使用 limit startIndex pageSize
            //当前页  （当前页-1）*页面大小
            sql.append(" order by creationDate DESC limit ?,?");
            currentPageNo = (currentPageNo-1)*pageSize;
            list.add(currentPageNo);
            list.add(pageSize);

            Object[] params = list.toArray();
            System.out.println("sql ----> " + sql.toString());
            rs = BaseDao.execute(connection, pstm, rs, sql.toString(), params);
            while(rs.next()){
                User user = new User();
                user.setID(rs.getInt("id"));
                user.setUserCode(rs.getString("userCode"));
                user.setUsername(rs.getString("userName"));
                user.setGender(rs.getInt("gender"));
                user.setBirthday(rs.getDate("birthday"));
                user.setPhone(rs.getString("phone"));
                user.setUserRole(rs.getInt("userRole"));
                userList.add(user);
            }
            BaseDao.closeResource(null,pstm,rs);
        }
        return userList;
    }

    //获取角色列表
    @Override
    public List<Role> getRoleList(Connection connection) throws Exception {
        PreparedStatement pstm=null;
        ResultSet rs=null;
        List<Role> userRoleList=new ArrayList<Role>();
        if (connection != null) {
            String sql="select * from smbms_role";
            Object[] params={};
            rs= BaseDao.execute(connection,pstm,rs,sql,params);
            while (rs.next()){
                Role role=new Role();
                role.setID(rs.getInt("id"));
                role.setRoleCode(rs.getString("roleCode"));
                role.setRoleName(rs.getString("roleName"));
                userRoleList.add(role);
            }
            BaseDao.closeResource(null,pstm,rs);
        }
        return userRoleList;
    }

到这里dao层的三条线写完了===================================================================

　　（3）Service层接口和实现类的编写

　　　　①接口的设计

//查询用户数量
    public int getUserCount(String username,int userRole);

    /**
     * 根据条件查询用户列表
     *
     * @param username
     * @param userRole
     * @return
     */
    public List<User> getUserList(String username, int userRole, int currentPageNo, int pageSize);

    //获取角色列表
    public List<Role> getRoleList();

　　　　②实现类的编写

@Override
    public int getUserCount(String username, int userRole) {
        Connection connection=null;
        int count=0;

        try {
            connection=BaseDao.getConnection();
            count=userDao.getUserCount(connection,username,userRole);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            BaseDao.closeResource(connection,null,null);
        }
        return count;
    }

    @Override
    public List<User> getUserList(String username, int userRole, int currentPageNo, int pageSize) {
        Connection connection = null;
        List<User> userList = null;
        System.out.println("queryUserName ---- > " + username);
        System.out.println("queryUserRole ---- > " + userRole);
        System.out.println("currentPageNo ---- > " + currentPageNo);
        System.out.println("pageSize ---- > " + pageSize);
        try {
            connection = BaseDao.getConnection();
            userList = userDao.getUserList(connection, username,userRole,currentPageNo,pageSize);
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            BaseDao.closeResource(connection, null, null);
        }
        return userList;
    }

    @Test
    public void test(){
        UserService userService=new UserServiceImpl();
        int count = userService.getUserCount(null, 0);
        System.out.println(count);
    }

@Override
    public List<Role> getRoleList() {
        Connection connection=null;
        List<Role> roleList=null;

        try {
            connection= BaseDao.getConnection();
            roleList=roleDao.getRoleList(connection);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            BaseDao.closeResource(connection,null,null);
        }
        return roleList;
    }

    @Test
    public void test(){
        RoleService roleService=new RoleServiceImpl();
        List<Role> roleList = roleService.getRoleList();
        for (Role role:roleList) {
            System.out.println(role.getRoleName());
        }
    }

service层完毕==============================================================================

　　（4）编写servlet

//用户管理
    public void getUserList(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        String queryUsername = req.getParameter("queryname");
        String temp = req.getParameter("queryUserRole");
        String pageIndex = req.getParameter("pageIndex");
        int queryUserRole=0;
        //第一次请求一定是第一页，所以页面大小和页码是固定的
        int pageSize=5;
        int currentPageNo=1;

        //获取用户列表
        UserServiceImpl userService = new UserServiceImpl();

        //判断前端传递的相关参数
        if (queryUsername == null) {
            queryUsername="";
        }
        if (temp != null && !temp.equals("")) {
            //给查询赋值0，1，2，3
            queryUserRole=Integer.parseInt(temp);
        }
        if (pageIndex != null) {
            currentPageNo=Integer.parseInt(pageIndex);
        }

        //获取用户总数量（分页：上一页 下一页的情况）
        int totalCount = userService.getUserCount(queryUsername, queryUserRole);
        //总页数支持
        PageSupport pages = new PageSupport();
        //设置当前页码
        pages.setCurrentPageNo(currentPageNo);
        //设置页总大小
        pages.setPageSize(pageSize);
        //设置页总数量
        pages.setTotalCount(totalCount);

        //控制首页和尾页
        int totalPageCount = pages.getTotalPageCount();

        if (currentPageNo < 1) {  //显示第一页的东西
            currentPageNo = 1;
        } else if (currentPageNo > totalPageCount) {//当前页面大于最后一页，让它为最后一页就行
            currentPageNo = totalPageCount;
        }

        List<User> userList = null;
        userList = userService.getUserList(queryUsername, queryUserRole, currentPageNo, pageSize);
        req.setAttribute("userList", userList);

        List<Role> roleList = null;
        RoleService roleService = new RoleServiceImpl();
        roleList = roleService.getRoleList();
        req.setAttribute("roleList", roleList);

        req.setAttribute("queryUserName", queryUsername);
        req.setAttribute("queryUserRole", queryUserRole);
        req.setAttribute("totalPageCount", totalPageCount);
        req.setAttribute("totalCount", totalCount);
        req.setAttribute("currentPageNo", currentPageNo);
        req.getRequestDispatcher("userlist.jsp").forward(req, resp);
    }