You need to enable JavaScript to run this app.
导航
插入语句 (INSERT)
最近更新时间:2024.11.06 13:58:48首次发布时间:2024.11.01 11:00:45

向表中添加数据。

INSERT 值

Data can be inserted with this basic query format.
语法

INSERT INTO [TABLE] [tableIdentifier] [columnsClause] VALUES

示例

--step1: create a tableCREATE TABLE 
example_table
(  
a Int8,  
b String,
c Date
)
ENGINE = CnchMergeTree
ORDER BY (a)
--step2: insert 2 rows into the table
INSERT INTO example_table VALUES (1, 'a', '2021-07-27'), (2, 'b', '2021-07-27')

INSERT格式

数据可以以 ByteHouse 支持的格式传递给 INSERT。
语法

INSERT INTO [TABLE] [tableIdentifier] [columnsClause] FORMAT format_name

示例

-- step 1: create a table
CREATE TABLE `example_table`
(
    `a` Int8,
    `b` String,
    `c` Date
)
ENGINE = `CnchMergeTree`
ORDER BY (`a`) 

-- step 2: insert 2 rows in value format into the table
INSERT INTO example_table FORMAT VALUES (1, 'a', '2021-07-27'), (2, 'b', '2021-07-27');

INSERT SELECT

插入 SELECT 查询的结果。列按照它们在 SELECT 子句中的位置进行映射。然而,它们在 SELECT 表达式和 INSERT 表中的名称可能不同。如有必要,会进行类型转换。
语法

INSERT INTO [TABLE] [tableIdentifier] [columnsClause] [selectUnionStmt]

示例

INSERT INTO example_table SELECT * FROM example_table

INSERT INFILE

从文件向表中插入数据。仅限于 gateway-client
支持的文件格式:

  • .csv

  • .json

  • .avro

  • .parquet

    语法

INSERT INTO [TABLE] [tableIdentifier] [columnsClause] [FORMAT format_name] INFILE filepath

示例

INSERT INTO my_table FORMAT csvwithnames INFILE '/Users/my_name/Downloads/ETH-USD.csv'

INSERT OVERWRITE

Description
该语句的功能是重写表或表的某些分区

  • 重写为原子性操作
  • 分区替换时会自动过滤不符合指定分区的导入数据

Syntax

INSERT OVERWRITE TABLE table_name
    [ PARTITION (p1, ... | *) ]
    [ (COLUMN [, ...]) ]
    { VALUES ([, ...] ), ([, ...]) | QUERY }

Parameters

  • table_name: 需要重写的目标表名
  • PARTITION:需要重写的分区
    • 可以为 partition id 或者 partition tuple
    • 可以为一个或者多个,使用逗号分隔
    • 最外层需要使用括号
    • 不写 partition 字段则为整表重写
  • COLUMN: 需要写入目标表的列
    • 可以为一个或者多个,使用逗号分隔
    • 最外层需要使用括号
  • VALUES:需要写入的值列表
  • QUERY:需要写入的查询query

Examples

单分区键的分区重写

INSERT OVERWRITE test.insert_overwrite_t PARTITION (1) SELECT * FROM test.insert_overwrite_s WHERE d = 1;

单分区键的分区VALUES重写

INSERT OVERWRITE test.insert_overwrite_t PARTITION (2) VALUES (2,6), (3,3);

单分区键的多分区重写

INSERT OVERWRITE test.insert_overwrite_t PARTITION (1,2) SELECT * FROM test.insert_overwrite_s;

多分区键的多分区重写

INSERT OVERWRITE test.insert_overwrite_t PARTITION (('1',1), ('2',2)) SELECT * FROM test.insert_overwrite_s;

多分区键指定列的导入重写

INSERT OVERWRITE test.insert_overwrite_t PARTITION (('1',1)) (s,d,n) SELECT s,d,n FROM test.insert_overwrite_s;

使用Partition ID的分区重写

INSERT OVERWRITE test.insert_overwrite_t PARTITION (ID '2f4b47c7cb10a88d637501e1a15cbb47') SELECT * FROM test.insert_overwrite_s;

使用Partition ID的多分区重写

INSERT OVERWRITE test.insert_overwrite_t PARTITION (ID '2f4b47c7cb10a88d637501e1a15cbb47', ID 'fe7805ebd452ed4c738bdbbab09c6617') SELECT * FROM test.insert_overwrite_s;

整表重写

INSERT OVERWRITE test.insert_overwrite_t SELECT * FROM test.insert_overwrite_s;