oracle数据库 —— 分页查询 java代码实现

分页查询的核心代码（理解这一句话很重要）：

prep = conn.prepareStatement("select * from (select t2.*,rownum rn from (select t1.* from sys_user t1 order by id) t2) where rn>? and rn<=?");

Dao实现层代码：

/**
   * 分页查询
   * @param pageNo 页码
   * @param pageSize 页的记录数
   * @return
   */
   public List<UserVO> findUserPaging(int pageNo, int pageSize){
       ResultSet rs = null;
       PreparedStatement prep = null;
       List<UserVO> list = new ArrayList<UserVO>();
       try{
           //调用连接对象的prepareStatement方法，得到预编对象，赋值给预编译对象变量
           prep = conn.prepareStatement("select * from (select t2.*,rownum rn from (select t1.* from sys_user t1 order by id) t2) "
                   + "where rn>? and rn<=?");
           //调用预编译对象的setXxx方法，给？号赋值
           prep.setInt(1,(pageNo-1)*pageSize);
           prep.setInt(2,pageNo*pageSize);//调用连接对象的executeQuery方法，执行查询结果，赋值给结果集译对象变量
           rs = prep.executeQuery();
           while(rs.next()){
               UserVO user = new UserVO(); //创建一个新用户对象，赋值给用户对象变量

               //调用结果集对象的getxxx的方法，取出各个字段的值
               //再调用用户对象的setxxx方法，给属性赋值
               //最后新创建的对象中包含了查询结果中的所有字段的值
               user.setId(rs.getInt("id"));
               user.setName(rs.getString("name"));
               user.setPassword(rs.getString("password"));
               user.setSex(rs.getString("sex"));
               user.setEmail(rs.getString("email"));
               user.setPower(rs.getString("power"));
               user.setBirth(rs.getDate("birth"));
               user.setStatus(rs.getInt("status"));
               list.add(user); //将对象放入集合中
           }

       }catch(Exception e){
           System.out.println("dao分页查询时候出错： "+e.getMessage());
           throw new DaoException("dao分页查询时候出错",e);
       }finally{
           DBUtil.closeStatement(rs, prep);; //调用数据库工具类的closeStatement的方法，关闭结果集合声明对象
       }
       return list;
   }

service类实现代码：

/**
   * 分页查询
   * @param pageNo 页码
   * @param pageSize 页的记录数
   * @return
   */
   public List<UserVO> findUserPaging(int pageNo, int pageSize){
       Connection conn = null; //声明数据库连接对象，用于保存数据库连接对象
       List<UserVO> user = null;
       try{
           //调用数据库工具类的getConnection方法，取得数据库连接对象，并赋值给数据库连接对象变量
           conn = DBUtil.getConnection();
           //调用dao工厂类的getDao方法，去得指定类型dao接口的实现类，并赋值给dao接口变量
           UserDao userMgrDao = (UserDao)DaoFactory.getDao(conn,EnumType.USER_DAO);
           //调用dao中的findUserPaging方法，进行分页查询操作，结果赋值给查询结果变量
           user = userMgrDao.findUserPaging(pageNo, pageSize);
       }catch(DaoException e){
           throw e;
       }catch(Exception e){
           throw new ServiceException("分页查询信息错误：",e);
       }finally{
           DBUtil.closeConnection(conn);
       }
       //返回用户查询结果
       return user;
   }

Control控制层代码：

/**
   * 分页查询
   * @param pageNo 页码
   * @param pageSize 页的记录数
   * @return
   */
   public List<UserVO> findUserPaging(int pageNo, int pageSize){
       List<UserVO> user = null;
       try{
           //调用用户service接口中的login方法，进行用户登录操作
           user = userMgrService.findUserPaging(pageNo, pageSize);
       }catch(Exception e){
           //异常信息
           System.out.println("分页查询用户信息时出现错误"+e.getMessage());
       }
       return user;
   }

view视图层代码：

/**
   * 分页查询全部结果显示
   */
   public void findUserPagingShow(){
       //声明冲处理流对象，用于接收控制台输入的数据
       BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
       try{
           UserController uc = new UserController();
           System.out.print("请输入每页要显示的记录数：");
           int pageSize = Integer.parseInt(br.readLine());
           System.out.print("请输入要查询的页码：");
           int pageNo = Integer.parseInt(br.readLine());
           //调用控制器中的findUserPaging方法，进行用户分页查询操作
           List<UserVO> list = uc.findUserPaging(pageNo, pageSize);
           if(list != null){
               for(UserVO user : list)
                   System.out.println("查询结果： "+user.getId()+" "+user.getName()+" "+user.getPassword()
                       +" "+user.getSex()+" "+user.getEmail()+" "+user.getPower()+" "+TypeUtils.dateToDate(user.getBirth())+" "+user.getStatus()+"\n");

           }else{
               System.out.println("不好意思，查找失败！");
           }
       }catch(Exception e){
           System.out.println(e.getMessage());
       }
   }

调用例子：