window frame clause用于定义窗口函数计算范围,默认range按排序值重复包含多行,而rows按物理行数精确控制;实际应优先用rows避免重复键导致的统计偏差。
什么是 window frame clause,它和默认 frame 有什么区别
PostgreSQL 的窗口函数默认使用 RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW,也就是“从分区开头到当前行(按 ORDER BY 排序后)所有值求和”。但这个“所有值”可能包含重复排序键——比如多行 order_time = '2024-01-01 10:00',它们会被一起纳入当前行的 frame,导致求和结果跳变。
ROWS frame 才真正按物理行偏移定义范围,比如 ROWS BETWEEN 2 PRECEDING AND 1 FOLLOWING 明确取前后固定行数,不受排序键重复影响。实际业务中,滚动平均、近 N 天累计、滑动窗口统计等,几乎都该用 ROWS,而不是依赖默认的 RANGE。
常见错误现象:SUM(val) OVER (ORDER BY ts) 在时间戳有重复时,sum 值突然增大一截,且无法预测跳变点。
如何用 ROWS 定义前 N 行滚动求和
这是最常用场景:对每个时间点,计算它及之前 2 行的 amount 总和。
SELECT
id,
ts,
amount,
SUM(amount) OVER (
ORDER BY ts, id
ROWS BETWEEN 2 PRECEDING AND CURRENT ROW
) AS sum_3_rows
FROM sales;
关键点:
-
ORDER BY必须明确、确定(加id是为避免 ts 相同时排序不稳定) -
ROWS BETWEEN 2 PRECEDING AND CURRENT ROW表示“当前行 + 它前面 2 行”,共 3 行 - 开头几行会自动截断:第 1 行只有自身,第 2 行有前 1 行 + 自身,第 3 行才满 3 行
如果想强制补零或补 NULL,得额外用 CASE WHEN ROW_NUMBER() OVER (...) 判断,PostgreSQL 不支持 frame 内自动填充。