概述

INSERT 语句是 SQL 中用于向数据库表插入新记录的核心操作。

Datalayers 当前支持两类常见写法：

• INSERT INTO ... VALUES ...：直接写入一行或多行字面量数据。适合直接写入单条或多条记录。
• INSERT INTO ... SELECT ...：将查询结果写入另一张表。适合做表到表的数据搬运、过滤和派生写入。

语法

-- 指定列名写入数据
INSERT INTO table_name (column1, column2, column3, ...)
VALUES (value1, value2, value3, ...), (value1, value2, value3, ...), ...

-- 将查询结果写入目标表
INSERT INTO target_table
SELECT select_expr [, ...]
FROM source_table
[WHERE condition]

语法示例

-- 指定列名写入数据
INSERT INTO sensor_info(sn, speed, temperature)
VALUES ('100', 22.12, 30.8), ('101', 34.12, 40.6), ('102', 56.12, 52.3);

-- 将 source 表中过滤后的查询结果写入 sink 表
INSERT INTO sink
SELECT *
FROM source
WHERE sid >= 2;

-- SELECT 部分可使用 Datalayers 支持的任意查询语法，包括 SQL hints
INSERT INTO sink
SELECT /*+ set_var(parallel_degree=1) */
  ts, sid, value
FROM source
WHERE sid BETWEEN 2 AND 10;

使用用例

下面示例展示如何先向源表写入测试数据，再通过 INSERT INTO ... SELECT ... 将满足条件的数据写入目标表：

CREATE TABLE `source` (
  ts TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
  sid INT32 NOT NULL,
  value FLOAT,
  timestamp key(ts)
)
PARTITION BY HASH (sid) PARTITIONS 1
ENGINE=TimeSeries;

CREATE TABLE `sink` (
  ts TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
  sid INT32 NOT NULL,
  value FLOAT,
  timestamp key(ts)
)
PARTITION BY HASH (sid) PARTITIONS 1
ENGINE=TimeSeries;

INSERT INTO source (ts, sid, value) VALUES
  (1732099812633, 1, 10.1),
  (1732099812634, 2, 20.2),
  (1732099812635, 3, 30.3);

INSERT INTO sink
SELECT *
FROM source
WHERE sid >= 2;

SELECT sid, value FROM sink;

执行结果会将 source 中 sid >= 2 的记录写入 sink。

执行语义

INSERT INTO ... SELECT ... 是一次性的快照写入，不是持续同步任务。

这意味着：

• 系统只会将源表在请求发起时的当前数据快照写入目标表。
• 即使源表正在被持续写入，请求发起之后新增的数据也不会被自动同步到目标表。

当前版本限制

1. 不支持为 INSERT INTO ... SELECT ... 指定目标列列表

下面的 SQL 当前会报错：

INSERT INTO sink (sid, value)
SELECT sid, value FROM source;

2. 当前只支持时序表到时序表的数据写入

实现层会校验：

• 目标表必须是 TimeSeries 表。
• SELECT 读取到的源表也必须是 TimeSeries 表。

因此，INSERT INTO ... SELECT ... 当前更适合用于时序表之间的数据搬运和过滤写入。