连接 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;
我正在研究雪花程序。
我有 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;