带Merge语句的流

Question

下面是我在Snowflake1中实现merge with stream的步骤。创建一个表create或replace表employee(employee_id number,salary number,manager_id number）；2.创建流。在表employees上创建或替换流employees_stream3.创建消费者表。创建或替换表employees_consumer(employee_id number,salary number,manager_id number）；4.我在employees表中插入了一些记录。在雇员中插入数值(8，400，4)，(12，500，9)，(3，300，5)，(4，100，5)，(25，350，9)；5.当我试图执行下面的命令时，我得到了错误。在A.employee_id=B.employee_id匹配时和B.metadata$action='DELETE'以及B.metadata$action='insert'和元数据$action='INSERT'然后插入(EMPLOYEE_ID,SALARY,MANAGER_ID)值(b.EMPLOYEE_ID,b.SALARY,b.MANAGER_ID)；错误是：“SQL编译错误：语法错误第15行，位置8意外'into'。”请帮帮忙。

Answer 1

这里只是语法上的一点错误。使用MERGE时，您不必在NOT MATCHATED子句上执行insert操作。

所以合并查询应该如下所示：

MERGE INTO EMPLOYEES_CONSUMER AS A 
USING (
  SELECT * 
  FROM employees_stream 
  WHERE NOT (METADATA$ACTION= 'DELETE' AND METADATA$ISUPDATE=TRUE)
) AS B 
ON A.EMPLOYEE_ID=B.EMPLOYEE_ID 

WHEN MATCHED AND b.METADATA$ACTION= 'INSERT' AND b.METADATA$ISUPDATE THEN UPDATE 
SET A.EMPLOYEE_ID =B.EMPLOYEE_ID, 
    A.SALARY=B.SALARY, 
    A.MANAGER_ID=B.MANAGER_ID 

WHEN MATCHED AND b.METADATA$ACTION= 'DELETE' THEN DELETE 

WHEN NOT MATCHED AND b. METADATA$ACTION= 'INSERT' THEN INSERT (EMPLOYEE_ID,SALARY,MANAGER_ID) VALUES (B.EMPLOYEE_ID,B.SALARY,B.MANAGER_ID)
;