数据湖探索 DLI-插入数据:示例

时间:2025-02-12 14:55:48

示例

导入数据前已参考创建OBS表或者创建 DLI 中的示例描述创建对应的表。

  • 将SELECT查询结果插入到表中
    • 使用DataSource语法创建一个parquet格式的分区表
      CREATE TABLE data_source_tab1 (col1 INT, p1 INT, p2 INT)  USING PARQUET PARTITIONED BY (p1, p2);
    • 插入查询结果到分区 (p1 = 3, p2 = 4)中
      INSERT INTO data_source_tab1 PARTITION (p1 = 3, p2 = 4)  SELECT id FROM RANGE(1, 3);
    • 插入新的查询结果到分区 (p1 = 3, p2 = 4) 中
      INSERT OVERWRITE TABLE data_source_tab1 PARTITION (p1 = 3, p2 = 4)  SELECT id FROM RANGE(3, 5);
  • 将某条数据插入表中
    • 使用Hive语法创建一个parquet格式的分区表
      CREATE TABLE hive_serde_tab1 (col1 INT, p1 INT, p2 INT)  USING HIVE OPTIONS(fileFormat 'PARQUET') PARTITIONED BY (p1, p2);
    • 插入两条数据到分区 (p1 = 3, p2 = 4)中
      INSERT INTO hive_serde_tab1 PARTITION (p1 = 3, p2 = 4)  VALUES (1), (2);
    • 插入新的数据到分区 (p1 = 3, p2 = 4) 中
      INSERT OVERWRITE TABLE hive_serde_tab1 PARTITION (p1 = 3, p2 = 4)  VALUES (3), (4);
support.huaweicloud.com/sqlref-spark-dli/dli_08_0095.html