您的位置：58脚本 > OceanBase INSERT

OceanBase INSERT

2023-05-09 19:32 OceanBase INSERT

OceanBase INSERT

INSERT 算子用于将指定的数据插入数据表，数据来源包括直接指定的值和子查询的结果。

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

INSERT

INSERT 算子用于向数据表的单个分区中插入数据。

如下例所示，Q1 查询将值 (1, '100') 插入到非分区表 t1 中。其中 1 号算子 EXPRESSION 用来生成常量表达式的值。

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)

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

obclient>CREATE INDEX IDX_t3_c2 ON t3 (c2) PARTITION BY HASH(c2) PARTITIONS 3;
Query OK, 0 rows affected (0.12 sec)

Q1: 
obclient>EXPLAIN INSERT INTO t1 VALUES (1, '100')G;
*************************** 1. row ***************************
Query Plan:
====================================
|ID|OPERATOR   |NAME|EST. ROWS|COST|
------------------------------------
|0 |INSERT     |    |1        |1   |
|1 | EXPRESSION|    |1        |1   |
====================================

Outputs & filters:
-------------------------------------
  0 - output([__values.C1], [__values.C2]), filter(nil),
      columns([{T1: ({T1: (T1.C1, T1.C2)})}]), partitions(p0)
  1 - output([__values.C1], [__values.C2]), filter(nil)
      values({1, '100'})

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

信息名称	含义
output	该算子输出的表达式。
filter	该算子上的过滤条件。由于示例中 INSERT 算子没有设置 filter，所以为 nil。
columns	插入操作涉及的数据表的列。
partitions	插入操作涉及到的数据表的分区（非分区表可以认为是一个只有一个分区的分区表）。

更多 INSERT 算子的示例如下：

Q2 查询将值（2, '200'）、（3, '300'）插入到表 t1 中。

Q2: 
obclient>EXPLAIN INSERT INTO t1 VALUES (2, '200'),(3, '300')G;
*************************** 1. row ***************************
Query Plan:
====================================
|ID|OPERATOR   |NAME|EST. ROWS|COST|
------------------------------------
|0 |INSERT     |    |2        |1   |
|1 | EXPRESSION|    |2        |1   |
====================================

Outputs & filters:
-------------------------------------
  0 - output([__values.C1], [__values.C2]), filter(nil),
      columns([{T1: ({T1: (T1.C1, T1.C2)})}]), partitions(p0)
  1 - output([__values.C1], [__values.C2]), filter(nil)
      values({2, '200'}, {3, '300'})

Q3 查询将子查询 SELECT * FROM t3 的结果插入到表 t1 中。

Q3: 
obclient>EXPLAIN INSERT INTO t1 SELECT * FROM t3G;
*************************** 1. row ***************************
Query Plan:
====================================
|0 |INSERT              |     |100000   |117862|
|1 | EXCHANGE IN DISTR  |     |100000   |104060|
|2 |  EXCHANGE OUT DISTR|     |100000   |75662 |
|3 |   SUBPLAN SCAN     |VIEW1|100000   |75662 |
|4 |    TABLE SCAN      |T3   |100000   |61860 |
================================================

Outputs & filters:
-------------------------------------
  0 - output([VIEW1.C1], [VIEW1.C2]), filter(nil),
      columns([{T1: ({T1: (T1.C1, T1.C2)})}]), partitions(p0)
  1 - output([VIEW1.C1], [VIEW1.C2]), filter(nil)
  2 - output([VIEW1.C1], [VIEW1.C2]), filter(nil)
  3 - output([VIEW1.C1], [VIEW1.C2]), filter(nil),
      access([VIEW1.C1], [VIEW1.C2])
  4 - output([T3.C1], [T3.C2]), filter(nil),
      access([T3.C2], [T3.C1]), partitions(p0)

Q4 查询将值（1, '100'）插入到分区表 t2 中，通过 partitions 参数可以看出，该值会被插入到 t2 的 p5 分区。

Q4: 
obclient>EXPLAIN INSERT INTO t2 VALUES (1, '100')G;
*************************** 1. row ***************************
Query Plan:
====================================
|ID|OPERATOR   |NAME|EST. ROWS|COST|
------------------------------------
|0 |INSERT     |    |1        |1   |
|1 | EXPRESSION|    |1        |1   |
====================================
Outputs & filters:
-------------------------------------
  0 - output([__values.C1], [__values.C2]), filter(nil),
      columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p5)
  1 - output([__values.C1], [__values.C2]), filter(nil)
      values({1, '100'})

MULTI PARTITION INSERT

MULTI PARTITION INSERT 算子用于向数据表的多个分区中插入数据。

如下例所示，Q5 查询将值（2, '200'）、（3, '300'）插入到分区表 t2 中，通过 partitions 可以看出，这些值会被插入到 t2 的 p0 和 p6 分区。

Q5: 
obclient>EXPLAIN INSERT INTO t2 VALUES (2, '200'),(3, '300')G;
*************************** 1. row ***************************
Query Plan:
===============================================
|ID|OPERATOR              |NAME|EST. ROWS|COST|
-----------------------------------------------
|0 |MULTI PARTITION INSERT|    |2        |1   |
|1 | EXPRESSION           |    |2        |1   |
===============================================

Outputs & filters:
-------------------------------------
  0 - output([__values.C1], [__values.C2]), filter(nil),
      columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p0, p6)
  1 - output([__values.C1], [__values.C2]), filter(nil)
      values({2, '200'}, {3, '300'})

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

