1 问题背景

线上有一个批处理任务,会批量读取昨日的数据,经过一系列加工后,插入到今日的表中。表结构如下:

 1 CREATE TABLE `detail_yyyyMMdd` (
2 `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
3 `batch_no` varchar(64) NOT NULL COMMENT '批次号',
4 `order_id` varchar(64) NOT NULL COMMENT '订单ID',
5 `user_id` varchar(64) NOT NULL COMMENT '用户ID',
6 `status` varchar(4) NOT NULL COMMENT '状态',
7 `product_id` varchar(32) NOT NULL COMMENT '产品ID',
8 PRIMARY KEY (`id`),
9 KEY `idx_batchno_userid` (`batch_no`,`user_id`)
10 ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='明细表';

因数据量较大,批量读取昨日数据时,使用了分页查询limit语句,查询sql如下:

SELECT id,batch_no,order_id,user_id,status,product_id FROM detail_yyyyMMdd WHERE batch_no=‘batch_type_yyyyMMdd’ LIMIT ?,?;

从某一天开始,客服频繁收到客诉,反馈数据未更新。

2 问题排查

初步排查,客诉反馈的数据确实没有插入。线上增加了一些业务日志后,发现分页查询昨日数据时,第二次查询的结果集与第一次查询的结果集有重复数据。

与DBA沟通,确认了客诉爆发前一天做了一次数据库变更,兄弟团队为了解决一个慢查询问题,增加了一个索引,变更sql如下:

ALTER TABLE `detail_yyyyMMdd` ADD INDEX `idx_batchno_status_productid` (`batch_no`, `status`, `product_id`);

DBA分析,该变更sql上线前,分页查询会走idx_batchno_userid索引,上线后则走idx_batchno_status_productid,而该索引存在大量重复记录,导致每次分页查询的数据都可能和之前的重复。

为什么索引有重复记录时,分页查询的数据就可能与之前的重复呢?在网上搜了下,这里贴一篇官方的文档:https://dev.mysql.com/doc/refman/5.6/en/limit-optimization.html

If multiple rows have identical values in the ORDER BY columns, the server is free to return those rows in any order, and may do so differently depending on the overall execution plan. In other words, the sort order of those rows is nondeterministic with respect to the nonordered columns.

One factor that affects the execution plan is LIMIT, so an ORDER BY query with and without LIMIT may return rows in different orders.

If it is important to ensure the same row order with and without LIMIT, include additional columns in the ORDER BY clause to make the order deterministic.

在MySQL 5.6的版本上,优化器在遇到order by limit语句时,做了个查询优化,即使用了priority queue(优先级队列)。采用priority queue能够根据limit N维护一个大小为N的堆,在排序的过程中,只用保留N条记录即可。但堆排序是一个不稳定的排序算法,所以当排序字段值存在重复时,返回的数据顺序可能会不一样,其中一个影响因素就是limit。

解决方案:查询语句加上order by id(保证排序字段的唯一性),上线后,问题得到解决。

但仍然存在两个疑点:

  • 原来的索引idx_batchno_userid也会有重复记录,为什么一直没有爆出问题?

  • 线上的查询语句只有limit,没有order by,可以直接按照索引的有序性(索引聚簇表)进行读取并分页,不需要触发priority queue优化。

3 问题定位

仔细观察了两次分页查询的结果集后发现,两次结果集的数据顺序分别对应两个索引,即第一次分页查询走了索引idx_batchno_userid,第二次分页查询走了索引idx_batchno_status_productid,两个索引的数据顺序是不一样的,从而导致两次分页查询的数据存在重复。与DBA交流,MySQL的优化器会基于成本选择最优的索引,而这两个索引的成本相差不大。

这个结论在线下得到复现,但并不能稳定复现。在总结果集没有变化的情况下,两次分页查询分别走了不同索引的根因,还有待继续深挖。

End

MySQL使用limit进行分页查询时,可能会出现重复数据,可以通过加上order by子句并保证排序字段的唯一性来解决。

最新文章

  1. [python] File path and system path
  2. Python读取文件内容并将内容插入到SSDB中
  3. Spring绑定表单数据
  4. ios 返回指定导航控制器
  5. 黄学长模拟day1 大逃亡
  6. test1.A[【dfs简单题】
  7. 【转】Java多线程编程中易混淆的3个关键字( volatile、ThreadLocal、synchronized)总结
  8. CSS3过渡效果实现菜单划出效果
  9. linux新建磁盘并分区
  10. Android: Failure [INSTALL_FAILED_DEXOPT] and Failure [INSTALL_FAILED_UID_CHANGED] 解决方案
  11. [心得]传统IT转互联网面试经验分享
  12. C#的一些获取时间的例子
  13. Matlab 中subsystem mask封装子系统
  14. Petrozavodsk Winter Camp, Warsaw U, 2014, A The Carpet
  15. 官宣 ! 52abp_Pro版本低调上线
  16. Vue(基础七)_webpack使用工具(下)
  17. 使用maven-shade-plugin打包spring项目为可执行的jar包
  18. Java并发之volatile二
  19. Hibernate学习笔记:基础模型类
  20. Tomcat笔记:Tomcat的执行流程解析

热门文章

  1. 【python】Leetcode每日一题-前缀树(Trie)
  2. Redis中几种数据类型的基本操作指令
  3. JVM什么叫安全检测点
  4. Sping AOP
  5. .Net Core导入千万级数据至Mysql
  6. mysql基本命令(增,查,改,删)
  7. 『动善时』JMeter基础 — 22、JMeter中实现参数化(CSV)
  8. 如何安装多个jdk并方便切换系统jdk版本
  9. 测usb读写
  10. Java 单例模式:懒加载(延迟加载)和即时加载