登录
推荐 文章 Go 技术 课程 下载 专题 AI
首页 >  数据库 >  MySQL

MySQL LAG 与 LAST_VALUE 窗口帧的结果边界

来源:17golang原创

时间:2026-10-31 22:21:19 432浏览 收藏

在 MySQL 窗口查询里,LAG() 和 LAST_VALUE() 都会让人联想到“上一条”和“最后一条”,但它们看的范围并不相同:LAG() 按分区和排序位置寻找当前行之前的记录,窗口帧不会把它限制成只看当前帧;LAST_VALUE() 则只返回当前窗口帧的最后一行。因此,LAST_VALUE() 如果沿用带 ORDER BY 的默认帧,往往会得到当前行的值,而不是整个分区的最后值。

官方资料:https://dev.mysql.com/doc/refman/8.4/en/window-functions.html

判断这两个函数的关键不是函数名里的“前”和“后”,而是先确定分区、排序键与窗口帧:要取上一条用 LAG(),要取帧末行用 LAST_VALUE(),要取整个分区末行就显式写出 UNBOUNDED FOLLOWING。

先固定分区和排序键,再谈“最后一行”

下面用账户流水作为例子。每个账户是一个分区,event_no 是账户内递增的事件序号,amount 是当前记录的金额。示例故意保留一个可重复的 event_time,用于说明 RANGE 如何处理 peers。

-- 建立按账户分析的示例表,event_no 用来提供稳定的行位置
CREATE TABLE account_events (
    account_id BIGINT NOT NULL,
    event_no BIGINT NOT NULL,
    event_time DATETIME NOT NULL,
    amount DECIMAL(10, 2) NOT NULL,
    PRIMARY KEY (account_id, event_no)
);

-- 两条记录共享 event_time,后面可用来观察 RANGE 的 peers 边界
INSERT INTO account_events (account_id, event_no, event_time, amount) VALUES
    (101, 1, '2026-10-01 09:00:00', 100.00),
    (101, 2, '2026-10-01 09:10:00', 120.00),
    (101, 3, '2026-10-01 09:10:00', 135.00),
    (101, 4, '2026-10-01 09:20:00', 150.00);
MySQL 分区排序后 LAG 与 LAST_VALUE 取值关系的静态结构说明图
图1:分区和排序键确定行的关系,LAG 指向前序分区行,LAST_VALUE 指向当前窗口帧末行;这是静态结构说明图,不是运行截图。

如果业务真正的顺序是时间,建议仍然把唯一列放在排序表达式里,例如 ORDER BY event_time, event_no。只写 ORDER BY event_time 时,两个相同时间的记录属于同一组 peers,不能把它们当成已经有稳定先后关系。

LAG 取前序分区行,LAST_VALUE 取当前帧末行

下面四列放在同一个查询中,最容易看出差异。第一列 previous_amount 取当前账户记录之前的金额;第二列故意把 LAST_VALUE() 写成默认帧;第三列把帧扩展到整个分区;第四列给 LAG() 一个很窄的帧,说明它并不会因此改变“上一行”的语义。

-- 用 event_no 作为唯一排序键,避免样例结果受 peers 顺序影响
SELECT
    account_id,
    event_no,
    amount,
    LAG(amount) OVER (
        PARTITION BY account_id
        ORDER BY event_no
    ) AS previous_amount,
    -- 带 ORDER BY 时,默认帧到当前行,所以通常等于当前 amount
    LAST_VALUE(amount) OVER (
        PARTITION BY account_id
        ORDER BY event_no
    ) AS last_in_default_frame,
    -- 显式覆盖到分区末行,得到同一账户的最终 amount
    LAST_VALUE(amount) OVER (
        PARTITION BY account_id
        ORDER BY event_no
        ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING
    ) AS last_in_partition,
    -- LAG 的取值基于分区排序位置,窄帧不会把它变成当前行
    LAG(amount) OVER (
        PARTITION BY account_id
        ORDER BY event_no
        ROWS BETWEEN CURRENT ROW AND CURRENT ROW
    ) AS previous_amount_with_narrow_frame
FROM account_events
ORDER BY account_id, event_no;

对账户 101,可以按下面的方式理解结果:

event_noamountLAG默认 LAST_VALUE全分区 LAST_VALUE
1100.00NULL100.00150.00
2120.00100.00120.00150.00
3135.00120.00135.00150.00
4150.00135.00150.00150.00

这里的“默认 LAST_VALUE 等于当前值”不是函数失效,而是默认帧的边界决定的。MySQL 文档把带 ORDER BY 且未显式指定帧的默认值定义为从分区开始到当前行,并把当前排序值相同的 peers 一并纳入。

默认帧为什么会让 LAST_VALUE 看起来像当前值

