基于EventName条件使用FIRST_VALUE窗口函数获取最新偏好币种

我懂你要解决的问题——就是想在表中新增一列PreferredCurrencyCurrent，专门提取EventName为AccountCreated或AccountUpdatedEvent2的记录里，PreferredCurrency的最新值对吧？下面给你两种实用的实现方案，适配Snowflake以及所有支持窗口函数的SQL方言。

方案一：用LAST_VALUE结合条件过滤（推荐） #

这种方法直接在窗口函数里完成过滤和取值，逻辑紧凑高效。假设你的表是按账户维度区分数据的（比如有AccountId字段），代码示例如下：

SELECT
    *,
    -- 仅筛选目标事件的货币值，跳过NULL取最新的非空值
    LAST_VALUE(CASE WHEN EventName IN ('AccountCreated', 'AccountUpdatedEvent2') THEN PreferredCurrency END IGNORE NULLS)
        OVER (
            PARTITION BY AccountId  -- 按账户分组，确保每个账户的最新值独立计算
            ORDER BY EventTimestamp  -- 按事件时间排序，保证取到最新的记录
            ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW  -- 范围覆盖从第一条到当前行的所有记录
        ) AS PreferredCurrencyCurrent
FROM your_sample_table;

关键细节解释： #

• CASE WHEN：先过滤出符合EventName条件的记录，不符合的返回NULL；
• IGNORE NULLS：让LAST_VALUE自动跳过这些NULL值，只取最新的有效货币值；
• 如果你的数据不需要按账户分组（比如全局唯一的最新值），直接去掉PARTITION BY AccountId即可。

如果你的SQL方言不支持IGNORE NULLS，可以用FILTER子句替代（部分方言支持）：

LAST_VALUE(PreferredCurrency) OVER (
    PARTITION BY AccountId
    ORDER BY EventTimestamp
    ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
    FILTER (WHERE EventName IN ('AccountCreated', 'AccountUpdatedEvent2'))
) AS PreferredCurrencyCurrent

方案二：子查询+关联（更直观） #

如果觉得窗口函数的逻辑有点绕，也可以先通过子查询找出每个账户的最新目标事件记录，再关联回原表：

-- 先筛选出每个账户的最新目标事件货币值
WITH latest_currency_data AS (
    SELECT
        AccountId,
        PreferredCurrency,
        -- 按时间倒序排，取每个账户的第一条（最新）记录
        ROW_NUMBER() OVER (PARTITION BY AccountId ORDER BY EventTimestamp DESC) AS row_rank
    FROM your_sample_table
    WHERE EventName IN ('AccountCreated', 'AccountUpdatedEvent2')
)
SELECT
    st.*,
    lcd.PreferredCurrency AS PreferredCurrencyCurrent
FROM your_sample_table st
-- 关联回原表，拿到对应账户的最新货币值
LEFT JOIN latest_currency_data lcd 
    ON st.AccountId = lcd.AccountId 
    AND lcd.row_rank = 1;

这种方法的好处是逻辑清晰，容易调试，适合复杂的过滤场景。

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