当前位置：首页 > 文章列表 > 数据库 > MySQL > MySQL 窗口函数取每组最新记录时如何处理并列时间

MySQL 窗口函数取每组最新记录时如何处理并列时间

来源：17golang原创 2026-09-09 08:32:59 0浏览收藏

做“每个客户取最新一条状态”时，真正容易出错的不是窗口函数语法，而是最新时间可能相同。只写 ORDER BY event_time DESC，MySQL 仍然要在并列行中编号；如果业务没有说明谁优先，外层的 rn = 1 就只是“任选一行”。

需要每组稳定保留一条时，用 ROW_NUMBER() 并把唯一键放进排序；需要保留同一最新时间的所有记录时，用 RANK()，不要用 ROW_NUMBER() 静默丢掉并列项。

要点速览

分组键写在 PARTITION BY，最新优先写在窗口 ORDER BY。
时间不是唯一值时，再用自增主键、事件序号或明确的业务优先级打破平局。
“只选一条”和“全部并列都要”是两种结果契约，分别对应 ROW_NUMBER 和 RANK。

为什么“最新时间”会在并列时变成不稳定结果

假设表 customer_order_events 保存订单状态：customer_id 是分组键，event_time 是事件时间，id 是唯一主键。同一个客户在同一秒写入两条状态并不罕见，尤其是批处理补写或多个服务同时落库。

下面这段查询能给每组编号，但排序条件没有覆盖并列项：

SELECT id, customer_id, event_time, status,
       ROW_NUMBER() OVER (
           PARTITION BY customer_id
           ORDER BY event_time DESC -- 只按时间，时间相同仍会并列
       ) AS rn
FROM customer_order_events;

MySQL 手册明确说明，ROW_NUMBER() 会给并列行不同的编号；ORDER BY 影响编号顺序。于是两个相同 event_time 的行可能分别得到 1 和 2，但第一名并没有业务含义。查询偶尔“换一条”时，不要先归咎于窗口函数失效，先检查排序键是否足够唯一。

用 ROW_NUMBER 给并列记录补上确定排序

MySQL customer_order_events 按 customer_id 分区，以 event_time DESC 和 id DESC 排序后由 ROW_NUMBER 生成 rn 并筛选 rn=1 的查询结构图 — 图1：把分组、复合排序、ROW_NUMBER 编号和 rn=1 筛选放在同一条查询结构中，理解并列时间为什么需要唯一键。

如果需求是“每个客户只留一条”，就必须先写出并列时的胜出规则。下面约定时间相同取 id 较大的事件；如果业务更看重状态优先级，也可以把优先级放到时间前面，但规则必须明确。

WITH ranked_events AS (
    SELECT id, customer_id, event_time, status,
           ROW_NUMBER() OVER (
               PARTITION BY customer_id
               ORDER BY event_time DESC, id DESC -- 时间相同取较新的唯一 id
           ) AS rn
    FROM customer_order_events
)
SELECT id, customer_id, event_time, status
FROM ranked_events
WHERE rn = 1; -- 窗口编号完成后，再筛每组第一行

这里的关键不是把 id 当成“时间”，而是把它当作确定性的平局裁判。若表里有可靠的 event_seq，优先使用事件序号；若业务规定“已支付”优先于“待支付”，则应写成 ORDER BY event_time DESC, status_priority DESC, id DESC，并确保最后仍有唯一键兜底。

如果业务要保留所有最新记录怎么办

MySQL 用 event_time 分别驱动 ROW_NUMBER 和 RANK，rn=1 只保留一行而 rnk=1 保留并列最新记录的语义对比图 — 图2：比较 ROW_NUMBER 与 RANK 的结果边界，看到单行策略和并列保留策略并不是同一个业务答案。

例如一个客户在相同时间产生了两条合法状态，报表要求两条都展示。这时应让相同排序值共享排名：

WITH ranked_events AS (
    SELECT id, customer_id, event_time, status,
           RANK() OVER (
               PARTITION BY customer_id
               ORDER BY event_time DESC -- 相同时间的行共享第一名
           ) AS rnk
    FROM customer_order_events
)
SELECT id, customer_id, event_time, status
FROM ranked_events
WHERE rnk = 1; -- 保留每组全部并列最新行

RANK 与 DENSE_RANK 都会让并列行得到相同排名；区别在于后续排名是否跳号。本题只取第一名，两者结果相同。若改回 ROW_NUMBER，即使不报错，也会把并列项拆成不同编号，因此不适合“全部最新记录”的契约。

把查询结果接回原表时检查什么

检查点	要确认的规则	常见后果
时间字段	是否可能为 NULL，时区是否统一	最新顺序与业务理解不一致
平局键	是否有唯一、稳定、可解释的第二排序键	同一客户的第一行不稳定
排名函数	只要一条用 ROW_NUMBER，全部并列用 RANK	报表少行或误合并状态
过滤位置	先完成窗口编号，再在外层过滤 rn/rnk	窗口编号范围被提前缩小