MySQL 窗口函数取每组最新记录时怎样稳定排序
在订单、设备、用户等分组数据里,“每组最新一条”看起来只是排序后取第一行,但真正上线后最容易出现两个问题:同一组有相同时间戳时,结果偶尔换人;要取每组前 3 条时,并列记录又不知道应该严格保留 3 行,还是把并列项一起带上。稳定写法是把窗口定义拆成三部分:PARTITION BY 划分分组,窗口内 ORDER BY 定义组内顺序,再用唯一键完成最后的平局裁决。
官方地址:https://dev.mysql.com/doc/refman/8.4/en/window-functions-usage.html
如果题目是“每组固定取几行”,优先使用ROW_NUMBER();如果并列记录必须同进同出,再考虑RANK()或DENSE_RANK()。时间字段不是唯一排序键时,要在窗口排序末尾补上主键或其他唯一列。
先把“最新”写成完整排序规则
假设有一张订单状态表,每次状态变化都会产生一行:
CREATE TABLE order_status_log (
id BIGINT PRIMARY KEY,
order_id BIGINT NOT NULL,
status VARCHAR(32) NOT NULL,
changed_at DATETIME(6) NOT NULL,
operator_id BIGINT NULL
);
-- 先按订单分组,再按变更时间倒序;id 用来处理同一时刻的并列
CREATE INDEX idx_order_status_latest
ON order_status_log (order_id, changed_at DESC, id DESC);
这里的“最新”并不是单独的 changed_at DESC,而是一个有优先级的排序元组:先比较时间,时间相同再比较 id。如果业务规定时间相同的记录按导入批次、版本号或状态序号决定,就把那个字段放在唯一键之前。关键是最终必须有一个能区分行的稳定字段,否则 SQL 只能知道两行属于同一并列组,不能凭空决定谁排第一。
ROW_NUMBER 怎样稳定取每组最新一条
窗口函数不会把分组压成一行,而是为每一行计算组内结果。PARTITION BY order_id 把订单状态分成多个窗口,ORDER BY changed_at DESC, id DESC 决定每个窗口的顺序,外层查询再保留编号为 1 的行:
WITH ranked AS (
SELECT
id,
order_id,
status,
changed_at,
operator_id,
ROW_NUMBER() OVER (
PARTITION BY order_id
ORDER BY changed_at DESC, id DESC
) AS rn
FROM order_status_log
)
SELECT id, order_id, status, changed_at, operator_id
FROM ranked
WHERE rn = 1
ORDER BY order_id;
这条语句的稳定性来自两个地方:第一,窗口排序写在 OVER 内,而不是只在查询末尾写一个全局排序;第二,时间相同的行由 id DESC 裁决。最后的 ORDER BY order_id 只负责结果集展示顺序,它不会替代窗口内部的排序。

每组前 N 条时,三种排名函数怎样选
“前 3 条”可能有两种不同含义:一种是每组严格返回 3 行,另一种是第 3 名并列的记录也要全部返回。三种函数的差异可以用同一组排序值理解:
| 函数 | 并列时的编号 | 适合的业务语义 |
|---|---|---|
ROW_NUMBER() | 并列行仍各得不同编号 | 严格每组取固定行数,需要可复现裁决 |
RANK() | 并列同名次,后续名次跳号 | 按真实名次取前 N 名,并列可能让行数超过 N |
DENSE_RANK() | 并列同名次,后续名次不跳号 | 按不间断的等级取前 N 组分值 |
例如每个店铺取销售额前 3 名,且销售额相同的商品必须同进同出,可以使用 RANK():
WITH ranked AS (
SELECT
shop_id,
product_id,
sales_amount,
sold_at,
RANK() OVER (
PARTITION BY shop_id
ORDER BY sales_amount DESC
) AS sales_rank
FROM shop_product_sales
)
SELECT shop_id, product_id, sales_amount, sold_at, sales_rank
FROM ranked
WHERE sales_rank
如果要求“每组一定三行”,就改成 ROW_NUMBER(),并在窗口内加上确定性的平局键,例如 product_id DESC。如果要求的是前三个不同销售额等级,则用 DENSE_RANK(),但要先确认并列值的业务含义,而不是看到函数名相近就替换。

