MyBatis 是一種持久層架構,支援通過配置檔案和注解将 SQL 映射為 Java 對象。在實際開發中,查詢資料時經常需要進行分頁處理。 MyBatis 也提供了支援分頁的方案,其主要思路是使用 Limit 偏移量和限制個數,來擷取指定數量的資料。下面将會介紹 MyBatis 如何進行分頁。
MyBatis 提供兩種分頁方式:基于參數改造和基于插件攔截 。下面我們将分别介紹這兩種方式:
1、基于參數改造:
第一種分頁方式是基于參數改造的,通過添加參數 limit 和 offset 就可以實作查詢從某個位置開始的若幹條記錄,代碼實作如下:
<select id="selectSomeData"
parameterType="map" resultType="com.example.SomeData">
SELECT * FROM sometable
ORDER BY somecolumn
LIMIT #{limit} OFFSET #{offset}
</select>
這段 SQL 語句會傳回從偏移量為 offset 的位置開始的 limit 條結果。例如:LIMIT 30,10 表示從第 31 行開始傳回 10 行結果。
在實際應用中,我們可以将 limit 和 offset 抽取成兩個參數,并傳入到 MyBatis 中。
2、基于插件攔截 :
MyBatis 還提供了另外一種分頁方式,基于插件攔截機制。這種方式更加靈活,支援實作更為複雜的分頁功能。
我們需要自定義一個攔截器,實作 Interceptor 接口,并重寫其中唯一的 intercept 方法,在其中對 SQL 語句進行修改,添加分頁資訊。具體操作如下:
首先,建立一個類來實作該攔截器:
public class PageInterceptor implements Interceptor {
/**
* 攔截方法
*
* @param invocation
* @return
* @throws Throwable
*/
@Override
public Object intercept(Invocation invocation) throws Throwable {
// 擷取原始的SQL語句
String sql = (String) invocation.getArgs()[0];
// 查詢總數并計算出總頁數和目前頁
int total = count(sql);
// 如果總數小于等于0,則直接傳回空結果集
if (total <= 0) {
return Collections.emptyList();
}
// 計算出目前頁的起始位置和結束位置
int offset = getOffset(pageNo, pageSize);
int limit = pageSize;
// 構造含分頁資訊的新SQL
String newSql = getNewSql(sql, offset, limit);
// 将新SQL替換成原來的SQL,并繼續執行原有方法
ReflectionUtils.setFieldValue(invocation, "h.sql", newSql);
Object result = invocation.proceed();
// 包裝成Page對象,并傳回
Page<T> pageResult = new Page<>(pageNo,pageSize,total,(List<T>)result);
return pageResult;
}
/**
* 擷取新的SQL語句(含分頁資訊)
*
* @param sql
* @param offset
* @param limit
* @return
*/
private String getNewSql(String sql, int offset, int limit) {
return sql + " LIMIT " + offset + "," + limit;
}
/**
* 擷取查詢結果總數
*
* @param sql
* @return
*/
private int count(String sql){
// code omitted
}
/**
* 計算目前分頁的 Offset
*
* @param pageNo
* @param pageSize
* @return
*/
private int getOffset(int pageNo, int pageSize) {
return (pageNo - 1) * pageSize;
}
}
然後,我們需要在 mybatis-config.xml 配置檔案中注冊該攔截器:
<plugins>
<plugin interceptor="com.example.mybatis.PageInterceptor"/>
</plugins>
最終,在查詢資料時,我們便可以按照以下方式進行分頁處理了:
public List<User> selectUserListByPage(int startRow, int pageSize){
RowBounds rowBounds = new RowBounds(startRow,pageSize);
String statement = "com.example.UserMapper.selectUserList";
return sqlSession.selectList(statement,null,rowBounds);
}