我正在尝试使用Merge
语句编写存储过程。它看起来像这样:
create or replace procedure database.events.insert_groupss()
returns string
LANGUAGE JAVASCRIPT
as
$$
var sql_cmd = 'Merge into database.events.groups et using
(select lower(f.VALUE:id::string) as id,
min(f.VALUE:time_timestamp::timestamp) as event_timestamp,
f.VALUE:service_string::string as service,
f.VALUE:title_string::string as title,
min(X.VALUE:created_at::timestamp) as title_ts ,
X.VALUE:group::string as group
from \'@database.sources.s3stage/version=3/stream=live/year=2019/month=12/\'
(file_format => \'oak.public.JSON_FORMAT\' ), lateral flatten (input => $1:group_events, RECURSIVE => TRUE) f
, LATERAL FLATTEN(parse_json(replace(replace(replace(replace(f.value:groups ,\'"[\', \'[\'),\'=>\',\':\'),\'\\\\\',\'\'),\']"\',\']\'))) x
where id is not null and group is not null
group by id,group,service,title)a
on et.id=a.id and et.group = a.group
when not matched then Insert (id , event_timestamp , service , title , title_ts ,group )
values (a.id , a.event_timestamp , a.service , a.title , a.title_ts ,a.group );';
try {
snowflake.execute ({sqlText: sql_cmd});
return "Succeeded";
}
catch (err) {
return "Failed: " + err; // Return a success/error indicator.
}
$$;
存储过程已创建,但如果我运行它,我会遇到一些语法错误。当我手动运行它(使用存储过程)时,转义字符被转义并且查询被执行。
这是我得到的错误
JavaScript 编译错误:未捕获的 SyntaxError:'var sql_cmd = 'Merge into database.events.groups et using'位置 14 处的 INSERT_GROUPS 中的令牌无效或意外