GaussDB数据库中的MERGE INTO介绍

本文介绍: MERGE INTO 语句在GaussDB数据库中是一个非常好用、方便的SQL工具。同时，在数据处理工作中起着非常重要的作用，它能够提高数据处理效率，简化数据处理流程，满足各种数据处理需求。本文通过在GaussDB数据库中模拟了一则简单的示例为大家进行了讲解，希望可以帮助读者更好的理解与使用。

一、前言

二、GaussDB MERGE INTO 语句的原理概述

1、MERGE INTO 语句原理

2、MERGE INTO 的语法

3、语法解释

三、GaussDB MERGE INTO 语句的应用场景

MERGE [/*+ plan_hint */] INTO table_name [ partition_clause ] [ [ AS ] alias ]
USING { { table_name | view_name } | subquery } [ [ AS ] alias ]
ON ( condition )
[
  WHEN MATCHED THEN
  UPDATE SET { column_name = { expression | subquery | DEFAULT } |
          ( column_name [, ...] ) = ( { expression | subquery | DEFAULT } [, ...] ) } [, ...]
  [ WHERE condition ]
]
[
  WHEN NOT MATCHED THEN
  INSERT { DEFAULT VALUES |
  [ ( column_name [, ...] ) ] VALUES ( { expression | subquery | DEFAULT } [, ...] ) [, ...] [ WHERE condition ] }
];

where partition_clause can be:
PARTITION { ( partition_name ) | FOR ( partition_value [, ...] ) } |
SUBPARTITION { ( subpartition_name ) | FOR ( subpartition_value [, ...] ) }
NOTICE: 'partition_clause' is only avaliable in CENTRALIZED mode!
NOTICE: 'subquery' in the UPDATE and INSERT clauses are only avaliable in CENTRALIZED mode!

--创建测试表target_table,存储历史销售数据
CREATE TABLE public.target_table
(
  product_id VARCHAR(20),
  product_name VARCHAR(20),
  sales_sum_number INT,
  sales_sum_amount MONEY,
  create_date VARCHAR(8),
  update_date VARCHAR(8)
);

--插入测试数据
INSERT INTO public.target_table(product_id,product_name,sales_sum_number,sales_sum_amount,create_date,update_date) VALUES('P1001','books',100,1000,'20240101','30001231');
INSERT INTO public.target_table(product_id,product_name,sales_sum_number,sales_sum_amount,create_date,update_date) VALUES('P1002','pens',200,400,'20240102','30001231');

--创建测试表source_table,包含最新的销售数据
CREATE TABLE public.source_table
(
  product_id VARCHAR(20),
  product_name VARCHAR(20),
  sales_sum_number INT,
  sales_sum_amount MONEY,
  create_date VARCHAR(8)
);

--插入测试数据
INSERT INTO public.source_table(product_id,product_name,sales_sum_number,sales_sum_amount,create_date) VALUES('P1001','books',50,500,'20240103');
INSERT INTO public.source_table(product_id,product_name,sales_sum_number,sales_sum_amount,create_date) VALUES('P1003','toys',100,1000,'20240103');

--查看结果
SELECT * FROM public.target_table;
SELECT * FROM public.source_table;

--更新 target_table 中的销售数据，并插入新的销售记录。
MERGE INTO target_table AS t  
USING source_table AS s  
ON (t.product_id = s.product_id)  
WHEN MATCHED THEN  
    UPDATE SET t.sales_sum_number=t.sales_sum_number + s.sales_sum_number,t.sales_sum_amount = t.sales_sum_amount + s.sales_sum_amount,t.update_date = s.create_date
WHEN NOT MATCHED THEN  
INSERT (product_id,product_name,sales_sum_number,sales_sum_amount,create_date,update_date) VALUES (s.product_id,s.product_name,s.sales_sum_number,s.sales_sum_amount,s.create_date,'30001231');

--查看执行结果
SELECT * FROM public.target_table;