Snowflake SQL：基于条件启动行号或排名的实现方法

问题分析 #

你需要基于Start Time分组，当15 Min Increment与Start Time匹配时启动连续计数，生成示例中的Rank列。核心是确定每个分组内的计数起始锚点，然后对后续行按时间增量顺序生成连续序号。

解决方案 #

方法一：利用时间差直接计算（适用于增量连续的场景） #

如果你的15 Min Increment是从Start Time开始严格按15分钟递增的（如示例数据），可以直接通过时间差计算序号，效率最高：

SELECT
    start_time,
    fifteen_min_increment,
    -- 计算从起始时间到当前增量的分钟差，转换为15分钟间隔数后加1得到Rank
    1 + TIMEDIFF('minute', start_time, fifteen_min_increment) / 15 AS rank
FROM your_table
-- 按分组和增量时间排序，保证结果顺序正确
ORDER BY start_time, fifteen_min_increment;

验证示例数据：

• 21:00与21:00的分钟差为0，0/15 +1 =1
• 21:00与21:15的分钟差为15，15/15 +1=2，以此类推，完全匹配示例结果。

方法二：通用锚点计数法（适用于复杂场景） #

如果分组内可能存在Start Time之前的增量行，或者起始锚点不是分组第一行，可通过标记锚点位置再计算序号：

WITH marked_rows AS (
    SELECT
        start_time,
        fifteen_min_increment,
        -- 标记当前行是否为计数起始锚点
        CASE WHEN fifteen_min_increment = start_time THEN 1 ELSE 0 END AS is_start,
        -- 生成分组内的行顺序号
        ROW_NUMBER() OVER(PARTITION BY start_time ORDER BY fifteen_min_increment) AS rn
    FROM your_table
),
anchor_points AS (
    SELECT
        start_time,
        -- 找到每个分组的起始锚点位置
        MIN(CASE WHEN is_start = 1 THEN rn END) AS start_rn
    FROM marked_rows
    GROUP BY start_time
)
SELECT
    mr.start_time,
    mr.fifteen_min_increment,
    -- 仅从锚点开始计数，锚点前的行返回NULL（可根据需求改为0或其他值）
    CASE WHEN mr.rn >= ap.start_rn THEN mr.rn - ap.start_rn + 1 ELSE NULL END AS rank
FROM marked_rows mr
JOIN anchor_points ap ON mr.start_time = ap.start_time
ORDER BY mr.start_time, mr.fifteen_min_increment;

常见问题说明 #

你之前尝试CASE结合ROW_NUMBER未成功，大概率是没有明确锚点的位置，直接对整个分组生成序号。上述方法通过锁定锚点，再基于锚点位置计算相对序号，就能实现需求中的计数逻辑。

内容的提问来源于stack exchange，提问作者messy_tess