KingbaseES数据库merge语法

数据库版本：KingbaseES V008R006C008B0014

简介

MERGE 语句是一种用于数据操作的 SQL 语句，它能够根据指定的条件将 INSERT、UPDATE 和 DELETE 操作结合到单个语句中。其主要作用是在目标表和源表之间进行数据比较和同步，根据条件的匹配情况来执行不同的操作。使用 MERGE 语法可合并 UPDATE 和 INSERT 语句，相比于单独执行 UPDATE + INSERT 语句效率更高。

1. 语法说明

2. 基础用法

2.1. insert子句

2.2. update子句

2.3. delete子句

1. 语法说明

花括号表示必选
方括号表示可选

MERGE INTO[模式.] {目标表} [分区名] | 子查询
USING[模式.] {源表} [分区名] | 子查询
ON(条件表达式)
[WHEN MATCHED THEN]--合并update子句
[WHEN NOT MATCHED THEN]--合并insert子句
;

合并子句的2种语法：

WHEN MATCHED THEN：如果条件匹配有相同的数据，那么执行update子句
WHEN NOT MATCHED THEN：如果条件匹配 "源表" > "目标表"，那么执行insert子句n次

合并update子句如下：

WHEN MATCHED THENUPDATE SET 列 = xxx...

合并insert子句如下：

WHEN NOT MATCHED THENINSERT[列名1, 列名2...]VALUES(值1, 值2...)

合并delete子句如下：

DELETE where_clause

2. 基础用法

2.1. insert子句

insert 子句语法为：

WHEN NOT MATCHED THENinsert子句

规则：

表达式对多表的列数据进行去重后比较，当出现n次不同数据时，且 "目标表" 小于 "源表"，执行 n 次 insert 子句，反之不执行。

【案例】用 id 作为 on(表达式)，t1 表2行数据、t2 表4行数据，使用 id 列作为条件比较

merge语句如下（向目标表插入数据）：

MERGE INTO t1 USING t2    -- 目标表为t1
ON (t1.id = t2.id)        -- 条件表达式
WHEN NOT MATCHED THEN     -- insert子句固定语法insert values(3, 30, '2000-01-03');  --执行insert操作

可以看到插入了2条数据。这是因为 t1.id 和 t2.id 有2行不相同（t2 的3/4），所以插入了2行。

使用刚才的语句继续执行1次

这次只插入了1行数据。这是因为上次插入的id中包含3，此时 t1.id 包含 1/2/3，t2.id 包含 1/2/3/4，它们之间只有1处不相同，所以只能插入1行。

通过如上案例，可以得出如下结论：merge语句是通过 on(条件表达式) 来判断是否执行 insert 子句向目标表插入数据（将表达式的列数据去重后做比较）：

当 "源表" 与 "目标表" 的条件列数据相同时，无法向目标表插入数据；
当 "源表" 与 "目标表" 的条件列有n行不同时：
- "源表" > "目标表" 时，可以向目标表插入n条数据。
- "源表" < "目标表" 时，无法插入数据。

2.2. update子句

update 子句语法为：

WHEN MATCHED THENupdate子句

规则

表达式对多表的列数据进行去重后比较，当出现n次相同数据时，执行n次update语句

【案例一】用 id 作为 on(表达式)，两张表存在相同的数据

merge语句如下（更新目标表数据）：

MERGE INTO t1 USING t2    -- 目标表为t1
ON (t1.id = t2.id)        -- 条件表达式
WHEN MATCHED THEN         -- update子句固定语法update set t1.amount = t1.amount + 1;  --执行update操作

两张表比较后存在相同的数据，执行 update 子句

【案例二】用 id 作为 on(表达式)，两张表不存在相同的数据

执行与上述相同的 merge 语句

MERGE INTO t1 USING t2    -- 目标表为t1
ON (t1.id = t2.id)        -- 条件表达式
WHEN MATCHED THEN         -- update子句固定语法update set t1.amount = t1.amount + 1;  --执行update操作