Snowflake新手求助：如何编写包含MERGE语句的函数？

Snowflake的用户定义函数（UDF）不支持执行DML语句（比如MERGE、DELETE这类数据操作），你需要改用**存储过程（Stored Procedure）**来实现这个逻辑，然后再用Task调用存储过程。

可行的代码骨架 #

1. 创建存储过程 #

CREATE OR REPLACE PROCEDURE sp_01()
RETURNS VARCHAR
LANGUAGE SQL
AS
$$
BEGIN
    MERGE INTO tb1 
    USING tb2
    ON tb1.a = tb2.a
    WHEN MATCHED THEN DELETE;
    RETURN 'MERGE操作执行完成';
END;
$$;

2. 创建调用存储过程的Task #

CREATE OR REPLACE TASK task_call_sp
WAREHOUSE = your_warehouse_name -- 替换成你的实际仓库名
SCHEDULE = 'USING CRON 0 0 * * * UTC' -- 替换成你需要的调度规则
AS
CALL sp_01();

注意事项 #

• 存储过程需要对应权限才能执行DML操作，确保当前角色拥有tb1和tb2的操作权限
• Task需要指定可用的仓库，创建后可通过ALTER TASK task_call_sp RESUME;启用任务

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