Snowflake中Materialized View如何强制客户端查询时携带eventDate过滤条件

以下是3种可落地的实现方式：

方案1：使用行访问策略（Row Access Policy） #

这是最常用的方案，通过绑定到物化视图的行访问策略，校验查询是否携带eventDate过滤条件，不符合要求的查询要么返回空结果，要么直接抛出错误。
示例代码：

-- 创建行访问策略
CREATE OR REPLACE ROW ACCESS POLICY require_event_date_filter
ON MATERIALIZED VIEW <你的物化视图名称>
AS (eventDate DATE)
RETURNS BOOLEAN ->
CASE
    -- 匹配所有eventDate的过滤逻辑，可根据业务调整匹配规则
    WHEN REGEXP_LIKE(CURRENT_STATEMENT(), 'eventDate\s*(=|>|<|>=|<=|BETWEEN)', 'i')
    THEN TRUE
    -- 不符合条件直接抛出自定义错误
    ELSE RAISE_APPLICATION_ERROR(-20001, '查询该视图必须包含eventDate字段的有效过滤条件')
END;

-- 将策略绑定到物化视图
ALTER MATERIALIZED VIEW <你的物化视图名称> ADD ROW ACCESS POLICY require_event_date_filter ON (eventDate);

方案2：封装为带参数的表函数，回收原视图直接访问权限 #

该方案完全杜绝用户直接访问物化视图，仅允许通过传入强制日期参数的表函数查询数据，不会出现规则误判的问题。
示例代码：

-- 1. 回收普通用户对原物化视图的直接查询权限
REVOKE SELECT ON MATERIALIZED VIEW <你的物化视图名称> FROM ROLE <普通用户角色>;

-- 2. 创建强制传入日期范围参数的表函数，字段和原视图完全对齐
CREATE OR REPLACE FUNCTION query_mv_by_date(start_date DATE, end_date DATE)
RETURNS TABLE (
    -- 此处填写和你的物化视图完全一致的字段定义
    eventDate DATE,
    col1 STRING,
    col2 NUMBER,
    ...
)
AS $$
SELECT * FROM <你的物化视图名称> WHERE eventDate BETWEEN start_date AND end_date;
$$;

-- 3. 给普通用户开放表函数的调用权限
GRANT USAGE ON FUNCTION query_mv_by_date(DATE, DATE) TO ROLE <普通用户角色>;

用户侧查询时只需要调用函数即可：SELECT * FROM TABLE(query_mv_by_date('2024-01-01'::DATE, '2024-01-07'::DATE));

方案3：使用查询策略（Query Policy）全局拦截 #

适合需要对多个大表/视图做统一过滤校验的场景，在账户级别对所有命中目标视图的查询做校验，不符合要求直接拦截。
示例代码：

CREATE OR REPLACE QUERY POLICY block_unfiltered_mv_query
ON ACCOUNT
AS ()
RETURNS BOOLEAN ->
CASE
    -- 命中目标视图且没有携带eventDate过滤条件的查询直接拒绝
    WHEN REGEXP_LIKE(CURRENT_STATEMENT(), '<你的物化视图名称>', 'i')
        AND NOT REGEXP_LIKE(CURRENT_STATEMENT(), 'eventDate\s*(=|>|<|>=|<=|BETWEEN)', 'i')
    THEN FALSE
    ELSE TRUE
END;

注意事项 #

• 涉及CURRENT_STATEMENT()做规则匹配的方案，建议用正则做更精准的匹配，避免因为空格、大小写、注释内容导致误判。
• 表函数方案改造成本略高，但可控性最强，不会出现规则漏判的情况。

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