pagehelper常见问题【分页失效】【ThreadLocal污染线程】

不摆烂的小劉

已于 2024-12-28 22:04:40 修改

阅读量2.5k

点赞数 66

分类专栏： Java那些事文章标签： java 数据库后端开发语言笔记

于 2024-11-26 21:00:03 首次发布

本文链接：https://blog.csdn.net/lygcsdn_/article/details/143895146

版权

Java那些事专栏收录该内容

12 篇文章

订阅专栏

🍰 个人主页:不摆烂的小劉
🍞文章有不合理的地方请各位大佬指正。
🍉文章不定期持续更新，如果我的文章对你有帮助➡️ 关注🙏🏻 点赞👍 收藏⭐️

在上一篇文章PageHelper 分页查询【底层代码-图文分析】【原理篇】探讨了PageHelper的底层原理——拦截MyBatis的查询操作，在Sql语句执行前动态地添加分页逻辑，从而实现数据的分页查询。

本篇文章研究一下Pagehelper常出现的问题。
在这里插入图片描述

文章目录

一、分页参数失效

1. 数据开启分页后查询的集合进行增删

!!!错误代码：

// 开启分页
PageHelper.startPage(1, 10);

// 执行查询
List<Product> products = productDAO.listProducts();

// 在查询结果集上进行增删操作
products.add(newProduct); // 添加新产品
products.remove(newProduct); // 删除产品

新增、删除新的元素，这只是在内存中的List层面进行了操作，并没有改变数据库中的数据分布和分页相关的设置，但会导致当前页数据量不等于PageSize

2. 更新集合生成一个新集合。

分页查询的集合通过lambda得到新的集合
!!!错误代码

PageMethod.startPage(dto.getPageNum(), dto.getPageSize());
List<ProductVO> products = productDAO.listProducts(dto);
// stream处理分页结果集 
List<ProductVO> resultList = products.stream().map(one -> handleProduct(one)).collect(Collectors.toList());
return new PageInfo<>(resultList);

处理后的流收集到一个新的列表中，新的集合resultList并不是 Page 类或其子类的实例，在new PageInfo<>(resultList)中无法设置分页参数（为什么是Page 类或其子类的实例才能设置，请看上一篇（原理篇）的第二章第2、3节）

错误代码得到的结果：
对比一下正确结果：

解决

更新集合问题解决：
PageInfo对象集合对象替换成新集合对象

PageMethod.startPage(dto.getPageNum(), dto.getPageSize());
List<ProductVO> products = productDAO.listProducts(dto);
// stream处理分页结果集,处理后的resultList 集合大小要与原集合products 大小相同
List<ProductVO> resultList = products.stream().map(one -> handleProduct(one)).collect(Collectors.toList());
PageInfo<ProductVO> pageProducts = new PageInfo<>(products);
pageProducts.setList(resultList);
return pageProducts

二、多limit的情况

`ThreadLocal` 与线程复用导致的 “污染”

Springboot项目中内部使用线程池来处理请求。
当一个线程完成一个请求的分页查询后，它的 ThreadLocal 中仍然保存着分页参数。
如果这个线程被线程池复用，去处理查询请求，会导致下一个查询也被添加了分页相关的limit语句

举例说明：线程数为1的线程池，两个查询请求

请求从#1处进入
执行到#2，将分页参数存储到当前线程的ThreadLocal中，后面未跟查询
随后的请求从#3处进入
线程复用，执行#4处时执行的Sql会被自动添加limit ?,?

ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
        1,  // 核心线程数为1
        1,  // 最大线程数为1
        1L, // 线程存活时间1分钟
        TimeUnit.MINUTES,
        new LinkedBlockingQueue<>(5)  // 等待队列大小为5
);

public void listProducts() { //#1
   threadPool.execute(() -> {
        PageHelper.startPage(1, 10); //#2
    });
}
 
public List<ProductVO> listCitys() { //#3
    threadPool.execute(() -> {
        List<City> list = cityDAO.lisCitys(); //#4
        return list;
    });
}

Pagehelper在分页查询后会自动清除ThreadLocal的分页参数。
设置分页参数，但后面未查询，方法直接返回。下次复用线程时，存在线程中的分页参数可能被其他查询消费。

解决

PageMethod.startPage后紧跟查询

PageHelper.startPage(1, 10);
List<Country> list = countryMapper.selectIf(1);

或者lambda用法

//jdk8 lambda用法
Page<Country> page = PageHelper.startPage(1, 10).doSelectPage(()-> countryMapper.selectGroupBy());

使用PageHelper.clearPage()手动清理

PageMethod.startPage(dto.getPageNum(), dto.getPageSize());
List<ProductVO> products = new ArrayList<>();
switch (dto.getBrand()) {
	case "Huawei":
		if ("Huawei".equals(brandToQuery)) {
			products= productDAO.listProducts(dto);
		}
		break;
	case "Apple":
		if ("Apple".equals(brandToQuery)) {
			  products = productDAO.listProducts(dto);
		}
		break;
	default:
		//手动清理
		PageHelper.clearPage()
		break;
}