mybatis-plus的分页拦截器(PaginationInterceptor)分页失败问题及解决

 更新时间:2025年05月22日 09:29:35   作者:thewindkee  
这篇文章主要介绍了mybatis-plus的分页拦截器(PaginationInterceptor)分页失败问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

背景

项目中使用到了mybatis-plus的3.0.5版本,分页拦截器是PaginationInterceptor。

代码如下:

    @Transactional(readOnly = true)
    public void test() {
        int current =1;
        while (true) {
            final LambdaQueryWrapper<Foo> query = Condition.<Foo>lambda().gt(AppProject::getBusiId, 1);
            //传入增长页数来查询
            Page<Foo> page = new Page<>(current++, 1000);
            Page<Foo> result = fooMapper.selectPage(page, query);
            //...业务
            if (result .getRecords() == null && || CollectionUtils.isEmpty(result .getRecords())) {
                break;
            }
        }
    }

现象

1.无法从while中跳出循环。

2.打印sql日志只打印了一次。

猜测

  • 怀疑分页失败了。
  • 由于只有一次日志,怀疑之后都走到了缓存。

证明过程

1.使用arthas看看sql是怎样的

tt org.apache.ibatis.mapping.SqlSource getBoundSql '{params,returnObj,throwExp}'

拿出来的sql的确没有LIMIT

  • TODO 待修改

打开sql日志,也有观察到Limit语句,虽然只出现了一次,但说明是有分页的。

因此:猜测1不成立。

2.查看PaginationInterceptor

PaginationInterceptor拦截的是StatementHandler#prepare,在prepare方法执行的时候,才会添加Limit语句。而在调用添加Limit语句之前,已经拿了缓存中的数据,不会真正执行查询了。

  • 调用顺序为:

由上图可以看出,当生成cacheKey的时候,由于此时的boundSql还未被拦截,不含有Limit语句,每次boundSql都一样,导致cacheKey都一样。

因此:

  1. 只有第一次查询会走不到缓存,然后被prepare阶段被拦截,添加Limit语句后查询数据库。将数据放入一级缓存中。
  2. 第二次查询开始,由于有事务,会尝试利用一级缓存中的数据,且cacheKey一样,缓存有对应的数据,就直接返回了缓存中的数据。

生成缓存key

  public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException {
    BoundSql boundSql = ms.getBoundSql(parameter);
    CacheKey key = createCacheKey(ms, parameter, rowBounds, boundSql);
    return query(ms, parameter, rowBounds, resultHandler, key, boundSql);
 }

优先查一级缓存,无缓存则查数据库

 public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
    ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
    if (closed) {
      throw new ExecutorException("Executor was closed.");
    }
    if (queryStack == 0 && ms.isFlushCacheRequired()) {
      clearLocalCache();
    }
    List<E> list;
    try {
      queryStack++;
      list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;
      if (list != null) {
        handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);
      } else {
        list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);
      }
    } finally {
      queryStack--;
    }
    if (queryStack == 0) {
      for (DeferredLoad deferredLoad : deferredLoads) {
        deferredLoad.load();
      }
      // issue #601
      deferredLoads.clear();
      if (configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {
        // issue #482
        clearLocalCache();
      }
    }
    return list;
  }

添加Limit语句

/**
 * <p>
 * MYSQL 数据库分页语句组装实现
 * </p>
 *
 * @author hubin
 * @since 2016-01-23
 */
public class MySqlDialect implements IDialect {

    @Override
    public String buildPaginationSql(String originalSql, long offset, long limit) {
        StringBuilder sql = new StringBuilder(originalSql);
        sql.append(" LIMIT ").append(offset).append(StringPool.COMMA).append(limit);
        return sql.toString();
    }
}

问题出现原因

  • PaginationInterceptor拦截时期太晚,导致虽然传了不同的页数,但是提前生成的cacheKey一样。
  • 使用了事务,导致用到同一sqlSession,走到了一级缓存。

解决方法

  • 升级Mybatis-Plus,高版本的MybatisPlusInterceptor来分页。(MybatisPlusInterceptor的拦截在cacheKey生成之前,可以避免上述问题)
  • 不在事务中使用分页查询。

总结

分页太深,查询太慢,最后还是放弃了这种分页查询方式。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Spring使用注解方式实现创建对象

    Spring使用注解方式实现创建对象

    这篇文章主要介绍了Spring使用注解方式实现创建对象,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2023-02-02
  • Mybatis如何根据List批量查询List结果

    Mybatis如何根据List批量查询List结果

    这篇文章主要介绍了Mybatis如何根据List批量查询List结果,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-03-03
  • Java中Elasticsearch的核心概念详解

    Java中Elasticsearch的核心概念详解

    这篇文章主要介绍了Java中Elasticsearch的核心概念详解,Elasticsearch 是一个分布式、免费和开放的搜索和分析引擎,适用于所有类型的数据,包括文本、数字、地理空间、结构化和非结构化数据,需要的朋友可以参考下
    2023-07-07
  • 使用Postman自动生成Cookie并转换为Java代码的实现

    使用Postman自动生成Cookie并转换为Java代码的实现

    在接口测试中,有时候需要在请求中携带Cookie信息,为了方便测试,我们可以使用Postman来自动生成Cookie,并将其转换为Java代码,以便在自动化测试中使用,下面将介绍如何实现这一功能,需要的朋友可以参考下
    2024-11-11
  • Java爬虫实现Jsoup利用dom方法遍历Document对象

    Java爬虫实现Jsoup利用dom方法遍历Document对象

    本文主要介绍了Java爬虫实现Jsoup利用dom方法遍历Document对象,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-05-05
  • SpringBoot和MybatisPlus实现通用Controller示例

    SpringBoot和MybatisPlus实现通用Controller示例

    本文主要介绍了SpringBoot和MybatisPlus实现通用Controller示例,只需创建实体类和mapper接口,就可以实现单表的增删改查操作,具有一定的参考价值,感兴趣的可以了解一下
    2025-03-03
  • 浅谈 JDBC 元数据

    浅谈 JDBC 元数据

    这篇文章主要介绍了JDBC元数据的相关内容,涉及一些获取数据源各种信息的方法,具有一定参考价值,需要的朋友可以了解下。
    2017-09-09
  • Java中的==和equals()区别小结

    Java中的==和equals()区别小结

    在Java编程中,理解==操作符和equals()方法的区别是至关重要的,本文主要介绍了Java中的==和equals()区别,具有一定的参考价值,感兴趣的可以了解一下
    2023-08-08
  • 用html css javascript打造自己的RIA图文教程

    用html css javascript打造自己的RIA图文教程

    用html&css&javascript打造自己的RIA之一,包括了配置等
    2009-07-07
  • 解决使用security和静态资源被拦截的问题

    解决使用security和静态资源被拦截的问题

    这篇文章主要介绍了解决使用security和静态资源被拦截的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-08-08

最新评论