存储过程中DML语句使用identifier报错：TRGT.COLUMN_ID无效

错误原因 #

• 在Snowflake存储过程中，identifier()用于动态指定表名时，编译阶段数据库无法识别动态表的元数据结构，直接使用TRGT.COLUMN_ID这类别名引用列会被判定为无效标识符——因为此时系统不知道TRGT对应的表包含该列。
• 代码中第二个SELECT语句末尾遗漏分号，属于语法问题，需一并修正。

解决方法 #

必须通过动态SQL拼接完整的DELETE语句，借助EXECUTE IMMEDIATE让数据库在运行时解析动态表的结构。以下是两种可行的修正方案：

方案1：字符串拼接直接执行 #

DECLARE
staging_table string;
main_table string;

BEGIN 

SELECT DISTINCT STAGING_TABLE INTO :staging_table FROM SCHEMA.TEST1 WHERE COLUMN1 = 'X';
SELECT DISTINCT MAIN_TABLE INTO :main_table FROM SCHEMA.TEST2 WHERE COLUMN1 = 'X';

EXECUTE IMMEDIATE 'DELETE FROM ' || identifier(:main_table) || ' AS TRGT 
    USING ' || identifier(:staging_table) || ' AS STG
    WHERE TRGT.COLUMN_ID = STG.COLUMN_ID';

END;

方案2：绑定变量方式（更安全，避免SQL注入） #

DECLARE
staging_table string;
main_table string;
delete_sql string;

BEGIN 

SELECT DISTINCT STAGING_TABLE INTO :staging_table FROM SCHEMA.TEST1 WHERE COLUMN1 = 'X';
SELECT DISTINCT MAIN_TABLE INTO :main_table FROM SCHEMA.TEST2 WHERE COLUMN1 = 'X';

delete_sql := 'DELETE FROM IDENTIFIER(?) AS TRGT 
               USING IDENTIFIER(?) AS STG
               WHERE TRGT.COLUMN_ID = STG.COLUMN_ID';

EXECUTE IMMEDIATE :delete_sql USING (:main_table, :staging_table);

END;

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