窗口结果为什么要放到外层再筛选
窗口函数发生在结果行形成之后,不能像普通列一样直接放进同一层的 WHERE。因此要先在 CTE 或派生表里计算排名,再由外层筛选:
SELECT order_id, status, changed_at
FROM (
SELECT
order_id,
status,
changed_at,
id,
-- 外层只需要判断 rn,内层负责完整排序
ROW_NUMBER() OVER (
PARTITION BY order_id
ORDER BY changed_at DESC, id DESC
) AS rn
FROM order_status_log
) AS ranked
WHERE rn
外层的排序也建议写清楚。否则即使每组编号已经稳定,最终返回的不同分组之间仍然没有展示顺序保证。对于分页接口,还应把外层排序和分页键设计成一致的稳定顺序,避免翻页时同一条记录在边界附近重复或消失。
用固定数据和 EXPLAIN 检查排序是否真的稳定
这类查询不需要靠“多跑几次看起来没变”来判断。准备至少包含同一分组相同时间、相同分值和不同唯一键的数据,逐项确认:
PARTITION BY只包含真正的分组字段,没有把状态或时间误放进去。- 窗口
ORDER BY的第一排序键符合“最新”或“最高”的业务定义。 - 末尾存在唯一键或等价的唯一组合,能处理所有并列。
ROW_NUMBER的过滤结果是每组固定行数;RANK或DENSE_RANK的结果行数则按并列规则解释。- 外层
ORDER BY与接口需要的展示、分页顺序一致。
EXPLAIN
WITH ranked AS (
SELECT
order_id,
status,
changed_at,
id,
-- 计划检查关注分组、排序和外层过滤的代价
ROW_NUMBER() OVER (
PARTITION BY order_id
ORDER BY changed_at DESC, id DESC
) AS rn
FROM order_status_log
)
SELECT order_id, status, changed_at
FROM ranked
WHERE rn = 1
ORDER BY order_id;
索引可以帮助缩小扫描范围,但不要把“有索引”误认为“结果自动稳定”。稳定性首先由窗口排序语义决定,执行计划则用来观察扫描、排序和数据量是否符合预期。表数据量大时,再结合实际版本、统计信息和执行计划调整索引,不要为了凑一个索引顺序改变业务排序。
最后记住这条选择规则
每组最新一条:ROW_NUMBER() OVER (PARTITION BY 分组 ORDER BY 时间 DESC, 唯一键 DESC),外层取 rn = 1。每组严格前 N 行:使用 ROW_NUMBER();并列必须全部保留:使用 RANK();按不间断等级筛选:使用 DENSE_RANK()。任何情况下,都要把并列处理写成明确的业务决定,而不是依赖数据库在缺少完整排序键时的偶然输出。
相关问题
窗口函数中的 ORDER BY 和最终 ORDER BY 是一回事吗?
不是。前者决定每个分组内的排名,后者决定最终结果集的展示顺序,两者可以相同,也可以不同,但都应按需求明确写出。
只按时间排序为什么会出现最新记录变化?
当同一分组的多行时间相同时,它们属于并列行;如果没有唯一键作为后续排序条件,SQL 没有规定哪一行先出现。
ROW_NUMBER 能不能直接写在 WHERE 里?
不能在同一查询层直接这样筛选,应先用 CTE 或派生表计算编号,再由外层过滤。
Go 子进程继承文件描述符数量不对怎么办
- 上一篇
- Go 子进程继承文件描述符数量不对怎么办
- 下一篇
- MySQL 用 LAG 比较相邻记录时怎样处理首行
-
- 数据库 · MySQL | 59分钟前 |
- MySQL 逻辑备份怎样处理并发写入窗口
- 444浏览 收藏
-
- 数据库 · MySQL | 1小时前 | MySQL · 主从复制 · replica_parallel_workers MySQL 复制延迟
- MySQL 复制延迟怎样按并行工作线程分析
- 488浏览 收藏
-
- 数据库 · MySQL | 1小时前 |
- MySQL 一致性快照怎样影响长事务读
- 214浏览 收藏
-
- 数据库 · MySQL | 1小时前 | MySQL · explain · optimizer trace MySQL 查询计划
- MySQL 查询计划选择异常时怎样读取 optimizer trace
- 466浏览 收藏
-
- 数据库 · MySQL | 1小时前 | MySQL · 执行计划 · 查询优化 · 分区表 · mysql partition pruning 分区裁剪 RANGE COLUMNS EXPLAIN partitions
- MySQL 分区裁剪未生效时怎样定位条件写法
- 124浏览 收藏
-
- 数据库 · MySQL | 1小时前 |
- MySQL 怎样判断两个 JSON 数组是否有交集
- 498浏览 收藏
-
- 数据库 · MySQL | 1小时前 | MySQL · JSON · mysql JSON数组 JSON_TABLE 重复行 NESTED PATH FOR ORDINALITY
- MySQL JSON_TABLE 展开数组后怎样避免重复行
- 406浏览 收藏
-
- 数据库 · MySQL | 1小时前 |
- MySQL 用 LAG 比较相邻记录时怎样处理首行
- 303浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- PubMedQA
- 深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
- 507次使用
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 569次使用
-
- LMArena
- LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
- 593次使用
-
- HELM
- 深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
- 546次使用
-
- MMBench
- MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
- 364次使用
-
- MySQL 明明加了索引,为什么查询还是很慢?先查这 6 个点
- 2026-06-27 374浏览
-
- golang MySQL实现对数据库表存储获取操作示例
- 2022-12-22 499浏览
-
- golang 基于 mysql 简单实现分布式读写锁
- 2023-01-07 384浏览
-
- 详解如何利用GORM实现MySQL事务
- 2023-01-07 184浏览
-
- Go语言实现操作MySQL的基础知识总结
- 2023-01-23 265浏览
