MERGE INTO 语句 – DuckDB - DuckDB 数据库

搜索快捷键 cmd + k | ctrl + k

文档 / SQL / 语句

MERGE INTO 语句

MERGE INTO 语句是 INSERT INTO ... ON CONFLICT 的一种替代方案。由于它允许自定义匹配条件，因此不需要主键。对于目标表没有主键约束的插入更新（Upsert，即 INSERT + UPDATE）用例来说，这是一种非常有用的替代方法。

示例

首先，让我们创建一个简单的表。

CREATE TABLE people (id INTEGER, name VARCHAR, salary FLOAT);
INSERT INTO people VALUES (1, 'John', 92_000.0), (2, 'Anna', 100_000.0);

最简单的插入更新操作是更新或插入整行数据。

MERGE INTO people
    USING (
        SELECT
            unnest([3, 1]) AS id,
            unnest(['Sarah', 'John']) AS name,
            unnest([95_000.0, 105_000.0]) AS salary
    ) AS upserts
    ON (upserts.id = people.id)
    WHEN MATCHED THEN UPDATE
    WHEN NOT MATCHED THEN INSERT;

FROM people
ORDER BY id;

id	name	salary（薪水）
1	John	105000.0
2	Anna	100000.0
3	Sarah	95000.0

在前面的示例中，如果 id 匹配，我们将更新整行数据。然而，接收包含某些键和已更改值的变更集（change set）也是一种常见的模式。这非常适合使用 SET。如果匹配条件中使用的列在源表和目标表中具有相同的名称，则可以在匹配条件中使用关键字 USING。

MERGE INTO people
    USING (
        SELECT
            1 AS id, 
            98_000.0 AS salary
    ) AS salary_updates
    USING (id)
    WHEN MATCHED THEN UPDATE SET salary = salary_updates.salary;

FROM people
ORDER BY id;

id	name	salary（薪水）
1	John	98000.0
2	Anna	100000.0
3	Sarah	95000.0

另一种常见的模式是接收一个删除集（delete set），其中可能仅包含需要删除的行的 ID。

MERGE INTO people
    USING (
        SELECT
            1 AS id, 
    ) AS deletes
    USING (id)
    WHEN MATCHED THEN DELETE;

FROM people
ORDER BY id;

id	name	salary（薪水）
2	Anna	100000.0
3	Sarah	95000.0

MERGE INTO 还支持更复杂的条件。例如，对于给定的删除集，我们可以决定仅删除 salary 大于或等于特定金额的行。

MERGE INTO people
    USING (
        SELECT
            unnest([3, 2]) AS id, 
    ) AS deletes
    USING (id)
    WHEN MATCHED AND people.salary >= 100_000.0 THEN DELETE;

FROM people
ORDER BY id;

id	name	salary（薪水）
3	Sarah	95000.0

如果需要，DuckDB 还支持多个 UPDATE 和 DELETE 条件。RETURNING 子句可用于指出哪些行受到 MERGE 语句的影响。

-- Let's get John back in!
INSERT INTO people VALUES (1, 'John', 105_000.0);

MERGE INTO people
    USING (
        SELECT
            unnest([3, 1]) AS id,
            unnest([89_000.0, 70_000.0]) AS salary
    ) AS upserts
    USING (id)
    WHEN MATCHED AND people.salary < 100_000.0 THEN UPDATE SET salary = upserts.salary
    -- Second update or delete condition
    WHEN MATCHED AND people.salary > 100_000.0 THEN DELETE
    WHEN NOT MATCHED THEN INSERT BY NAME
    RETURNING merge_action, *;

merge_action（合并动作）	id	name	salary（薪水）
UPDATE	3	Sarah	89000.0
DELETE	1	John	105000.0

在某些情况下，如果源数据不满足特定条件，您可能希望执行不同的操作。例如，如果我们期望源数据中不存在的数据也不应出现在目标表中

CREATE TABLE target AS
    SELECT unnest([1,2]) AS id;

MERGE INTO target
    USING (SELECT 1 AS id) source
    USING (id)
    WHEN MATCHED THEN UPDATE
    WHEN NOT MATCHED BY SOURCE THEN DELETE
    RETURNING merge_action, *;

merge_action（合并动作）	id
UPDATE	1
DELETE	2

还有一种可能性是指定 WHEN NOT MATCHED BY TARGET。然而，正如您所料，其行为与 WHEN NOT MATCHED 相同，因为在指定条件时，默认情况下我们查看的是目标表。

语法

关于此页面

行为准则商标使用指南

示例

语法

关于此页面

本文中