0
271
Visualizaçõesconcatenar 2 columnas de datos para usar como una condición en la declaración de unión (procedimiento Snowflake)
Estoy trabajando en el procedimiento del copo de nieve.
Tengo 2 tablas, es decir, la tabla ASSET_DEC y la tabla ASSET_DATA .
La columna serviceid_versionid está en ASSET_DATA y tiene un valor como 1234_5678 .
Ahora, la columna en ASSET_DEC es serviceid (valor = 1234) y versionid (valor = 5678). Necesito escribir una consulta donde necesito unir estas 2 tablas con la condición como
left outer join logs.public.ASSET_DATA asd1 on asd1.serviceid_versionid = concat_ws('_',ASSET_DEC.serviceid,ASSET_DEC.versionid).El error que recibo al usar concat_ws es:
JavaScript compilation error: Uncaught SyntaxError: Unexpected identifier in PROD_TEST at '"left outer join logs.public.ASSET_DATA asd1 on asd1.serviceid_versionid = concat_ws('_',ASSET_DEC.serviceid,ASSET_DEC.versionid) ";' position 124¿Cómo puedo lograr esto dentro del procedimiento de copo de nieve?
Actualización después de que @nick señaló:
Nuevo mensaje de error :
Execution error in store procedure PROD_TEST: SQL compilation error: error line 6 at position 1,527 invalid identifier '_' At Snowflake.execute, line 66 position 20
·
Santiago Gelvez
1 Respostas
Responde à pergunta0
Es posible usar la expresión como parte de la condición ON dentro del procedimiento almacenado de JavaScript:
CREATE OR REPLACE TABLE PUBLIC.ASSET_DATA(serviceid_versionid VARCHAR) AS SELECT '1234_5678'; CREATE OR REPLACE TABLE PUBLIC.ASSET_DEC(serviceid INT, versionid INT) AS SELECT '1234', '5678';proceso:
CREATE OR REPLACE PROCEDURE test1 () RETURNS VARCHAR NOT NULL LANGUAGE javascript EXECUTE AS CALLER AS $$ var sql_stmt = ` CREATE OR REPLACE TABLE test AS SELECT serviceid_versionid, serviceid, versionid FROM PUBLIC.ASSET_DATA asd1 LEFT JOIN PUBLIC.ASSET_DEC ASSET_DEC ON asd1.serviceid_versionid = concat_ws('_',ASSET_DEC.serviceid,ASSET_DEC.versionid) `; var statement = snowflake.createStatement( {sqlText:sql_stmt} ); var rs = statement.execute(); $$;Prueba:
CALL test1(); SELECT * FROM test; 
·
Santiago Gelvez
Relatório
Responde à pergunta