本文为您介绍如何向Fluss表写入、更新与删除数据。
写入数据
主键表：可以处理所有类型的消息（INSERT、UPDATE、DELETE）。
日志表：只能接收 INSERT 消息，无法更新或删除记录。
登录实时计算控制台。
单击流计算Flink工作空间操作列下的控制台。
在左侧导航栏，单击。
主建表
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;更新数据
仅支持主键表更新数据。
仅支持更新主键等值的单条数据。
在左侧导航栏，单击。
编写SQL并选中运行。
-- 只能支持按照 primary key 的等值条件进行更新 UPDATE `my-catalog`.`my_db`.`my_pk_tbl` SET total_amount = 2 WHERE shop_id = 10000 and user_id = 123456;
删除数据
仅支持主键表删除数据。
仅支持删除主键等值的单条数据。
在左侧导航栏，单击。
编写SQL并选中运行。
-- 只能支持按照 primary key 的等值条件进行删除 DELETE FROM `my-catalog`.`my_db`.`my_pk_tbl` WHERE shop_id = 10000 and user_id = 123456;
该文章对您有帮助吗？