AnalyticDB：湖儲存

前提條件

叢集核心版本需為3.2.3.0及以上版本。

操作步驟

1. 進入資料開發。

   1. 登入雲原生資料倉儲AnalyticDB MySQL控制台，在左上方選擇叢集所在地區。在左側導覽列，單擊集群清單，然後單擊目的地組群ID。

   2. 在左側導覽列，單擊作業開發 > SQL開發。

   3. 在SQLConsole視窗，選擇Spark引擎和資源群組（Job型資源群組或Spark引擎的Interactive型資源群組）。

2. 建立外庫與Iceberg湖儲存表。

   1. 建立資料庫。

      CREATE DATABASE adb_external_db_iceberg 
      WITH DBPROPERTIES ('adb_lake_bucket' = 'adb-lake-cn-shanghai-6gml****');

      參數說明：

      參數	說明
      adb_lake_bucket	指定湖儲存表資料的儲存位置。 在資料庫建表語句中指定湖儲存後，資料庫中的所有表將統一儲存於該湖儲存中。如果您不希望將資料庫下的所有表都儲存到湖儲存中，可以在建表時再設定該參數。

   2. 建立Iceberg外表。

      SET spark.adb.lakehouse.enabled=true;                      ----開啟湖儲存  
      CREATE TABLE adb_external_db_iceberg.test_iceberg_tbl (
        `id` int,
        `name` string,
        `age` int
      ) USING iceberg
      PARTITIONED BY (age)
      TBLPROPERTIES ( 'adb_lake_bucket' = 'adb-lake-cn-shanghai-6gml****' );

      參數說明：

      參數	說明
      adb_lake_bucket	指定湖儲存表資料的儲存位置。 若您已在建立資料庫時指定湖儲存，資料庫中的所有表將統一儲存於該湖儲存中，在建表時您無需再次指定。 若您在建立資料庫時未指定湖儲存，此處必須顯式指定，否則建表會報錯。指定後，該表的資料會儲存到該湖儲存中。 若在建立資料庫和建立表時均顯式指定湖儲存，則該表的資料會儲存在建表時指定的湖儲存中；而資料庫下的其他表則會儲存在建庫語句指定的湖儲存中。

3. 寫入Iceberg資料。

   SET spark.adb.lakehouse.enabled=true;                      ----開啟湖儲存
   INSERT INTO adb_external_db_iceberg.test_iceberg_tbl VALUES (1, 'lisa', 10), (2, 'jams', 10);

4. （可選）刪除Iceberg資料。

   SET spark.adb.lakehouse.enabled=true;                      ----開啟湖儲存
   DELETE FROM adb_external_db_iceberg.test_iceberg_tbl WHERE id = 1;
   DELETE FROM adb_external_db_iceberg.test_iceberg_tbl WHERE age = 20;

5. 查詢Iceberg外表資料。

   SET spark.adb.lakehouse.enabled=true;                      ----開啟湖儲存
   SELECT * FROM adb_external_db_iceberg.test_iceberg_tbl;

   返回結果如下：

   +---+----+---+
   |id |name|age|
   +---+----+---+
   |1  |anna|10 |
   |2  |jams|20 |
   +---+----+---+

6. （可選）刪除Iceberg外表。

   執行如下語句會刪除AnalyticDB for MySQL中的Iceberg外表和OSS中Iceberg外表的資料。

   SET spark.adb.lakehouse.enabled=true;
   DROP TABLE adb_external_db_iceberg.test_iceberg_tbl;

前提條件

叢集核心版本需為3.2.5.3及以上版本。

注意事項

不支援通過DELETE語句刪除湖儲存表中的單條資料，僅支援刪除整張表。

操作步驟

1. 進入資料開發。

   1. 登入雲原生資料倉儲AnalyticDB MySQL控制台，在左上方選擇叢集所在地區。在左側導覽列，單擊集群清單，然後單擊目的地組群ID。

   2. 在左側導覽列，單擊作業開發 > SQL開發。

   3. 在SQLConsole視窗，選擇XIHE引擎和Interactive型資源群組。

2. 建立外庫與Iceberg外表。

   1. 建立外庫。

      CREATE EXTERNAL DATABASE test_db 
      WITH DBPROPERTIES ('adb_lake_bucket' = 'adb-lake-cn-shanghai-6gml****');

      參數說明：

      參數	說明
      adb_lake_bucket	指定湖儲存表資料的儲存位置。 在資料庫建表語句中指定湖儲存後，資料庫中的所有表將統一儲存於該湖儲存中。如果您不希望將資料庫下的所有表都儲存到湖儲存中，可以在建表時再設定該參數。

   2. 建立Iceberg外表。

      CREATE TABLE test_db.test_iceberg_tbl (
        `id` int,
        `name` string
      )PARTITIONED BY (age int) 
      STORED AS ICEBERG
      TBLPROPERTIES (
        'catalog_type' = 'ADB', 
        'adb_lake_bucket' = 'adb-lake-cn-shanghai-6gml****'
      );

      參數說明：

      參數	說明
      catalog_type	指定catalog類型。固定填寫為ADB。
      adb_lake_bucket	指定湖儲存表資料的儲存位置。 若您已在建立資料庫時指定湖儲存，資料庫中的所有表將統一儲存於該湖儲存中，在建表時您無需再次指定。 若您在建立資料庫時未指定湖儲存，此處必須顯式指定，否則建表會報錯。指定後，該表的資料會儲存到該湖儲存中。 若在建立資料庫和建立表時均顯式指定湖儲存，則該表的資料會儲存在建表時指定的湖儲存中；而資料庫下的其他表則會儲存在建庫語句指定的湖儲存中。

3. 寫入Iceberg資料。

   INSERT INTO test_db1.test_iceberg_tbl select 1, 'anna', 10;
   INSERT INTO test_db1.test_iceberg_tbl select 2, 'jams', 20;

4. 查詢Iceberg外表資料。

   SELECT * FROM adb_external_db_iceberg.test_iceberg_tbl;

   返回結果如下：

   +---+----+---+
   |id |name|age|
   +---+----+---+
   |1  |anna|10 |
   |2  |jams|20 |
   +---+----+---+

5. （可選）刪除Iceberg外表。

   執行如下語句會刪除AnalyticDB for MySQL中的Iceberg外表和OSS中Iceberg外表的資料。

   SET spark.adb.lakehouse.enabled=true;
   DROP TABLE adb_external_db_iceberg.test_iceberg_tbl;