Mybatis是如何进行分页的

2024-06-23 18:44

文章标签 进行分页 mybatis

本文主要是介绍Mybatis是如何进行分页的，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

MyBatis 也提供了支持分页的方案，其主要思路是使用 Limit 偏移量和限制个数，来获取指定数量的数据

MyBatis 提供两种分页方式：基于参数改造和基于插件拦截

1、基于参数改造：

第一种分页方式是基于参数改造的，通过添加参数 limit 和 offset 就可以实现查询从某个位置开始的若干条记录，代码实现如下：

<select id="selectSomeData"parameterType="map" resultType="com.example.SomeData">SELECT * FROM sometableORDER BY somecolumnLIMIT #{limit} OFFSET #{offset}
</select>

2、基于插件拦截：

MyBatis 还提供了另外一种分页方式，基于插件拦截机制。这种方式更加灵活，支持实现更为复杂的分页功能。

自定义一个拦截器，实现 Interceptor 接口，并重写其中唯一的 intercept 方法，在其中对 SQL 语句进行修改，添加分页信息。具体操作如下：

public class PageInterceptor implements Interceptor {/*** 拦截方法** @param invocation* @return* @throws Throwable*/@Overridepublic 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;// 构造含分页信息的新SQLString 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);
}