INSERT

功能描述

向表中添加一行或多行数据。

注意事项

• 只有拥有表INSERT权限的用户，才可以向表中插入数据。

• 如果使用RETURNING子句，用户必须要有该表的SELECT权限。

• 如果使用ON DUPLICATE KEY UPDATE，用户必须要有该表的SELECT、UPDATE权限，唯一约束（主键或唯一索引）的SELECT权限。

• 如果使用query子句插入来自查询里的数据行，用户还需要拥有在查询里使用的表的SELECT权限。

• 当连接到TD兼容的数据库时，td_compatible_truncation参数设置为on时，将启用超长字符串自动截断功能，在后续的insert语句中（不包含外表的场景下），对目标表中char和varchar类型的列上插入超长字符串时，系统会自动按照目标表中相应列定义的最大长度对超长字符串进行截断。

  说明：
  如果向字符集为字节类型编码（SQL_ASCII，LATIN1等）的数据库中插入多字节字符数据（如汉字等），且字符数据跨越截断位置，这种情况下，按照字节长度自动截断，自动截断后会在尾部产生非预期结果。如果用户有对于截断结果正确性的要求，建议用户采用UTF8等能够按照字符截断的输入字符集作为数据库的编码集。

语法格式

[ WITH [ RECURSIVE ] with_query [, ...] ]
INSERT INTO table_name [ ( column_name [, ...] ) ]
    { DEFAULT VALUES
    | VALUES {( { expression | DEFAULT } [, ...] ) }[, ...] 
    | query }
    [ ON DUPLICATE KEY UPDATE {{ column_name = { expression | DEFAULT } } [, ...] | NOTHING} ]
    [ RETURNING {* | {output_expression [ [ AS ] output_name ] }[, ...]} ];

参数说明

• WITH [ RECURSIVE ] with_query [, …]

  用于声明一个或多个可以在主查询中通过名称引用的子查询，相当于临时表。

  如果声明了RECURSIVE，那么允许SELECT子查询通过名称引用它自己。

  其中with_query的详细格式为：with_query_name [ ( column_name [, …] ) ] AS

  ( {select | values | insert | update | delete} )

  – with_query_name指定子查询生成的结果集名称，在查询中可使用该名称访问

  子查询的结果集。

  – column_name指定子查询结果集中显示的列名。

  – 每个子查询可以是SELECT，VALUES，INSERT，UPDATE或DELETE语句。

  说明：
  INSERT ON DUPLICATE KEY UPDATE不支持WITH及WITH RECURSIVE子句。

• table_name

  要插入数据的目标表名。

  取值范围：已存在的表名。

• column_name

  目标表中的字段名：

  • 字段名可以有子字段名或者数组下标修饰。
  • 没有在字段列表中出现的每个字段，将由系统默认值，或者声明时的默认值填充，若都没有则用NULL填充。例如，向一个复合类型中的某些字段插入数据的话，其他字段将是NULL。
  • 目标字段（column_name）可以按顺序排列。如果没有列出任何字段，则默认全部字段，且顺序为表声明时的顺序。
  • 如果value子句和query中只提供了N个字段，则目标字段为前N个字段。
  • value子句和query提供的值在表中从左到右关联到对应列。

  取值范围：已存在的字段名。

• expression

  赋予对应column的一个有效表达式或值：

  • 如果是INSERT ON DUPLICATE KEY UPDATE语句下，expression可以为VALUES(column_name)或EXCLUDED.column_name用来表示引用冲突行对应的column_name字段的值。需注意，其中VALUES(column_name)不支持嵌套在表达式中（例如VALUES(column_name)+1），但EXCLUDED不受此限制。

  • 向表中字段插入单引号 " ' “时需要使用单引号自身进行转义。

  • 如果插入行的表达式不是正确的数据类型，系统试图进行类型转换，若转换不成功，则插入数据失败，系统返回错误信息。

• DEFAULT

  对应字段名的缺省值。如果没有缺省值，则为NULL。

• query

  一个查询语句（SELECT语句），将查询结果作为插入的数据。

• RETURNING

  返回实际插入的行，RETURNING列表的语法与SELECT的输出列表一致。注意：INSERT ON DUPLICATE KEY UPDATE不支持RETURNING子句。

• output_expression

  INSERT命令在每一行都被插入之后用于计算输出结果的表达式。

  取值范围：该表达式可以使用table的任意字段。可以使用*返回被插入行的所有字段。

• output_name

  字段的输出名称。

  取值范围：字符串，符合标识符命名规范。

• ON DUPLICATE KEY UPDATE

  对于带有唯一约束（UNIQUE INDEX或PRIMARY KEY）的表，如果插入数据违反唯一约束，则对冲突行执行UPDATE子句完成更新。对于不带唯一约束的表，则仅执行插入。UPDATE时，若指定NOTHING则忽略此条插入，可通过"EXCLUDE.” 或者 “VALUES()” 来选择源数据相应的列。

  • 支持触发器，触发器执行顺序由实际执行流程决定：
  • 执行insert：触发before insert、after insert触发器。
  • 执行update：触发before insert、before update、after update触发器。
  • 执行update nothing：触发before insert触发器。
  • 不支持延迟生效（DEFERRABLE）的唯一约束或主键。

