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

MySQL 窗口函数按分组累计求和的窗口范围设置方法

来源:17golang原创

时间:2026-11-07 19:40:07 336浏览 收藏

MySQL 按客户、订单或设备分组计算累计金额时,稳定写法是把三个条件一起放进窗口定义:PARTITION BY 负责分组,ORDER BY 负责顺序,ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW 负责从组首行累计到当前行。只写 SUM(amount) OVER (PARTITION BY customer_id) 得到的是组内总额重复列,并不是逐行增长的累计值。

官方文档:https://dev.mysql.com/doc/refman/8.4/en/window-functions-frames.html

需要逐行累计时,优先显式写出排序键和 ROWS 窗口帧;如果排序列可能重复,再补一个唯一键,避免同一时间的记录顺序不稳定。
要点速览
  • 先确定分组列、排序列和累计列,再写窗口函数。
  • ROWS 按物理行扩展;RANGE 可能把排序值相同的行视为同一范围。
  • 累计结果、组内总额和取每组最后一条是三个不同任务,不要用一个窗口定义混用。

分组、排序和累计边界要同时写清

假设表名为 payments,字段包括 customer_id、paid_at、自增键 id 和金额 amount。按客户分别累计时,可以这样写:

SELECT
    customer_id,
    paid_at,
    amount,
    -- 同一客户从第一笔累计到当前行
    SUM(amount) OVER (
        PARTITION BY customer_id
        ORDER BY paid_at, id
        ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
    ) AS running_total
FROM payments
ORDER BY customer_id, paid_at, id;

PARTITION BY customer_id 让客户 A 的累计值不会带入客户 B;ORDER BY paid_at, id 先按业务时间排序,再用唯一键处理同一时间的多笔记录。窗口函数仍为每一行返回结果,不会像普通 GROUP BY 那样压缩成一行。

MySQL 窗口函数按 customer_id 分组并按 paid_at 和 id 计算 running_total 的结构说明图
图1:累计求和的分组与排序关系说明图,不是截图或运行证据。
窗口部分作用缺失时的风险
PARTITION BY隔离每个客户或业务组所有行可能进入同一累计序列
ORDER BY定义累计先后结果顺序不可解释或不稳定
ROWS ... CURRENT ROW从组首行累计到当前物理行并列排序值可能出现跳变

ROWS 与 RANGE 不是等价写法

窗口中有 ORDER BY 时,帧的含义会影响重复排序值。ROWS 以物理行计数:当前行向前扩展一行,累计值逐行变化。RANGE 以排序值范围判断边界:如果两笔记录的 paid_at 相同,它们可能被放进同一个当前范围,因此结果会在同一时间点一起增加。

如果业务要求“同一时间戳仍按入库顺序逐笔累计”,使用 ORDER BY paid_at, id 并显式声明 ROWS。如果业务只关心“截至某个时间点的累计”,并列时间应当一起结算,那么可以保留值域语义,但要明确它不是逐物理行的结果。不要只靠默认帧规则猜结果。

MySQL ROWS 与 RANGE 在重复 paid_at 排序值下的窗口帧边界对比说明图
图2:ROWS 与 RANGE 的窗口帧边界对比说明图,不是截图或运行证据。

用边界数据检查累计结果

先用四类边界检查查询含义。第一,同一客户只有一笔记录时,累计值应等于金额本身;第二,同一客户同一 paid_at 有多笔记录时,检查是否需要唯一键;第三,退款等负数金额应参与累计,但不能把负数误当成异常空值;第四,若还需要组内最终总额,应单独使用 SUM(amount) OVER (PARTITION BY customer_id),不要拿最后一行的累计值代替所有场景。

累计查询常见的修正顺序是:先确认分组键,再确认排序是否唯一,最后确认使用 ROWS 还是值域范围。日期过滤也要放在窗口计算之前的结果集上,否则你看到的可能只是筛选区间内的累计,不是全历史累计。

相关问题

为什么 SUM OVER 计算出来每行都一样?

通常只写了 PARTITION BY 而没有写排序和当前行帧,此时表达的是每组总额重复展示。需要逐行增长时补上 ORDER BY 与 ROWS ... CURRENT ROW。

同一时间有多条记录,必须增加 id 吗?

如果结果需要逐笔稳定复现,应该增加唯一键或其他确定性排序列。否则同一时间的行没有明确先后,累计值对应哪一行就无法作为稳定契约。

取每组最后一条和累计求和一样吗?

不一样。累计求和为每行产生历史累计;取每组最后一条需要先排序并筛选排名为一的行,属于另一个查询任务。

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