Mybatis-plus之RowBounds實現分頁查詢

物理分頁和邏輯分頁

物理分頁：直接從數據庫中拿出我們需要的數據，例如在Mysql中使用limit。

邏輯分頁：從數據庫中拿出所有符合要求的數據，然后再從這些數據中拿到我們需要的分頁數據。

優缺點

物理分頁每次都要訪問數據庫，邏輯分頁只訪問一次。

物理分頁占用內存少，邏輯分頁相對較多。

物理分頁數據每次都是最新的，邏輯分頁有可能滯后。

一般用法

public List<Order> queryListByPage(RowBounds rowBounds);

dao.queryListPage(new RowBounds(offset,limit));

RowBounds對象有2個屬性，offset和limit。

offset:起始行數

limit：需要的數據行數

因此，取出來的數據就是：從第offset+1行開始，取limit行

Mybatis中使用RowBounds實現分頁的大體思路：

先取出所有數據，然后游標移動到offset位置，循環取limit條數據，然后把剩下的數據舍棄。

private void handleRowValuesForSimpleResultMap(ResultSetWrapper rsw, ResultMap resultMap, ResultHandler<?> resultHandler, RowBounds rowBounds, ResultMapping parentMapping) throws SQLException {
    DefaultResultContext<Object> resultContext = new DefaultResultContext();
    this.skipRows(rsw.getResultSet(), rowBounds);  //游標跳到offset位置
    //取出limit條數據
    while(this.shouldProcessMoreRows(resultContext, rowBounds) && rsw.getResultSet().next()) {
        ResultMap discriminatedResultMap = this.resolveDiscriminatedResultMap(rsw.getResultSet(), resultMap, (String)null);
        Object rowValue = this.getRowValue(rsw, discriminatedResultMap);
        this.storeObject(resultHandler, resultContext, rowValue, parentMapping, rsw.getResultSet());
    }

}

private void skipRows(ResultSet rs, RowBounds rowBounds) throws SQLException {
    if (rs.getType() != 1003) {
        if (rowBounds.getOffset() != 0) {
            rs.absolute(rowBounds.getOffset());
        }
    } else {     //從頭開始移動游標，直至offset位置
        for(int i = 0; i < rowBounds.getOffset(); ++i) {
            rs.next();
        }
    }

}

在Mybatis-Plus中的應用

Controller層

@RequestMapping(value = "list", method = { RequestMethod.GET, RequestMethod.POST })
@PageableDefaults(sort = "createDate=desc")
private void getList(Queryable queryable,String queryStr, PropertyPreFilterable propertyPreFilterable, HttpServletRequest request,
                      HttpServletResponse response) throws IOException {
    //前端傳過來需要的參數，加上id，fastjson會在得到結果集時過濾數據
    propertyPreFilterable.addQueryProperty("id");
    QueryableConvertUtils.convertQueryValueToEntityValue(queryable, entityClass);
    SerializeFilter filter = propertyPreFilterable.constructFilter(entityClass);
    //調用service層的分頁查詢
    PageJson<OprPrintOrder> pagejson = new PageJson<OprPrintOrder>(service.list(queryable));
    //得到需要的結果集后的數據過濾操作
    String content = JSON.toJSONString(pagejson, filter);
    JSONObject result = JSONObject.parseObject(content);
    StringUtils.printJson(response, result.toString());
}

Service層

@Override
public Page<Order> list(Queryable queryable) {
    //pageable中有數據查詢的要求
    Pageable pageable = queryable.getPageable();
    //封裝新的分頁查詢類
    com.baomidou.mybatisplus.plugins.Page<Order> page = new com.baomidou.mybatisplus.plugins.Page<Order>(pageable.getPageNumber(), pageable.getPageSize());
    //傳入RowBounds，page就是RowBounds的子類，這樣查詢后page就有了總頁數與總條數
    page.setRecords(mapper.selectList(page));
    return new PageImpl<Order>(page.getRecords(), pageable, page.getTotal());
}

Mapper層

List<Order> selectList(RowBounds rowBounds);

<select id="selectList" resultType="Order">
  select * from order
</select>