创新互联OceanBase教程：OceanBaseMERGE

MERGE 算子用于将源表中的数据行以更新或插入的方式合并到目标表中。

OceanBase 数据库支持的 MERGE 算子包括 MERGE 和 MULTI PARTITION MERGE。

MERGE

MERGE 算子用于合并数据表单个分区中的数据。

如下例所示，Q1 查询将 src_tbl 表中的数据行合并到 t1 表中，对于 src_tbl 中的每一条数据行按照如下方式进行合并：

  • 当 t1 中存在满足 t1.c1=src_tbl.c1 条件的数据行：

    • 如果满足 src_tbl.c2 > '100'，则执行更新操作，将 t1.c2 的值置为 src_tbl.c2 的值（目标表中的每一行只会更新一次）。

    • 如果不满足 src_tbl.c2 > '100'，则不执行更新操作。

  • 当 t1 中不存在满足 t1.c1 = src_tbl.c1 条件的数据行：

    • 如果满足 src_tbl.c1 > 10，则执行插入操作，向 t1 中插入 (src_tbl.c1,src_tbl.c2)。

    • 如果不满足 src_tbl.c1 > 10，则不指定插入操作。


    obclient>CREATE TABLE src_tbl (c1 INT PRIMARY KEY, c2 VARCHAR2(10));
Query OK, 0 rows affected (0.12 sec)

obclient>CREATE TABLE t1 (c1 INT PRIMARY KEY, c2 VARCHAR2(10));
Query OK, 0 rows affected (0.12 sec)

obclient>CREATE TABLE t2 (c1 INT PRIMARY KEY, c2 VARCHAR2(10)) PARTITION BY HASH(c1) 
         PARTITIONS 10;
Query OK, 0 rows affected (0.12 sec)

Q1: 
obclient>EXPLAIN MERGE INTO t1 USING src_tbl ON (t1.c1 = src_tbl.c1)
        WHEN MATCHED THEN 
        UPDATE SET t1.c2 = src_tbl.c2 WHERE src_tbl.c2 > '100'
        WHEN NOT MATCHED THEN 
        INSERT (t1.c1, t1.c2)  VALUES (src_tbl.c1,src_tbl.c2) WHERE src_tbl.c1 > 10\G;
*************************** 1. row ***************************
Query Plan:
===============================================
|ID|OPERATOR         |NAME   |EST. ROWS|COST  |
-----------------------------------------------
|0 |MERGE            |       |100001   |100001|
|1 | MERGE OUTER JOIN|       |100001   |219005|
|2 |  TABLE SCAN     |SRC_TBL|100000   |61860 |
|3 |  TABLE SCAN     |T1     |100000   |61860 |
===============================================

Outputs & filters:
-------------------------------------
  0 - output([column_conv(DECIMAL,PS:(38,0),NOT NULL,SRC_TBL.C1)], [column_conv(VARCHAR,utf8mb4_bin,length:10,NULL,SRC_TBL.C2)]), filter(nil),
      columns([{T1: ({T1: (T1.C1, T1.C2)})}]), partitions(p0),
      update([T1.C2=column_conv(VARCHAR,utf8mb4_bin,length:10,NULL,SRC_TBL.C2)]),
      match_conds([T1.C1 = SRC_TBL.C1]), insert_conds([SRC_TBL.C1 > 10]),
      update_conds([SRC_TBL.C2 > '100']), delete_conds(nil)
  1 - output([SRC_TBL.C1], [SRC_TBL.C2], [T1.C1], [T1.C1 = SRC_TBL.C1], [T1.C2]), filter(nil),
      equal_conds([T1.C1 = SRC_TBL.C1]), other_conds(nil)
  2 - output([SRC_TBL.C1], [SRC_TBL.C2]), filter(nil),
      access([SRC_TBL.C1], [SRC_TBL.C2]), partitions(p0)
  3 - output([T1.C1], [T1.C2]), filter(nil),
      access([T1.C1], [T1.C2]), partitions(p0)

    其中，OUTER JOIN 是合并功能实现时依赖的一次联接操作，使用 MERGE 算子时，一定会在 source_table 和 target_table 上做一次外联接，目的是为了区分哪些行是匹配的，哪些是不匹配的。

    执行计划展示中的 outputs & filters 详细列出了 MERGE 算子的输出信息如下：

    信息名称

    含义

    output

    该算子输出的表达式。

    filter

    该算子上的过滤条件。

    由于示例中 MERGE 算子没有设置 filter，所以为 nil。

    columns

    插入操作涉及的数据表的列。

    partitions

    插入操作涉及到的数据表的分区。

    update

    更新操作中所有的赋值表达式。

    match_conds

    源表和目标表进行匹配的条件。

    insert_conds

    插入操作需要满足的条件。

    update_conds

    更新操作需要满足的条件。

    delete_conds

    删除操作需要满足的条件。

MULTI PARTITION MERGE

MULTI PARTITION MERGE 算子用于合并数据表多个分区中的数据。

