写入数据

写入数据

• 主键表：可以处理所有类型的消息（INSERT、UPDATE、DELETE）。

• 日志表：只能接受 INSERT 消息，无法更新或删除记录。

CREATE TEMPORARY TABLE source
(
shop_id BIGINT,
user_id BIGINT,
num_orders INT,
total_amount INT,
PRIMARY KEY (shop_id, user_id) NOT ENFORCED
)
WITH ('connector' = 'datagen');

# 写入部分列
INSERT INTO `fluss-catalog`.`my_db`.`my_pk_tbl` (shop_id, user_id, num_orders)
SELECT shop_id, user_id, num_orders FROM source;

# 写入全部列
INSERT INTO `fluss-catalog`.`my_db`.`my_pk_tbl`
SELECT * FROM source;

CREATE TEMPORARY TABLE source (
order_id BIGINT,
item_id BIGINT,
amount INT,
address STRING
) WITH ('connector' = 'datagen');

INSERT INTO `fluss-catalog`.`my_db`.`my_log_tbl` 
SELECT * FROM source;

更新数据

• 仅支持主键表更新数据。

• 仅支持更新主键等值的单条数据。

1. 登录实时计算控制台。

2. 单击目标工作空间操作列下的控制台。

3. 在左侧导航栏，单击数据开发 > 数据查询 > 新建临时查询脚本。

4. 编写SQL并部署运行。

   -- 只能支持按照 primary key 的等值条件进行更新
   UPDATE `my-catalog`.`my_db`.`my_pk_tbl` SET total_amount = 2 WHERE shop_id = 10000 and user_id = 123456;

删除数据

• 仅支持主键表删除数据。

• 仅支持删除主键等值的单条数据。

1. 登录实时计算控制台。

2. 单击目标工作空间操作列下的控制台。

3. 在左侧导航栏，单击数据开发 > ETL。

4. 单击后，单击新建流作业，填写文件名称并选择引擎版本，单击创建。

5. 编写SQL并部署运行。

   -- 只能支持按照 primary key 的等值条件进行删除
   DELETE FROM `my-catalog`.`my_db`.`my_pk_tbl` WHERE shop_id = 10000 and user_id = 123456;