更新 Iceberg 表数据 - Amazon Athena
INSERT INTO删除更新MERGE INTO
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

更新 Iceberg 表数据

Iceberg 表数据可以直接在 Athena 上使用 INSERT、UPDATE 和 DELETE 查询进行管理。每个数据管理事务都会生成一个新的快照，可以使用时间旅行查询该快照。UPDATE 和 DELETE 语句遵循 Iceberg 格式 v2 行级位置删除规范并强制执行快照隔离。

使用以下命令对 Iceberg 表执行数据管理操作。

INSERT INTO

将数据插入 Iceberg 表。Athena Iceberg INSERT INTO 收费与当前对外部 Hive 表进行 INSERT INTO 查询的收费一致，皆按扫描的数据量收费。要将数据插入到 Iceberg 表中，请使用以下语法，其中 query 可以是 VALUES (val1, val2, ...) 或 SELECT (col1, col2, …) FROM [db_name.]table_name WHERE predicate。有关 SQL 语法和语义的详细信息，请参阅 INSERT INTO。

INSERT INTO [db_name.]table_name [(col1, col2, …)] query

以下示例将值插入到表 iceberg_table 中。

INSERT INTO iceberg_table VALUES (1,'a','c1')
INSERT INTO iceberg_table (col1, col2, ...) VALUES (val1, val2, ...)
INSERT INTO iceberg_table SELECT * FROM another_table

删除

Athena Iceberg DELETE 将 Iceberg 位置删除文件写入表中。这称为读取时合并删除。与写入时复制删除不同，读取时合并删除效率更高，因为其不会重写文件数据。当 Athena 读取 Iceberg 数据时，将合并 Iceberg 位置删除文件与数据文件，以生成表的最新视图。若要删除这些位置删除文件，您可以运行 REWRITE DATA 压缩操作。DELETE 操作按扫描的数据量收费。有关语法，请参阅 删除。

以下示例从 iceberg_table 中删除 c3 作为 category 的值的行。

DELETE FROM iceberg_table WHERE category='c3'

更新

Athena Iceberg UPDATE 将 Iceberg 位置删除文件和新更新的行作为数据文件写入同一事务中。UPDATE 可视为 INSERT INTO 和 DELETE 的组合。UPDATE 操作按扫描的数据量收费。有关语法，请参阅 更新。

以下示例更新表 iceberg_table 中的指定值。

UPDATE iceberg_table SET category='c2' WHERE category='c1'

MERGE INTO

有条件地更新行、删除行或将行插入到 Iceberg 表中。单个语句可以组合更新、删除和插入操作。有关语法，请参阅 MERGE INTO。

注意

MERGE INTO 是事务性的，仅支持用于 Athena 引擎版本 3 中的 Apache Iceberg 表。

以下示例从表 t 中删除源表 s 中的所有客户。

MERGE INTO accounts t USING monthly_accounts_update s
ON t.customer = s.customer
WHEN MATCHED
THEN DELETE

以下示例使用源表 s 中的客户信息更新目标表 t。如果表 t 与表 s 中的客户行匹配，则该示例会增加表 t 中的购买量。如果表 t 与表 s 中的客户行不匹配，则该示例会将表 s 的客户行插入到表 t 中。

MERGE INTO accounts t USING monthly_accounts_update s
    ON (t.customer = s.customer)
    WHEN MATCHED
        THEN UPDATE SET purchases = s.purchases + t.purchases
    WHEN NOT MATCHED
        THEN INSERT (customer, purchases, address)
              VALUES(s.customer, s.purchases, s.address)

以下示例使用源表 s 中的信息有条件地更新目标表 t。该示例删除了源地址为 Centreville 的所有匹配的目标行。对于所有其他匹配的行，该示例会添加源采购并将目标地址设置为源地址。如果目标表中没有匹配项，该示例会插入源表中的行。

MERGE INTO accounts t USING monthly_accounts_update s
    ON (t.customer = s.customer)
    WHEN MATCHED AND s.address = 'Centreville'
        THEN DELETE
    WHEN MATCHED
        THEN UPDATE
            SET purchases = s.purchases + t.purchases, address = s.address
    WHEN NOT MATCHED
        THEN INSERT (customer, purchases, address)
              VALUES(s.customer, s.purchases, s.address)