Snowflake Javascript 程序截断表无效

Question

本周我花了大部分时间在 Snowflake 中编写一些 Javascript 存储过程来处理一些事情。但我终其一生都无法弄清楚为什么 Truncate Table 不起作用。

    try {

        var get_tables = "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'SCHEMA' AND TABLE_CATALOG = 'DATABASE' ORDER BY TABLE_NAME DESC;"
        var tableStmt = snowflake.createStatement( {sqlText: get_tables} );
        var rs = tableStmt.execute();

        while (rs.next()) {

            var table = rs.getColumnValue(1);

            var truncateTable = "TRUNCATE TABLE DATABASE.SCHEMA." + table
            var truncateStmt = snowflake.createStatment( {sqlText: truncateTable} );
            var truncateEx = truncateStmt.execute();
      }
   }

这种创建查询的模式在他们的文档中，并且似乎适用于我汇总的所有其他查询。但是这个失败了，我没有收到语法错误或任何东西。我省略了捕获和其他内容，因为这是唯一相关的部分。

我也试过了

var truncateTable = "TRUNCATE TABLE DATABASE.SCHEMA." + table + ";"

我已针对 Snowflake 中的普通 SQL 查询中的表测试了此特定查询，并确认它有效。

我错过了什么吗？

Answer 1

由于 SQL 在 try 块内执行，因此不会显示错误。也许你正在处理它，但它没有显示出来。

如果你注释掉 try 块，它应该在运行时显示错误。可能是权限问题。存储过程可以使用调用者权限或所有者权限运行。如果调用者没有权限从 INFORMATION_SCHEMA 读取或截断列表中的表，则会出错。如果在这种情况下有意义，您可以调用使用所有者的权利。

这样运行会发生什么？

    //try {

        var get_tables = "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'SCHEMA' AND TABLE_CATALOG = 'DATABASE' ORDER BY TABLE_NAME DESC;"
        var tableStmt = snowflake.createStatement( {sqlText: get_tables} );
        var rs = tableStmt.execute();

        while (rs.next()) {

            var table = rs.getColumnValue(1);

            var truncateTable = "TRUNCATE TABLE DATABASE.SCHEMA." + table
            var truncateStmt = snowflake.createStatment( {sqlText: truncateTable} );
            var truncateEx = truncateStmt.execute();
      }
   //}

Answer 2

这将起作用：

 create or replace procedure util_db.public.truncate_table("table_name" varchar,"truncate" boolean)
returns string
language javascript
strict
execute as owner
as
$$
var sql_command = "Truncate table " + table_name ;
try {
    if (truncate){
        snowflake.execute (
            {sqlText: sql_command}
            );
        return "Succeeded.";   // Return a success/error indicator.
        }
    }
catch (err)  {
    throw(err);
   // return "Failed: " + err;   // Return a success/error indicator.
    }
$$
;