iceberg1.0用flinksql如何实现增删改查

Iceberg 1.0 是一个数据表格管理工具，可以方便地对数据表格进行增删改查操作。在使用 FlinkSQL 对 Iceberg 表格进行增删改查操作时，需要注意以下几点：

1. 创建表格：可以使用 CREATE TABLE 语句创建 Iceberg 表格。例如：

   CREATE TABLE my_table (
     id INT,
     name STRING,
     age INT
   ) PARTITIONED BY (date DATE) 
   WITH (
     'partitioning.type'='hash',
     'partitioning.hash.columns'='date',
     'write.format'='parquet'
   );

在这个例子中，我们创建了一个名为 `my_table` 的表格，包含 `id`、`name` 和 `age` 三个字段，同时按照 `date` 列进行分区。

2. 插入数据：可以使用 INSERT INTO 语句插入数据。例如：

   INSERT INTO my_table VALUES (1, 'Alice', 20, '2021-01-01');

在这个例子中，我们向 `my_table` 表格中插入了一条记录，包含 `id`、`name`、`age` 和 `date` 四个字段。

3. 更新数据：可以使用 UPDATE 语句更新数据。例如：

   UPDATE my_table SET age=21 WHERE name='Alice';

在这个例子中，我们将 `my_table` 表格中 `name` 为 `Alice` 的记录的 `age` 字段更新为 `21`。

4. 删除数据：可以使用 DELETE 语句删除数据。例如：

   DELETE FROM my_table WHERE age<18;

在这个例子中，我们删除了 `my_table` 表格中 `age` 小于 `18` 的所有记录。

5. 查询数据：可以使用 SELECT 语句查询数据。例如：

   SELECT * FROM my_table WHERE age>=18;

在这个例子中，我们查询了 `my_table` 表格中 `age` 大于等于 `18` 的所有记录。

需要注意的是，在使用 FlinkSQL 对 Iceberg 表格进行增删改查操作时，需要先通过 `TableEnvironment` 对象获取到表格，并且需要导入相关依赖，例如 `flink-table-planner-blink` 和 `iceberg-flink`。具体用法可以参考官方文档。