Estoy tratando de implementar el manejo de errores en el copo de nieve usando el bloque Try Catch . Consultas SQL adjuntas en javascript para aplicar el manejo de errores. Cuando ejecuto la consulta, ejecuta la declaración de devolución directamente y no se ejecuta ninguna de las consultas dentro del bloque Try Catch .
CREATE OR REPLACE PROCEDURE "SP_N_1Test"("STAGE_S3" VARCHAR(16777216), "STAGE_OUTPUT" VARCHAR(16777216)) RETURNS VARCHAR(16777216) LANGUAGE Javascript EXECUTE AS CALLER AS $$ var cmd = `truncate table STAGE2A.T001_IRF_STUDENT_FORM_S3`; var my_sql_command1 = snowflake.createStatement({sqlText: cmd}); var result = my_sql_command1.execute(); var cmd1 = `''COPY INTO STAGE2A.T001_IRF_STUDENT_FORM_S3 FROM ( select FN_TrimStr($1) as State, FN_TrimStr($2) as AdminCode, from @stage2a.''||:STAGE_S3||'') pattern= ''''.*_IRF_.*\\\\.csv'''' file_format = (type=csv, skip_header=1 )''`; var my_sql_command2 = snowflake.createStatement({sqlText: cmd1}); var result1 = my_sql_command2.execute(); var cmd2 = `Insert into STAGE2B.T011_IRF_STUDENT_FORM_V001 ( STATE_FLAG, STATE_CD, ) SELECT STATE_FLAG, STATE_CD, from STAGE2A.V001_IRF_STUDENT_FORM_T001`; var my_sql_command3 = snowflake.createStatement({sqlText: cmd2}); var result2 = my_sql_command3.execute(); return; $$; Además, quiero imprimir un mensaje en cada bloque Try para generar el éxito cuando se ejecuta correctamente. He usado Print, Println, sustem.print.out() pero ninguno de ellos funcionó.
Parece que tiene cierta confusión acerca de llamar a las declaraciones SQL dentro del procedimiento. Debe usar la API de copo de nieve para llamar a SQL:
https://docs.snowflake.com/en/sql-reference/stored-procedures-javascript.html
Lo que veo aquí es:
try{ `truncate table "STAGE2A"."T001_IRF_STUDENT_FORM_S3"`;} -- nothing to execute catch (err){} try{ `bla bla bla bla`; --- nothing to execute return "Load process completed for IRF_STUDENT_FORM_S3"; } catch(err){}Abrió el acento grave (`) y lo cerró antes del comando de retorno, convirtiendo todo en una cadena de plantilla. Es por eso que ves que la función regresa inmediatamente. Como dije, debe verificar cómo usar la API de copo de nieve para llamar a los SQL.
Acerca de escribir una salida, no puede escribir una salida como esta, pero puede definir una variable y devolverla, o puede insertar los registros en una tabla.
CREATE OR REPLACE PROCEDURE sp_test("STAGE_S3" VARCHAR(16777216), "STAGE_OUTPUT" VARCHAR(16777216)) RETURNS VARCHAR(16777216) LANGUAGE Javascript EXECUTE AS CALLER AS ' var result = ""; try{ `truncate table "STAGE2A"."T001_IRF_STUDENT_FORM_S3"`; result += "table truncated "; } catch (err){} ... result += "Load process completed for IRF_STUDENT_FORM_S3"; } catch(err){} return result; ';