Блог

Вопрос касается Snowflake snowsql. И нужно выполнить условную проверку, чтобы увидеть, вставлен ли ETL_Date уже в таблицу, и если он есть; выйдите из сохраненной процедуры. В противном случае, если дата не вставлена, продолжайте и вставьте данные, а затем верните успех (ноль) и завершите работу. Любая помощь будет очень признательна. Спасибо.

Отправная точка: то, что я сделал до сих пор в своем коде.

 IF ((SELECT IFNULL(MAX(ETL_DATE),'1900-01-01') FROM DB.TABLES.test_20200909) > CURRENT_DATE() )
{RETURN 0; break;}
else insert into DB.TABLES.test_20200909 (ETL_DATE,INSERT_VALUE)
values(CURRENT_DATE(),1)
  

И это выдает мне ошибку: ошибка компиляции SQL: синтаксическая ошибка строки 1 в позиции 0 неожиданное ‘IF’.

Цель / Конец игры: Нужно поместить это в сохраненный процесс. То, что я изложил до сих пор, это:

 CREATE or replace procedure   TABLE_DB.TABLES.test_20200909_1 ()
returns FLOAT
language javascript
as
$$

var test_1 =`IF ((SELECT MAX(ETL_DATE) FROM DB.TABLES.test_20200909) > CURRENT_DATE() )
{RETURN 0; break;}
else insert into DB.TABLES.test_20200909 (ETL_DATE,INSERT_VALUE)
values(CURRENT_DATE(),1)`;
var test_1_stmt =  snowflake.createStatement({sqlText: test_1});  
var test_1_res = test_1_stmt.execute();
return 0
$$
  

Если ваша цель — создать хранимую процедуру для проверки / управления вашей загрузкой, я бы создал ее следующим образом :

 create or replace procedure SP_CHECK_LOAD()
    RETURNS VARCHAR(256) NOT NULL
    LANGUAGE JAVASCRIPT
    EXECUTE AS CALLER
as $$    

function get_check_load()
{
    var v_out_check_load;
    rs = snowflake.execute ( { sqlText: `SELECT CASE WHEN MAX(ETL_DATE)>=CURRENT_DATE() THEN 0 ELSE 1 END AS CHECK_RESULT FROM DB.TABLES.test_20200909;` }  );
    if( rs.next())
    {
       v_out_check_load = rs.getColumnValue(1); // get check result
    }

    return v_out_check_load; 
}   
  
  var result = new String('Successfully Executed');
  var v_check = get_check_load();
  
  if ( v_check==1 )
  {
    //data not yet loaded -> load them
    try {
       
    var sql_command = `INSERT INTO DB.TABLES.test_20200909 (ETL_DATE,INSERT_VALUE) VALUES(CURRENT_DATE(),1)`;
 
    var stmt = snowflake.createStatement({sqlText: sql_command});
    var res = stmt.execute();  
    
    }
    catch (err) {
    result =  "Failed: Code: "   err.code   " | State: "   err.state;
    result  = "n  Message: "   err.message;
    result  = "nStack Trace:n"   err.stackTraceTxt; 
    } 
 } // end if
 
 return result;

  $$;
  

Пожалуйста, обратите внимание, что я использовал >= внутри условия проверки MAX(ETL_DATE)>=CURRENT_DATE(), а не только > как в вашем примере, потому что в этом случае вы исключили бы загрузку текущей даты. Измените его, если это не соответствует вашим потребностям.

Исходя из того, что вы упомянули, похоже, что вам даже не нужна хранимая процедура для этого. Вы можете использовать сопоставление слиянием, которое, вероятно, проще настроить

И нужно выполнить условную проверку, чтобы увидеть, вставлен ли ETL_Date уже в таблицу, и если он есть; выйдите из сохраненной процедуры. ИНАЧЕ, если дата не вставлена, продолжайте вставлять данные, а затем возвращайте успех (ноль)

Пожалуйста, посмотрите, есть ли ниже то, чего вы пытаетесь достичь

 CREATE OR REPLACE TABLE test_20200909(INSERT_VALUE NUMBER, ETL_DATE TIMESTAMP);
 
INSERT INTO TEST_20200909 VALUES(1, '2020-09-01 00:00:00.000');
INSERT INTO TEST_20200909 VALUES(1, '2020-09-02 00:00:00.000');
INSERT INTO TEST_20200909 VALUES(1, '2020-09-03 00:00:00.000');
INSERT INTO TEST_20200909 VALUES(1, '2020-09-04 00:00:00.000');
 
SELECT * FROM test_20200909;
 
MERGE INTO test_20200909 T
 USING(SELECT MAX(ETL_DATE) maxdate FROM test_20200909) S 
 ON S.maxdate=CURRENT_DATE()
 when NOT matched then 
  insert (INSERT_VALUE,ETL_DATE)  values (1, CURRENT_DATE());
  
SELECT * FROM test_20200909;