Snowflake遍历Schema下所有表统计数据时遇语法错误求助

错误原因解析 #

• 变量引用错误：循环内拼接SQL时直接使用TABLE_NAME，但该变量未绑定游标返回的记录，需改为record.TABLE_NAME。
• 表名未做标识符处理：若表名含特殊字符或关键字，直接拼接会触发语法错误，需用IDENTIFIER()函数包裹。
• 冗余变量与语法遗漏：声明的table_name变量未使用可移除；结尾SELECT语句缺失分号。

修正后的完整脚本 #

-- Snowflake 遍历当前Schema下所有实体表，统计总记录数和TARGET_CHANGED_ON字段最大值
CREATE OR REPLACE TEMPORARY TABLE TEMP_TARGET_TABLE (
    TABLE_NAME STRING,
    ROW_COUNT INTEGER,
    MAX_TARGET_CHANGED_ON TIMESTAMP
);

DECLARE
    row_count INTEGER;
    sql_cmd STRING;
    max_target_changed_on TIMESTAMP;
    table_cursor CURSOR FOR (
        SELECT TABLE_NAME 
        FROM INFORMATION_SCHEMA.TABLES
        WHERE TABLE_SCHEMA = CURRENT_SCHEMA() -- 限定仅遍历当前Schema
          AND TABLE_TYPE = 'BASE TABLE' -- 仅统计实体表，排除视图/外部表等
    );

BEGIN
    FOR record IN table_cursor DO
        -- 统计记录数，用参数传递表名避免拼接风险
        LET sql_cmd = 'SELECT COUNT(*) FROM IDENTIFIER(:1)';
        EXECUTE IMMEDIATE sql_cmd USING record.TABLE_NAME INTO row_count;

        -- 统计TARGET_CHANGED_ON最大值
        LET sql_cmd = 'SELECT MAX(TARGET_CHANGED_ON) FROM IDENTIFIER(:1)';
        EXECUTE IMMEDIATE sql_cmd USING record.TABLE_NAME INTO max_target_changed_on;
        
        -- 插入结果到临时表
        INSERT INTO TEMP_TARGET_TABLE (TABLE_NAME, ROW_COUNT, MAX_TARGET_CHANGED_ON)
        VALUES (record.TABLE_NAME, row_count, max_target_changed_on);
    END FOR;

    SELECT * FROM TEMP_TARGET_TABLE;
END;

优化说明 #

• 新增TABLE_SCHEMA与TABLE_TYPE过滤条件，确保仅遍历当前Schema下的实体数据表，避免无效统计。
• 使用USING参数传递表名，替代字符串拼接，既规避SQL注入风险，又自动处理表名的标识符转义。

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