连接 2 列数据以用作连接语句中的条件(Snowflake 过程)

concatenate 2 columns data to use as a one as a condition in joining statement(Snowflake procedure)

我正在研究雪花程序。

我有 2 个 table,即 ASSET_DEC table 和 ASSET_DATA table。

serviceid_versionid 列在 ASSET_DATA 中,其值类似于 1234_5678

现在,ASSET_DEC 中的列是 serviceid(值 = 1234)和 versionid(值 = 5678)。 我需要编写一个查询,在其中我需要加入这 2 个 table,条件如下

left outer join logs.public.ASSET_DATA asd1 on asd1.serviceid_versionid = concat_ws('_',ASSET_DEC.serviceid,ASSET_DEC.versionid).

我在使用 concat_ws 时遇到的错误是:

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

如何在雪花程序中实现这一点?

在@nick 指出后更新

新错误消息:

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

可以在 JavaScript 存储过程中使用表达式作为 ON 条件的一部分:

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';

过程:

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();
 $$;

测试:

CALL test1();

SELECT * FROM test;