--- title: "INSERT - OceanBase 数据库 V4.2.1 | OceanBase 文档中心" description: INSERT INSERT 算子用于将指定的数据插入数据表，数据来源包括直接指定的值和子查询的结果。 OceanBase 数据库支持的 INSERT 算子有两种形式：普通的 INSERT 和 DISTRIBUTED INSERT 。 普通 INSERT 普通的 INSERT 用于向数据表的单个分区中插入数据。 如下例… --- 切换语言 - 中文站 - 简体中文 - International - English - 日本站 - 日本語 文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*P8CuR4UJ_FkAAAAAAAAAAAAADiGDAQ/original) OceanBase 数据库分布式版 - V 4.2.1 LTS # INSERT 更新时间：2026-04-16 00:11:36 [编辑](https://github.com/oceanbase/oceanbase-doc/edit/V4.2.1/zh-CN/700.reference/1000.performance-tuning-guide/500.sql-optimization/200.sql-execution-plan/200.execution-plan-operator/1900.INSERT.md) `INSERT` 算子用于将指定的数据插入数据表，数据来源包括直接指定的值和子查询的结果。 OceanBase 数据库支持的 `INSERT` 算子有两种形式：普通的 `INSERT` 和 `DISTRIBUTED INSERT`。 ## 普通 `INSERT` 普通的 `INSERT` 用于向数据表的单个分区中插入数据。 如下例所示，Q1 查询将值 (1, '100') 插入到非分区表 `t1` 中。其中 1 号算子`EXPRESSION` 用来生成常量表达式的值。 ```sql --Oracle 模式下： obclient> CREATE TABLE t1 (c1 INT PRIMARY KEY, c2 VARCHAR2(10)); Query OK, 0 rows affected obclient> CREATE TABLE t2 (c1 INT PRIMARY KEY, c2 VARCHAR2(10)) PARTITION BY HASH(c1) PARTITIONS 10; Query OK, 0 rows affected obclient> CREATE TABLE t3 (c1 INT PRIMARY KEY, c2 VARCHAR2(10)); Query OK, 0 rows affected obclient> CREATE INDEX IDX_t3_c2 ON t3 (c2) PARTITION BY HASH(c2) PARTITIONS 3; Query OK, 0 rows affected --MySQL模式下： obclient> CREATE TABLE t1 (c1 INT PRIMARY KEY, c2 INT); Query OK, 0 rows affected obclient> CREATE TABLE t2 (c1 INT PRIMARY KEY, c2 INT) PARTITION BY HASH(c1) PARTITIONS 10; Query OK, 0 rows affected obclient> CREATE TABLE t3 (c1 INT PRIMARY KEY, c2 INT); Query OK, 0 rows affected Q1: obclient> EXPLAIN INSERT INTO t1 VALUES (1, '100'); Query Plan: ==================================== |ID|OPERATOR |NAME|EST. ROWS|COST| ------------------------------------ |0 |INSERT | |1 |1 | |1 | EXPRESSION| |1 |1 | ==================================== Outputs & filters: ------------------------------------- 0 - output([column_conv(NUMBER,PS:(38,0),NOT NULL,__values.C1)], [column_conv(VARCHAR2,utf8mb4_bin,length:10,NULL,__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` 中。 ```sql Q2: obclient> EXPLAIN INSERT INTO t1 VALUES (2, '200'),(3, '300'); Query Plan: ==================================== |ID|OPERATOR |NAME|EST. ROWS|COST| ------------------------------------ |0 |INSERT | |2 |1 | |1 | EXPRESSION| |2 |1 | ==================================== Outputs & filters: ------------------------------------- 0 - output([column_conv(NUMBER,PS:(38,0),NOT NULL,__values.C1)], [column_conv(VARCHAR2,utf8mb4_bin,length:10,NULL,__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` 中。 ```sql Q3: obclient> EXPLAIN INSERT INTO t1 SELECT * FROM t3; 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` 分区。 ```sql Q4: obclient> EXPLAIN INSERT INTO t2 VALUES (1, '100'); Query Plan: ==================================== |ID|OPERATOR |NAME|EST. ROWS|COST| ------------------------------------ |0 |INSERT | |1 |1 | |1 | EXPRESSION| |1 |1 | ==================================== Outputs & filters: ------------------------------------- 0 - output([column_conv(NUMBER,PS:(38,0),NOT NULL,__values.C1)], [column_conv(VARCHAR2,utf8mb4_bin,length:10,NULL,__values.C2)]), filter(nil), columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p5) 1 - output([__values.C1], [__values.C2]), filter(nil) values({1, '100'}) ``` ## DISTRIBUTED INSERT `DISTRIBUTED INSERT` 用于向数据表的多个分区中插入数据。 如下例所示，Q5 查询将值（2, '200'）、（3, '300'）插入到分区表 `t2` 中，通过 `partitions` 可以看出，这些值会被插入到 `t2` 的 `p0` 和 `p6` 分区。 ```sql Q5: obclient> EXPLAIN INSERT INTO t2 VALUES (2, '200'),(3, '300'); Query Plan: =============================================== |ID|OPERATOR |NAME|EST. ROWS|COST| ----------------------------------------------- |0 |DISTRIBUTED INSERT| |2 |1 | |1 | EXPRESSION | |2 |1 | =============================================== Outputs & filters: ------------------------------------- 0 - output([column_conv(NUMBER,PS:(38,0),NOT NULL,__values.C1)], [column_conv(VARCHAR2,utf8mb4_bin,length:10,NULL,__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` 详细列出了 `DISTRIBUTED INSERT` 算子的信息，字段的含义与 `INSERT` 算子相同。 更多 `DISTRIBUTED INSERT` 算子的示例如下： - Q6 查询将子查询 `SELECT * FROM t3` 的结果插入到分区表 `t2` 中，因为无法确定子查询的结果集，因此数据可能插入到 `t2` 的 `p0` 到 `p9` 的任何一个分区中。从 3 号算子可以看到，这里的 `SELECT * FROM t3` 会被放在一个子查询中，并将子查询命名为 `VIEW1`。当 OceanBase 数据库内部改写 SQL 产生了子查询时，会自动为子查询命名，并按照子查询生成的顺序命名为 `VIEW1`、`VIEW2`、`VIEW3`... ```sql Q6: obclient> EXPLAIN INSERT INTO t2 SELECT * FROM t3; Query Plan: ============================================== |ID|OPERATOR |NAME |EST. ROWS|COST | --------------------------------------------- |0 |DISTRIBUTED INSERT| |100000 |41687| |1 | SUBPLAN SCAN |VIEW1|100000 |40184| |2 | TABLE SCAN |T3 |100000 |38681| ============================================= Outputs & filters: ------------------------------------- 0 - output([column_conv(NUMBER,PS:(38,0),NOT NULL,VIEW1.C1)], [column_conv(VARCHAR2,utf8mb4_bin,length:10,NULL,VIEW1.C2)]), filter(nil), columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p[0-9]) 1 - output([VIEW1.C1], [VIEW1.C2]), filter(nil), access([VIEW1.C1], [VIEW1.C2]) 2 - output([T3.C1], [T3.C2]), filter(nil), access([T3.C2], [T3.C1]), partitions(p0) ``` - Q7 查询将值（1, '100'）插入到非分区表 `t3` 中。虽然 `t3` 本身是一个非分区表，但因为 `t3` 上存在全局索引 `idx_t3_c2`，因此本次插入也涉及到了多个分区。 ```sql Q7: obclient> EXPLAIN INSERT INTO t3 VALUES (1, '100'); Query Plan: =========================================== |ID|OPERATOR |NAME|EST. ROWS|COST| ------------------------------------------- |0 |DISTRIBUTED INSERT| |1 |20 | |1 | EXPRESSION | |1 |1 | =========================================== Outputs & filters: ------------------------------------- 0 - output([column_conv(NUMBER,PS:(38,0),NOT NULL,__values.C1)], [column_conv(VARCHAR2,utf8mb4_bin,length:10,NULL,__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'}) ``` 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线