Snowflake存储过程传递schema变量调用报错问题咨询

错误原因 #

• Snowflake JavaScript存储过程的输入参数，在JS执行上下文里会自动转为全大写变量名，你代码中使用的小写dbschema、tmpschema在上下文中不存在，因此触发未定义报错。
• 原有代码存在SQL语法错误：表名属于标识符，不能用单引号包裹，单引号仅用于包裹字符串字面量，标识符要么直接写，有大小写特殊要求时用双引号包裹。

修正后的存储过程代码 #

CREATE OR REPLACE PROCEDURE test_proc(tmpschema VARCHAR, dbschema VARCHAR)
RETURNS VARCHAR
LANGUAGE JAVASCRIPT
AS
$$
/* Load STARTED */
    try{
        // 参数名用全大写访问，同时去掉表名外侧的单引号
        snowflake.createStatement({sqlText:`TRUNCATE TABLE ${DBSCHEMA}.TAB1`}).execute();
        snowflake.createStatement({sqlText:`TRUNCATE TABLE ${TMPSCHEMA}.TAB2`}).execute();
        return 'Truncate success';
    }
    catch(err){
        return 'Failed Truncating TMP tables: ' + err;
    }
$$
;

调用测试 #

call BIGDATA.test_proc('TMP', 'DB');

如果你的schema名包含小写、特殊字符或者和关键字重名，可以修改SQL拼接逻辑为双引号包裹标识符：

snowflake.createStatement({sqlText:`TRUNCATE TABLE "${DBSCHEMA}".TAB1`}).execute();

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