• 如果表中存在多个唯一约束，如果所插入数据违反多个唯一约束，对于检测到冲突的第一行进行更新，其他冲突行不更新（检查顺序与索引维护具有强相关性，一般先创建的索引先进行冲突检查）。

  • 如果插入多行，这些行均与表中同一行数据存在唯一约束冲突，则按照顺序，第一条执行插入或更新，之后依次执行更新。

• 主键、唯一索引列不允许UPDATE。

  • 不支持列存，不支持外表、内存表。

  说明：
  当GUC参数 enable_upsert_to_merge 为 on 时，此条INSERT ON DUPLICATE KEY UPDATE语句(UPSERT语句)会被转换成一条具有同等语义的MERGE INTO语句，之后的行为与MERGE INTO相同，在如下行为中与UPSERT将会不同：

  • 不支持UPDATE更新自定义类型或者数组类型的元素的值
  • 如果INSERT指定了目标列，那么仅检查只包含目标列或设有DEFAULT值的列的唯一约束或主键约束冲突。
  • 当表中存在多个唯一约束，如果所插入数据与表中多个行都存在唯一约束冲突，所有冲突行都会执行UPDATE子句完成更新。
  • 如果插入多行，这些行均与表中同一行数据存在唯一约束冲突，执行会失败。需设置GUC参数 behavior_compat_options ='merge_update_multi'，允许该对冲突行会执行多次UPDATE。
  • 如果插入多行，这些行与表中已有数据不存在唯一约束冲突，但是相互违反唯一约束时，INSERT执行失败。
  • 在多行插入场景，执行性能较差。由于MERGE INTO不支持并发更新，在多行插入情况下，容易出现报错导致事务回滚。
  • 通过EXPLAIN 显示的计划为转换为MERGE INTO语句的执行计划。

示例

--创建表tpcds.reason_t2。
postgres=# CREATE TABLE tpcds.reason_t2
  r_reason_sk    integer,
  r_reason_id    character(16),
  r_reason_desc  character(100)
--向表中插入一条记录。
postgres=# INSERT INTO tpcds.reason_t2(r_reason_sk, r_reason_id, r_reason_desc) VALUES (1, 'AAAAAAAABAAAAAAA', 'reason1');
--向表中插入一条记录，和上一条语法等效。
postgres=# INSERT INTO tpcds.reason_t2 VALUES (2, 'AAAAAAAABAAAAAAA', 'reason2');
--向表中插入多条记录。
postgres=# INSERT INTO tpcds.reason_t2 VALUES (3, 'AAAAAAAACAAAAAAA','reason3'),(4, 'AAAAAAAADAAAAAAA', 'reason4'),(5, 'AAAAAAAAEAAAAAAA','reason5');
--向表中插入tpcds.reason中r_reason_sk小于5的记录。
postgres=# INSERT INTO tpcds.reason_t2 SELECT * FROM tpcds.reason WHERE r_reason_sk <5;
--对表创建唯一索引
postgres=# CREATE UNIQUE INDEX reason_t2_u_index ON tpcds.reason_t2(r_reason_sk);
--向表中插入多条记录，如果冲突则更新冲突数据行中r_reason_id字段为'BBBBBBBBCAAAAAAA'。
postgres=# INSERT INTO tpcds.reason_t2 VALUES (5, 'BBBBBBBBCAAAAAAA','reason5'),(6, 'AAAAAAAADAAAAAAA', 'reason6') ON DUPLICATE KEY UPDATE r_reason_id = 'BBBBBBBBCAAAAAAA';
--向表中插入多条记录，如果冲突则忽略此条插入。
postgres=# INSERT INTO tpcds.reason_t2 VALUES (5, 'BBBBBBBBCAAAAAAA','reason5'),(6, 'AAAAAAAADAAAAAAA', 'reason6') ON DUPLICATE KEY UPDATE NOTHING;
--向表中插入多条记录，如果冲突则更新冲突数据行中r_reason_id字段为插入数据的r_reason_id值。
postgres=# INSERT INTO tpcds.reason_t2 VALUES (5, 'BBBBBBBBCAAAAAAA','reason5'),(6, 'AAAAAAAADAAAAAAA', 'reason6') ON DUPLICATE KEY UPDATE r_reason_id = EXCLUDED.r_reason_id;
postgres=# INSERT INTO tpcds.reason_t2 VALUES (5, 'BBBBBBBBCAAAAAAA','reason5'),(6, 'AAAAAAAADAAAAAAA', 'reason6') ON DUPLICATE KEY UPDATE r_reason_id = values(r_reason_id);
--删除表tpcds.reason_t2。
postgres=# DROP TABLE tpcds.reason_t2;

优化建议

• VALUES

  通过insert语句批量插入数据时，建议将多条记录合并入一条语句中执行插入，以提高数据加载性能。例如，INSERT INTO sections VALUES (30, 'Administration', 31, 1900),(40, 'Development', 35, 2000), (50, 'Development' , 60 , 2001);