带 ORDER BY 的默认帧可以近似写成:

-- 默认帧的等价写法:包含当前行及其排序值相同的 peers
RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW

因此,窗口走到第三行时,当前帧的末端通常就是第三行;LAST_VALUE(amount) 当然会返回第三行的 amount。如果目标是“这个账户最后一次事件的金额”,应该把结束边界明确写成 UNBOUNDED FOLLOWING:

-- 取整个账户分区的末值,而不是当前累计帧的末值
LAST_VALUE(amount) OVER (
    PARTITION BY account_id
    ORDER BY event_no
    ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING
) AS final_amount

如果目标只是“截至当前事件,当前累计范围的末值”,默认写法可以保留,但建议在团队 SQL 中显式写出 ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW,让读者不必猜默认规则。

MySQL LAST_VALUE 默认帧与完整分区帧边界对照的静态说明图
图2:默认帧在 CURRENT ROW 处收口,显式全分区帧延伸到 UNBOUNDED FOLLOWING;这是窗口边界结构图,不是查询截图。

ROWS、RANGE 和重复排序值要分开处理

ROWS 按物理行位置定义范围,RANGE 按排序值定义范围。排序列出现重复值时,RANGE ... CURRENT ROW 的当前行边界会包含同值 peers;这正是只按时间排序时最容易产生误解的地方。

-- 只按时间排序:相同 event_time 的记录属于同一 peers 组
SELECT
    account_id,
    event_no,
    event_time,
    amount,
    LAST_VALUE(amount) OVER (
        PARTITION BY account_id
        ORDER BY event_time
        RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
    ) AS range_last_value,
    -- 增加唯一 event_no 后,ROWS 的位置边界更容易解释
    LAST_VALUE(amount) OVER (
        PARTITION BY account_id
        ORDER BY event_time, event_no
        ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
    ) AS rows_last_value
FROM account_events
ORDER BY account_id, event_time, event_no;

实践中可以遵循三个约束:

  • 需要“第几条”时,把唯一键加入 ORDER BY,并优先使用 ROWS 表达行位置。
  • 需要按同一排序值成组累计时,才使用 RANGE,并在注释中写明 peers 会同时进入当前帧。
  • 需要整个分区的末值时,无论排序列是否重复,都显式写 ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING。

按业务目标选择窗口表达式

不要把 LAST_VALUE() 当成“最大值”或“最后插入的值”。它只寻找窗口帧的最后一行;如果要比较数值大小,应该使用 MAX() 这样的聚合窗口函数。

业务目标推荐表达式需要注意
取当前分区的上一条金额LAG(amount) OVER (PARTITION BY ... ORDER BY 唯一键)第一行没有前序行时默认返回 NULL,可按需提供默认值。
取当前帧末行LAST_VALUE(amount) OVER (... ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)这是累计到当前行的结果,不是全分区末值。
取整个分区末行LAST_VALUE(amount) OVER (... ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING)结束边界必须到 FOLLOWING。
取分区中的最大金额MAX(amount) OVER (PARTITION BY account_id)最大值与最后一行可能属于不同记录。

如果需要同时比较前后金额,可以把 LAG() 的偏移量和默认值写清楚:

-- 偏移量为 1;分区第一行没有上一条时用 0 代替 NULL
LAG(amount, 1, 0) OVER (
    PARTITION BY account_id
    ORDER BY event_time, event_no
) AS previous_amount

常见误区和边界问题

为什么 LAST_VALUE 没有返回分区最后一条

因为默认帧在当前行结束。把结束边界改为 UNBOUNDED FOLLOWING,并配合稳定的排序键,才能表达“整个分区末值”。

给 LAG 写窗口帧有用吗

对 LAG() 来说,核心是分区内的偏移位置;窗口帧不会把它改成帧内查找函数。为了避免误读,通常不需要给 LAG() 额外添加帧子句。

ORDER BY 只有时间列会怎样

相同时间的记录是 peers。若业务要求明确的先后关系,应追加自增序号、主键或其它唯一列;否则不要把同一时间组内的返回顺序当成稳定契约。

可以用 LAST_VALUE 取最新金额吗

可以,但前提是排序列确实表达“最新”,并且末行边界写到了分区末端。如果只是要数值最大金额,应使用 MAX(),两者语义不同。

小结

LAG() 解决的是“当前行之前的第 N 行”,LAST_VALUE() 解决的是“当前窗口帧的最后一行”。带排序的默认帧通常只到当前行,所以 LAST_VALUE 经常等于当前值。写查询前先确定分区和唯一排序键,再根据目标选择默认累计帧、显式全分区帧或 MAX(),结果边界就不会被函数名带偏。

声明:本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>