在Snowflake中创建UDTF时RETURNS TABLE语法匹配仍报错求助

你的UDTF创建失败主要是因为返回结构不匹配、动态表引用错误、变量/字段冲突等几个关键问题，以下是具体修正点和完整可用代码：

核心错误点 #

• 返回字段不匹配：RETURNS TABLE定义了VALUE字段，但原查询未返回该列，导致结构校验失败。
• 动态表引用无效：Snowflake不支持直接用字符串拼接作为表名，必须使用IDENTIFIER()和TABLE()函数实现动态表引用。
• 参数与字段名冲突：函数参数TABLE_NAME、COLUMN_NAME与查询中表的字段名重名，需用$前缀明确引用函数参数。
• 未定义变量V：CASE语句中的V没有定义，应替换为目标列的实际值。
• 数据类型不匹配：CURRENT_TIME()返回TIME类型，与EXECUTION_TS的TIMESTAMP类型不兼容，需改用CURRENT_TIMESTAMP()。
• 字段名拼写不一致：返回定义中的TABLE_NME/COLUMN_NME与查询返回的TABLE_NAME/COLUMN_NAME拼写不一致，需统一。

修正后的UDTF代码 #

CREATE OR REPLACE FUNCTION DQ_IS_NULL ("SCHEMA_NAME" VARCHAR(500), "TABLE_NAME" VARCHAR(500), "COLUMN_NAME" VARCHAR(500))
RETURNS TABLE (TABLE_NME VARCHAR(500), COLUMN_NME VARCHAR(500), ISSUE_CODE VARCHAR(100), PARAMETERS VARCHAR(500), VALUE VARCHAR(500), ROW_HASH NUMBER(19,0), EXECUTION_TS TIMESTAMP)
LANGUAGE SQL
AS
$$
    SELECT 
        $TABLE_NAME AS TABLE_NME,
        $COLUMN_NAME AS COLUMN_NME,
        'NULLed' AS ISSUE_CODE,
        'NULLS not permitted' AS PARAMETERS,
        -- 动态引用目标列的值作为VALUE
        IDENTIFIER($COLUMN_NAME) AS VALUE,
        HASH(*) AS ROW_HASH,
        CURRENT_TIMESTAMP() AS EXECUTION_TS
    FROM TABLE(IDENTIFIER(CONCAT($SCHEMA_NAME, '.', $TABLE_NAME)))
    WHERE IDENTIFIER($COLUMN_NAME) IS NULL
$$;

关键修正说明 #

1. 动态表与列引用：使用TABLE(IDENTIFIER(CONCAT($SCHEMA_NAME, '.', $TABLE_NAME)))实现动态表查询，IDENTIFIER($COLUMN_NAME)动态引用目标列。
2. 返回字段对齐：新增VALUE字段，通过动态列引用返回空值列的实际值；统一返回字段名的拼写（TABLE_NME/COLUMN_NME）。
3. 参数引用：用$SCHEMA_NAME、$TABLE_NAME、$COLUMN_NAME明确引用函数参数，避免与表字段名冲突。
4. 数据类型修正：用CURRENT_TIMESTAMP()替代CURRENT_TIME()，匹配EXECUTION_TS的TIMESTAMP类型。
5. CASE语句简化：由于查询已经过滤出COLUMN_NAME IS NULL的行，直接返回固定的ISSUE_CODE和PARAMETERS即可，无需CASE判断。

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