SQL插入数据 - 云原生多模数据库 Lindorm

UPSERT是INSERT与UPDATE的结合语法，表示行存在时执行UPDATE，不存在时执行INSERT。执行UPSERT操作时必须指定完整的PRIMARY KEY的相关列信息。UPSERT语法支持带时间戳的数据写入和批量写入，其中的UPSERT谓词也可用INSERT来替代。

引擎与版本

UPSERT语法适用于宽表引擎和时序引擎。无版本限制。

与关系型数据库写入的区别

Lindorm的UPSERT语句写入数据的效果与传统关系型数据库的写入效果存在以下不同：

传统关系型数据库
如果表定义了PRIMARY KEY，那么当连续两次写入相同PRIMARY KEY的数据时（使用INSERT语句且不带ON DUPLICATE KEY子句），第二次写入会失败。此时需要执行UPDATE语句，或在第二次执行INSERT语句时，在语句中带上ON DUPLICATE KEY子句。
Lindorm
- 宽表引擎：使用UPSERT语句写入数据时，即使连续两次写入的PRIMARY KEY相同，第二次写入数据时也不会报错，而是覆盖UPSERT涉及的数据。实际上，Lindorm会将两次写入的数据保存为两个版本，当使用SELECT语句查询某行数据时，默认返回最新版本的数据。
- 时序引擎：使用UPSERT语句写入数据时，连续两次写入的PRIMARY KEY相同，则第二次写入的数据将直接覆盖第一次写入的数据。

使用UPSERT语句连续两次写入相同PRIMARY KEY数据的示例，请参见写入相同PRIMARY KEY的数据。

语法

upsert_statement   ::= { UPSERT | INSERT } [ hint_expression ] 
                       INTO table_identifier columns_delaration
                       VALUES value_list ( ',' value_list)*
                       [ ON DUPLICATE KEY column_identifier = 
                         value_literal | IGNORE ]
columns_delaration ::=  '(' column_identifier ( ',' column_identifier)* ')'
value_list         ::=  '(' value_expression( ',' value_expression)* ')'

使用说明

HINT表达式（hint_expression）

仅宽表引擎支持HINT表达式。

支持在UPSERT语句中添加HINT参数_l_ts_，用于指定写入数据的时间戳。_l_ts_参数的详细介绍，请参见hintOption参数说明。

ON DUPLICATE KEY

仅宽表引擎支持ON DUPLICATE KEY子句。

ON DUPLICATE KEY子句用于检查指定行是否已存在，类似于HBase中的checkAndPut操作，具体规则如下：

ON DUPLICATE KEY子句后跟随UPDATE，用于更新某一列的值。如果指定行已存在，则执行UPDATE关键字后的语句，更新指定列的值；如果指定行不存在，则既不报错也不更新指定列的值。例如ON DUPLICATE KEY UPDATE c1 = 20是指如果指定行已存在，则将c1列的值更新为20；如果指定行不存在则不更新也不报错。
ON DUPLICATE KEY子句后跟随IGNORE时，如果指定行已存在，则既不报错也不写入；如果指定行不存在，则直接将数据写入。
仅支持CONSISTENCY为strong的表。CONSISTENCY参数的详细介绍，请参见表属性（table_options）。如果您想要更改CONSISTENCY参数的值，请参见ALTER TABLE。

示例

假设示例表sensor的结构如下：

CREATE TABLE sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time)
)WITH(VERSIONS=2);