Snowflake SQL存储过程中CASE分支执行查询的语法错误排查

可以实现，Snowflake的SQL存储过程支持使用IF/ELSE流程控制来根据参数值执行不同查询。以下是针对你的问题的错误分析及修正方案：

错误分析 #

你的代码存在几个关键语法问题：

1. CASE语句误用：SQL存储过程中的CASE是表达式（用于返回值），不能直接在分支内执行赋值、EXECUTE IMMEDIATE或RETURN语句，流程控制应使用IF/ELSE。
2. 比较运算符错误：将赋值运算符:=当成了比较运算符=，判断参数值应该用=。
3. 返回类型不一致：存储过程声明返回TABLE()，但ELSE分支返回字符串，类型不匹配，必须统一返回结果集。
4. 逻辑顺序错误：res的赋值和RETURN语句的位置不符合流程控制的执行逻辑。

修正后的代码示例 #

假设你的查询返回字段为contract_id VARCHAR, valid_from_tstp TIMESTAMP_NTZ(9), product_system_code VARCHAR（可根据实际业务调整字段）：

CREATE OR REPLACE PROCEDURE CASE_DEMO_CMS(
    CONTRACT_ID VARCHAR, 
    VALID_FROM_TSTP TIMESTAMP_NTZ(9),
    product_System_code VARCHAR
)
RETURNS TABLE (
    contract_id VARCHAR,
    valid_from_tstp TIMESTAMP_NTZ(9),
    product_system_code VARCHAR
)
LANGUAGE SQL
AS
DECLARE
    res RESULTSET;
    query VARCHAR;
BEGIN
    -- 根据参数值分支处理
    IF product_system_code = 'U2' THEN
        query := 'SELECT
                    ctrt.contract_id,
                    ctrt.valid_from_tstp,
                    ctrt.product_system_code
                  FROM  -- 替换为你的实际表名
                    your_target_table ctrt
                  WHERE ctrt.contract_id = ?
                    AND ctrt.valid_from_tstp = ?
                    AND ctrt.product_system_code = ?';
        res := (EXECUTE IMMEDIATE :query USING (CONTRACT_ID, VALID_FROM_TSTP, product_system_code));
    ELSE
        -- 返回空的同结构结果集，保证返回类型统一
        query := 'SELECT NULL::VARCHAR AS contract_id, NULL::TIMESTAMP_NTZ(9) AS valid_from_tstp, NULL::VARCHAR AS product_system_code WHERE 1=0';
        res := (EXECUTE IMMEDIATE :query);
    END IF;
    
    RETURN TABLE(res);
END;

扩展说明 #

如果需要支持更多参数值分支（如'A'、'B'等），可以添加ELSIF分支扩展逻辑：

ELSIF product_system_code = 'A' THEN
    query := 'SELECT ... -- 对应sql_query1的查询逻辑';
    res := (EXECUTE IMMEDIATE :query USING (...)); -- 按需传递参数
ELSIF product_system_code = 'B' THEN
    query := 'SELECT ... -- 对应sql_query2的查询逻辑';
    res := (EXECUTE IMMEDIATE :query USING (...));

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