怎样在SQL中利用窗口函数计算连续非空状态的累计值-SQL-PHP中文网

“连续非空状态”的累计值需在NULL处重置，正确做法是先用SUM(CASE WHEN val IS NULL THEN 1 ELSE 0 END) OVER (ORDER BY id)生成分组ID，再按该ID分区并窗口求和，而非简单SUM() OVER (ORDER BY ...)。

怎样在sql中利用窗口函数计算连续非空状态的累计值

什么是“连续非空状态”的累计值

这不是简单的 SUM() OVER (ORDER BY ...)。它要求：一旦某行的值为 NULL，累计就中断；后续非空值从头开始累加，而不是跳过 NULL 继续累计。比如数据序列 [1, 2, NULL, 3, 4]，期望结果是 [1, 3, NULL, 3, 7]，而非 [1, 3, NULL, 6, 10]。

用条件分组（GROUP BY 连续段）实现重置累计

核心思路是：先给每段连续非空记录打上唯一组号，再在组内做窗口求和。组号通过「前一行是否为空」的累积变化来构造。

关键操作：LAG() 判断上一行是否为空，SUM() OVER (ORDER BY ...) 累积生成分组 ID：

SELECT
  id,
  val,
  SUM(val) OVER (
    PARTITION BY grp 
    ORDER BY id
    ROWS UNBOUNDED PRECEDING
  ) AS running_sum
FROM (
  SELECT *,
    SUM(CASE WHEN LAG(val) OVER (ORDER BY id) IS NULL THEN 1 ELSE 0 END)
      OVER (ORDER BY id) AS grp
  FROM t
) t1;

注意点：

LAG(val) IS NULL 表示上一行 val 是空 —— 这标志着新连续段开始（第一行默认上一行为空，所以首段 grp=0）
实际中更稳妥的做法是用 val IS NULL 反向标记断点：SUM(CASE WHEN val IS NULL THEN 1 ELSE 0 END) OVER (ORDER BY id)，再用该和作为分组键（这样每遇到一个 NULL，grp 就 +1，所有非空块自然被隔离）
PostgreSQL/SQL Server 支持 ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW，MySQL 8.0+ 同样适用；但旧版 MySQL 或 SQLite 不支持窗口函数，这条路走不通

处理边界：首行、全空、连续 NULL

上面逻辑对首行友好（LAG() 返回 NULL，触发 grp 增量），但若首行 val 就是 NULL，它会被归入 grp=0 的“空段”，后续第一个非空值会落在 grp=1 段 —— 这符合语义。

需警惕的情况：

排序字段 id 必须严格递增且无重复，否则 LAG() 和 OVER (ORDER BY ...) 行为不可靠
若存在多个 NULL 连续，它们各自不参与累计，但会把前后非空段切开成不同 grp，这是预期行为
某些数据库（如 BigQuery）对 NULL 在 SUM() 中自动忽略，无需额外 CASE；但若字段是字符串或需要计数，就得改用 COUNT(val) 并确认是否跳过 NULL