检索变量值并插入另一个 table

Question

我可以从以下语句中检索 before(0) 和 after counts(4) 的值，但是当我从代码中使用这些变量（load_cnt_before、load_cnt_after）时下面并让他们将值插入到 table 中，它说找不到变量（请参阅下面的错误）。我如何使用这些值将它们插入 table.

Error: Execution error in stored procedure REC_COUNT_CHECK: SQL compilation error: error line 1 at position 114 invalid identifier 'LOAD_CNT_BEFORE' At Statement.execute, line 25 position 90

代码：

CREATE OR REPLACE PROCEDURE REC_COUNT_CHECK()       
RETURNS VARCHAR LANGUAGE JAVASCRIPT   
AS $$ 
 
    
    /***** Get the Record Count before Refresh ****/  
        var load_cnt=`SELECT Count(*) as record_cnt from "PLNG_ANALYSIS"."LOADDATA"."LOAD_VERIFICATION" WHERE EXTRACTDATE=Current_date()-1 ;`
        var load_cnt_check = snowflake.createStatement({sqlText: load_cnt}).execute();
        load_cnt_check.next();
        load_cnt_before = load_cnt_check.getColumnValue(1);
        

/***** Execute the SP ****/
        var sp_call = "CALL LOAD_VERIFICATION()";    /***Refreshes data in table LOAD_VERIFICATION***/
        var result = snowflake.execute({sqlText: sp_call});  
        result.next();
        var return_msg2 = result.getColumnValue(1);
        
        /***** Check the After Refresh Count ****/
        var load_cnt_after=`SELECT Count(*) as record_cnt from "PLNG_ANALYSIS"."HFM"."LOAD_VERIFICATION" WHERE EXTRACTDATE=Current_date() ;`
        var load_cnt_check_after = snowflake.createStatement({sqlText: load_cnt_after}).execute();
        load_cnt_check_after.next();
        load_cnt_after= load_cnt_check_after.getColumnValue(1);
        
  /***** INSERT BEFORE AND AFTER COUNTS INTO LOG TABLE ****/     
         var insert_status_sp1=`INSERT INTO LOAD_STATUS_LOG_KK values (Current_TIMESTAMP(),1,'LOAD_VERIFICATION','Success','',**load_cnt_before,load_cnt_after**,1);`
            var exec_sp1_status = snowflake.createStatement({sqlText: insert_status_sp1}).execute();
            exec_sp1_status.next();
         
  
  return 'Success'
            
  $$;
  CALL REC_COUNT_CHECK();

Answer 1

JS 变量应传递到 SQL 查询中。该机制称为 Binding Variables

var insert_status_sp1=`INSERT INTO LOAD_STATUS_LOG_KK values (Current_TIMESTAMP(),1,'LOAD_VERIFICATION','Success','',:1,:2,1);`
        
var exec_sp1_status = snowflake.createStatement(
         {sqlText: insert_status_sp1,binds:[load_cnt_before,load_cnt_after]}
         ).execute();

检索变量值并插入另一个 table

Retrieve the Variable value and insert into another table

snowflake-schema

snowflake-cloud-data-platform