更多 MULTI PARTITION INSERT 算子的示例如下：

Q6 查询将子查询 SELECT * FROM t3 的结果插入到分区表 t2 中，因为无法确定子查询的结果集，因此数据可能插入到 t2 的 p0 到 p9 的任何一个分区中。从1 号算子可以看到，这里的 SELECT * FROM t3 会被放在一个子查询中，并将子查询命名为 VIEW1。当 OceanBase 数据库内部改写 SQL 产生了子查询时，会自动为子查询命名，并按照子查询生成的顺序命名为 VIEW1、VIEW2、VIEW3...

Q6: 
obclient>EXPLAIN INSERT INTO t2 SELECT * FROM t3G;
*************************** 1. row ***************************
Query Plan:
==============================================
|ID|OPERATOR             |NAME|EST. ROWS|COST|
--------------------------------------------------
|0 |MULTI PARTITION INSERT|     |100000   |117862|
|1 | EXCHANGE IN DISTR    |     |100000   |104060|
|2 |  EXCHANGE OUT DISTR  |     |100000   |75662 |
|3 |   SUBPLAN SCAN       |VIEW1|100000   |75662 |
|4 |    TABLE SCAN        |T3   |100000   |61860 |
==================================================

Outputs & filters:
-------------------------------------
  0 - output([VIEW1.C1], [VIEW1.C2]), filter(nil),
      columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p[0-9])
  1 - output([VIEW1.C1], [VIEW1.C2]), filter(nil)
  2 - output([VIEW1.C1], [VIEW1.C2]), filter(nil)
  3 - output([VIEW1.C1], [VIEW1.C2]), filter(nil),
      access([VIEW1.C1], [VIEW1.C2])
  4 - output([T3.C1], [T3.C2]), filter(nil),
      access([T3.C2], [T3.C1]), partitions(p0)

Q7 查询将值（1, '100'）插入到非分区表 t3 中。虽然 t3 本身是一个非分区表，但因为 t3 上存在全局索引 idx_t3_c2，因此本次插入也涉及到了多个分区。

Q7: 
obclient>EXPLAIN INSERT INTO t3 VALUES (1, '100')G;
*************************** 1. row ***************************
Query Plan:
==============================================
|ID|OPERATOR              |NAME|EST. ROWS|COST|
-----------------------------------------------
|0 |MULTI PARTITION INSERT|    |1        |1   |
|1 | EXPRESSION           |    |1        |1   |
===============================================

Outputs & filters:
-------------------------------------
  0 - output([__values.C1], [__values.C2]), filter(nil),
      columns([{T3: ({T3: (T3.C1, T3.C2)}, {IDX_T3_C2: (T3.C2, T3.C1)})}]), partitions(p0)
  1 - output([__values.C1], [__values.C2]), filter(nil)
      values({1, '100'})

阅读全文

以上是58脚本为你收集整理的 OceanBase INSERT全部内容。

声明：本站所有文章资源内容，如无特殊说明或标注，均为采集网络资源。如若本站内容侵犯了原著者的合法权益，可联系本站删除。

全部标签 标签详情

鸿蒙os应用基础知识大全鸿蒙OS 应用基础知识

鸿蒙OS开发文档

APPHarmonyOS 的应用软件包以 APP Pack（Application Package）形式发布，它是由一个或多个 HAP（HarmonyOS Ability Package）以...
鸿蒙os模拟器鸿蒙OS 模拟器运行

鸿蒙OS开发文档

点击 ToolsHVD Manager 登录过程中一直卡住不动，如何解决？问题现象使用模拟器前需跳转至浏览器登录页面，使用个人实名帐号进行...
鸿蒙系统鸿蒙OS SortedMap

鸿蒙OS开发文档

SortedMappublic interface SortedMapK,Vextends MapK,V进一步提供对其键的总排序的 Map。映射根据其键的 Comparable 或通常在...
鸿蒙系统鸿蒙OS AbstractList

鸿蒙OS开发文档

AbstractListjava.lang.Object |---java.util.AbstractCollectionE |---|---java.util.AbstractListEpublic abstract class Abst...
鸿蒙系统鸿蒙OS ArrayList

鸿蒙OS开发文档

ArrayListjava.lang.Object |---java.util.AbstractCollectionE |---|---java.util.AbstractListE |---|---|---java.util.ArrayL...
微信小程序使用插件怎么设置微信小程序使用插件

04-04

使用插件添加插件在使用插件前，首先要在小程序管理后台的“设置-第三方服务-插件管理”中添加插件。开发者可登录小程序管理后台...
微信小程序网络测速微信小程序小程序测速

03-20

小程序测速为帮助开发者优化小程序性能，我们推出了"小程序测速"功能。"小程序测速"可以简单方便地统计小程序内某一事件的实时耗...
微信小程序canvas绘制微信小程序API 绘介绍（如何在Canvas上画）

04-26

绘图接口和方法在Canvas上画图所有在canvas/中的画图必须用 JavaScript 完成：WXML：（我们在接下来的例子中如无特殊声明都会用...
微信小程序绘微信小程序API 绘·draw（进行绘）

05-14

绘图接口和方法canvasContext.draw定义将之前在绘图上下文中的描述（路径、变形、样式）画到 canvas 中。Tip: 绘图上下文需要由w...
微信小程序api用户数据的签名验证和加解密的区别微信小程序API 用户数据的签名验证和加解密

04-13

用户数据的签名验证和加解密数据签名校验为了确保开放接口返回用户数据的安全性，微信会对明文数据进行签名。开发者可以根据业...