如何在Snowflake存储过程中执行SQL文件？报错求助

原代码的核心问题 #

• 使用my_csv_format读取SQL文件不合适：CSV格式会按分隔符解析内容，破坏SQL语句结构，应改用纯文本格式读取。
• 字符长度限制：varchar(160000)可能无法容纳较长SQL语句，建议使用Snowflake支持的最大长度VARCHAR(16777216)。
• 多语句处理：若SQL文件包含多条语句，直接执行会报错，需拆分后逐条执行。

步骤1：创建纯文本文件格式 #

先创建适配SQL文件的文本格式（无则新建）：

CREATE OR REPLACE FILE FORMAT my_text_format
TYPE = 'TEXT'
FIELD_DELIMITER = NONE
RECORD_DELIMITER = '\n'
SKIP_HEADER = 0
ENCODING = 'UTF8';

方案1：执行单条SQL语句的存储过程 #

若stg_order_line.sql仅包含单条SQL语句，使用以下存储过程：

CREATE OR REPLACE PROCEDURE sp_stg_load()
RETURNS VARCHAR
LANGUAGE SQL 
AS
$$
    declare
        sql_stmt VARCHAR(16777216);
    begin
        -- 读取SQL文件所有行并合并为完整语句
        SELECT LISTAGG($1, '\n') INTO sql_stmt 
        FROM @eg_stage/stg_order_line.sql(file_format => 'my_text_format');
        
        EXECUTE IMMEDIATE :sql_stmt;
        return 'Success';
    end;
$$;

方案2：执行多条SQL语句的存储过程 #

若SQL文件包含多条用分号分隔的语句，使用拆分执行的版本：

CREATE OR REPLACE PROCEDURE sp_stg_load()
RETURNS VARCHAR
LANGUAGE SQL 
AS
$$
    declare
        full_sql VARCHAR(16777216);
        sql_commands ARRAY;
        cmd VARCHAR(16777216);
        i INTEGER;
    begin
        -- 读取并合并文件所有行
        SELECT LISTAGG($1, '\n') INTO full_sql 
        FROM @eg_stage/stg_order_line.sql(file_format => 'my_text_format');
        
        -- 移除末尾多余分号，再按分号拆分语句（简单处理，复杂场景需优化）
        sql_commands := SPLIT(REGEXP_REPLACE(full_sql, ';\\s*$', ''), ';');
        
        -- 逐条执行有效语句
        FOR i IN 1 TO ARRAY_SIZE(sql_commands) DO
            cmd := TRIM(ARRAY_GET(sql_commands, i-1));
            IF cmd != '' THEN
                EXECUTE IMMEDIATE :cmd;
            END IF;
        END FOR;
        
        return 'Success';
    end;
$$;

注意事项 #

• 确保存储过程拥有执行SQL文件中语句的权限（如创建表、插入数据等）。
• 若SQL语句包含绑定变量，需在存储过程中提前替换变量值。
• 对于包含分号的字符串常量（如INSERT INTO ... VALUES ('abc;def')），上述拆分逻辑会误拆分，需根据实际场景调整正则表达式处理这类特殊情况。

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