如下例所示，Q2 查询将 src_tbl 表中的数据行合并到分区表 t2 表中，对于 src_tbl 中的每一条数据行按照如下方式进行合并：

  • 当 t2 中存在满足 t2.c1 = src_tbl.c1 条件的数据行：

    • 执行更新操作，将 t2.c2 的值置为 substr(src_tbl.c2, 1, 5) 的值（目标表中的每一行只会更新一次）。

    • 更新完成后，如果满足 t2.c2 > '80000' ，则删除对应的数据行。

  • 当 t2 中不存在满足 t2.c1 = src_tbl.c1 条件的数据行，执行插入操作，向 t2 中插入 (src_tbl.c1, src_tbl.c2)。


Q2: 
obclient>EXPLAIN MERGE INTO t2 USING SRC_TBL ON (t2.c1 = src_tbl.c1)
        WHEN MATCHED THEN 
        UPDATE SET t2.c2 = SUBSTR(src_tbl.c2, 1, 5) 
        DELETE WHERE t2.c2 > '80000'
        WHEN NOT MATCHED THEN 
        INSERT (t2.c1, t2.c2) VALUES (src_tbl.c1,src_tbl.c2)\G;
*************************** 1. row ***************************
Query Plan:
============================================================

|ID|OPERATOR                      |NAME    |EST. ROWS|COST   |
--------------------------------------------------------------
|0 |MULTI PARTITION MERGE         |        |100000   |100000 |
|1 | PX COORDINATOR               |        |100000   |956685 |
|2 |  EXCHANGE OUT DISTR          |:EX10001|100000   |899889 |
|3 |   MERGE OUTER JOIN           |        |100000   |899889 |
|4 |    EXCHANGE IN DISTR         |        |100000   |90258  |
|5 |     EXCHANGE OUT DISTR (PKEY)|:EX10000|100000   |61860  |
|6 |      TABLE SCAN              |SRC_TBL |100000   |61860  |
|7 |    SORT                      |        |1000000  |5447108|
|8 |     PX PARTITION ITERATOR    |        |1000000  |618524 |
|9 |      TABLE SCAN              |T2      |1000000  |618524 |
==============================================================

Outputs & filters:
-------------------------------------
  0 - output([column_conv(DECIMAL,PS:(38,0),NOT NULL,SRC_TBL.C1)], [column_conv(VARCHAR,utf8mb4_bin,length:10,NULL,SRC_TBL.C2)]), filter(nil),
      columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p[0-9]),
      update([T2.C2=column_conv(VARCHAR,utf8mb4_bin,length:10,NULL,SUBSTR(SRC_TBL.C2, 1, 5))]),
      match_conds([T2.C1 = SRC_TBL.C1]), insert_conds(nil),
      update_conds(nil), delete_conds([T2.C2 > '80000'])
  1 - output([SRC_TBL.C1], [SRC_TBL.C2], [T2.C1], [T2.C1 = SRC_TBL.C1], [T2.C2]), filter(nil)
  2 - output([SRC_TBL.C1], [SRC_TBL.C2], [T2.C1], [T2.C1 = SRC_TBL.C1], [T2.C2]), filter(nil), dop=1
  3 - output([SRC_TBL.C1], [SRC_TBL.C2], [T2.C1], [T2.C1 = SRC_TBL.C1], [T2.C2]), filter(nil),
      equal_conds([T2.C1 = SRC_TBL.C1]), other_conds(nil)
  4 - output([SRC_TBL.C1], [SRC_TBL.C2]), filter(nil)
  5 - (#keys=1, [SRC_TBL.C1]), output([SRC_TBL.C1], [SRC_TBL.C2]), filter(nil), is_single, dop=1
  6 - output([SRC_TBL.C1], [SRC_TBL.C2]), filter(nil),
      access([SRC_TBL.C1], [SRC_TBL.C2]), partitions(p0)
  7 - output([T2.C1], [T2.C2]), filter(nil), sort_keys([T2.C1, ASC]), local merge sort
  8 - output([T2.C1], [T2.C2]), filter(nil)
  9 - output([T2.C1], [T2.C2]), filter(nil),
      access([T2.C1], [T2.C2]), partitions(p[0-9])

上述示例的执行计划展示中的 outputs & filters 详细列出了 MULTI PARTITION MERGE 算子的输出信息，字段的含义与 MERGE 算子相同。

网页题目：创新互联OceanBase教程：OceanBaseMERGE
标题URL：http://www.csdahua.cn/qtweb/news48/364498.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

商城网站知识

行业网站建设

成都网站设计　　 　响应式建站　　 　攀枝花网站设计　　 　成都做网站　　 　响应式网站建设　　 　成都logo设计公司　　 　移动网站建设　　 　成都App定制　　 　四川盐亭做网站　　 　成都移动机房　　 　重庆网络营销　　 　眉山托管服务器　　 　青羊区雕琢时光　　 　四川德阳主机托管　　 　响应式网站　　 　绵阳科技城电信IDC机房　　 　宏昇商务服务　　 　品牌网站建设　　 　四川雅安服务器托管　　 　成都外贸网站建设公司