Snowflake JavaScript存储过程初始化失败，报无效标识符错误求助

问题场景 #

我在Snowflake中编写了一个JavaScript存储过程，用于执行SQL查询并将数据插入到目标表，但调用时始终无法初始化，取消查询后返回SQL编译错误：无效标识符'TABLE_NAME'。以下是我的存储过程代码及调用语句：

CREATE OR REPLACE procedure TRIAL
    (
    DATABASE_NAME VARCHAR,
    SCHEMA_NAME VARCHAR,
    TABLE_NME VARCHAR,
    COLUMN_NME VARCHAR
    )
    RETURNS varchar(100)
    language javascript
    as '   

    var return_value = "";

    var sql_command= `INSERT INTO XXX.YYY.END_TABLE (table_name, column_name, issue_code,parameters,value,row_hash, exception_ts)
                    WITH CTE AS (
                            SELECT 
                            ${TABLE_NME},
                            ${COLUMN_NME},
                            ''DQ_IS_NULL'',
                            ''NULLs not permitted'',
                            HASH(*) AS ROW_HASH,
                            CURRENT_TIMESTAMP()
                            FROM ${DATABASE_NAME}.${SCHEMA_NAME}.${TABLE_NME}
                            )
                    SELECT CTE.* FROM CTE
                    LEFT JOIN XXX.YYY.END_TABLE dql
                    ON CTE.ROW_HASH = dql.ROW_HASH WHERE dql.ROW_HASH IS NULL;`
    var stmt1 = snowflake.createStatement({sqlText: sql_command});
    var result_scan=stmt1.execute();
 
       return "Records Inserted";        
    ';

CALL TRIAL('DATABASE_NAME','SCHEMA_NAME','TABLE_NME','COLUMN_NME');

错误原因 #

1. 参数解析错误：你把传入的表名参数TABLE_NME直接写在SELECT ${TABLE_NME}里，Snowflake会把这个参数值（比如调用时传的'TABLE_NME'）当成数据表的列名来解析，而你的表里根本没有这个列，所以触发"无效标识符"错误。实际上你需要把表名和列名作为字符串值插入到END_TABLE的对应字段，不是作为查询列。
2. 字段数量不匹配：INSERT目标表有7个字段，但CTE的SELECT语句只返回了6个字段，顺序也和目标列不对应，会导致插入失败。
3. 缺少过滤逻辑：原代码没有筛选NULL值的条件，会把全表数据都拿来处理，不符合你校验NULL的需求。

修正后的代码 #

CREATE OR REPLACE procedure TRIAL
(
    DATABASE_NAME VARCHAR,
    SCHEMA_NAME VARCHAR,
    TABLE_NME VARCHAR,
    COLUMN_NME VARCHAR
)
RETURNS varchar(100)
language javascript
as '   
    try {
        // 构造SQL：将表名、列名作为字符串插入，同时筛选目标列的NULL值
        var sql_command = `INSERT INTO XXX.YYY.END_TABLE (table_name, column_name, issue_code, parameters, value, row_hash, exception_ts)
                          WITH CTE AS (
                                  SELECT 
                                      ''${TABLE_NME}'' AS table_name,
                                      ''${COLUMN_NME}'' AS column_name,
                                      ''DQ_IS_NULL'' AS issue_code,
                                      ''NULLs not permitted'' AS parameters,
                                      ${COLUMN_NME} AS value,
                                      HASH(*) AS row_hash,
                                      CURRENT_TIMESTAMP() AS exception_ts
                                  FROM ${DATABASE_NAME}.${SCHEMA_NAME}.${TABLE_NME}
                                  WHERE ${COLUMN_NME} IS NULL -- 仅处理NULL值的行
                                  )
                          SELECT CTE.* FROM CTE
                          LEFT JOIN XXX.YYY.END_TABLE dql
                          ON CTE.row_hash = dql.row_hash 
                          WHERE dql.row_hash IS NULL;`;

        var stmt1 = snowflake.createStatement({sqlText: sql_command});
        stmt1.execute();
        return "Records Inserted Successfully";        
    } catch (err) {
        return "Error: " + err.message;
    }
';

-- 调用时传入实际的库、Schema、表、列名
CALL TRIAL('MY_DB', 'MY_SCHEMA', 'MY_TABLE', 'MY_COLUMN');

修正说明 #

• 给表名和列名参数加上单引号（''${TABLE_NME}''），确保它们被解析为字符串值插入到目标表的对应字段，而非当成列名。
• 补充了value字段，对应目标列的实际值，匹配INSERT的7个目标列。
• 添加WHERE ${COLUMN_NME} IS NULL条件，只筛选出存在NULL值的行，符合数据校验逻辑。
• 新增try-catch异常处理，方便捕获并返回执行时的错误信息，便于排查问题。
• 统一了字段名的大小写（如row_hash），保持与目标表字段一致。

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