Iceberg SQL 是基于 Apache Iceberg 的數據查詢接口,它允許你使用標準的 SQL 語句來查詢和管理 Iceberg 表中的數據。以下是一些基本的 Iceberg SQL 示例:
假設我們有一個名為 my_table
的表,具有以下列:id
(整數),name
(字符串),timestamp
(時間戳)。
CREATE TABLE my_table (
id INT,
name STRING,
timestamp TIMESTAMP
)
USING iceberg;
你可以使用 INSERT INTO
語句向表中插入數據。
INSERT INTO my_table (id, name, timestamp)
VALUES (1, 'Alice', '2023-04-01T12:00:00Z'),
(2, 'Bob', '2023-04-02T12:00:00Z');
使用 SELECT
語句查詢表中的數據。
SELECT id, name, timestamp
FROM my_table
WHERE timestamp > '2023-04-01T12:00:00Z';
Iceberg SQL 不直接支持 UPDATE 語句,但你可以使用 MERGE
語句來實現類似的功能。
MERGE INTO my_table t1
USING (SELECT 3 as id, 'Charlie' as name, '2023-04-03T12:00:00Z' as timestamp) t2
ON t1.id = t2.id
WHEN MATCHED THEN
UPDATE SET name = t2.name, timestamp = t2.timestamp
WHEN NOT MATCHED THEN
INSERT (id, name, timestamp)
VALUES (t2.id, t2.name, t2.timestamp);
Iceberg SQL 也不直接支持 DELETE 語句,但你可以使用 DELETE
關鍵字與 WHERE
子句來實現刪除功能。
DELETE FROM my_table
WHERE id = 1;
注意:以上示例假設你已經正確配置了 Iceberg 和相關的依賴項,并且你的環境支持 Iceberg SQL。在實際使用時,你可能需要根據你的具體環境和需求進行調整。