如何让Snowflake Native App向提供者账户执行写操作（无需复杂API）

以下几种方案均无需跨系统API集成，可直接在Snowflake生态内实现Native App对提供者账户数据的写操作：

1. 基于存储过程的受控写操作 #

通过在提供者账户创建封装了INSERT/UPDATE逻辑的存储过程，将执行权限授予应用包共享，让Native App调用该过程完成数据修改，适合需要复杂业务逻辑或权限管控的场景。

操作步骤： #

• 创建处理数据修改的存储过程：

-- 在提供者账户执行
CREATE OR REPLACE PROCEDURE NATIVE_APP.NATIVE_APP_SCHEMA.MODIFY_PROVIDER_DATA(
    operation_type VARCHAR,
    row_data VARIANT
)
RETURNS VARCHAR
LANGUAGE SQL
AS
$$
BEGIN
    IF (operation_type = 'INSERT') THEN
        INSERT INTO PROVIDER_DB.PROVIDER_SCHEMA.PROVIDER_TABLE
        SELECT * FROM TABLE(FLATTEN(input => row_data));
    ELSIF (operation_type = 'UPDATE') THEN
        UPDATE PROVIDER_DB.PROVIDER_SCHEMA.PROVIDER_TABLE
        SET col1 = row_data:col1, col2 = row_data:col2
        WHERE id = row_data:id;
    END IF;
    RETURN '操作成功';
END;
$$;

• 授予存储过程执行权限：

GRANT EXECUTE ON PROCEDURE NATIVE_APP.NATIVE_APP_SCHEMA.MODIFY_PROVIDER_DATA(VARCHAR, VARIANT)
TO SHARE IN APPLICATION PACKAGE NATIVE_APP_PACKAGE;

• 在Native App中调用存储过程：

-- 消费者端Native App内执行
CALL MODIFY_PROVIDER_DATA('INSERT', PARSE_JSON('{"col1": "value1", "col2": "value2"}'));

2. 使用可更新视图直接写操作 #

如果你的视图满足Snowflake可更新视图的条件（基于单个表、无DISTINCT/聚合/GROUP BY/JOIN等操作），可以直接授予视图的INSERT/UPDATE权限，让Native App直接对视图执行写操作，Snowflake会自动将操作映射到底层源表。

操作步骤： #

• 确认视图符合可更新条件：你的现有视图SOME_VIEW是单表查询，满足可更新要求。
• 授予写权限：

-- 在提供者账户执行
GRANT INSERT, UPDATE ON VIEW NATIVE_APP.NATIVE_APP_SCHEMA.SOME_VIEW
TO SHARE IN APPLICATION PACKAGE NATIVE_APP_PACKAGE;

• 消费者端直接执行写操作：

-- Native App内执行INSERT
INSERT INTO SOME_VIEW (col1, col2) VALUES ('new_val1', 'new_val2');

-- Native App内执行UPDATE
UPDATE SOME_VIEW SET col2 = 'updated_val' WHERE col1 = 'target_val';

3. 基于INSTEAD OF触发器处理复杂视图的写操作 #

如果视图包含JOIN、聚合等无法直接更新的逻辑，可以通过INSTEAD OF触发器拦截视图的写操作，将请求转发到预先定义的存储过程中处理，实现复杂场景下的写回。

操作步骤： #

• 创建处理写操作的存储过程（可复用方案1中的存储过程）
• 创建INSTEAD OF触发器：

-- 在提供者账户执行
CREATE OR REPLACE TRIGGER NATIVE_APP.NATIVE_APP_SCHEMA.SOME_VIEW_INSERT_TRIGGER
INSTEAD OF INSERT ON NATIVE_APP.NATIVE_APP_SCHEMA.SOME_VIEW
FOR EACH ROW
CALL NATIVE_APP.NATIVE_APP_SCHEMA.MODIFY_PROVIDER_DATA('INSERT', OBJECT_CONSTRUCT(*));

CREATE OR REPLACE TRIGGER NATIVE_APP.NATIVE_APP_SCHEMA.SOME_VIEW_UPDATE_TRIGGER
INSTEAD OF UPDATE ON NATIVE_APP.NATIVE_APP_SCHEMA.SOME_VIEW
FOR EACH ROW
CALL NATIVE_APP.NATIVE_APP_SCHEMA.MODIFY_PROVIDER_DATA('UPDATE', OBJECT_CONSTRUCT(*));

• 授予视图的写权限：

GRANT INSERT, UPDATE ON VIEW NATIVE_APP.NATIVE_APP_SCHEMA.SOME_VIEW
TO SHARE IN APPLICATION PACKAGE NATIVE_APP_PACKAGE;

这样消费者端对视图执行INSERT/UPDATE时，触发器会自动调用存储过程完成对源表的修改。

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