Write data
This topic describes how to write, update, and delete data in a Fluss table.
Write data
-
Primary key tables can process all types of messages, such as INSERT, UPDATE, and DELETE.
-
Log tables accept only INSERT messages. You cannot update or delete records.
-
Log in to the Real-time Compute for Apache Flink console.
-
In the Actions column of the desired Streaming Compute Flink workspace, click Console.
-
In the navigation pane on the left, choose .
Primary table creation
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');
# Write data to specific columns.
INSERT INTO `fluss-catalog`.`my_db`.`my_pk_tbl` (shop_id, user_id, num_orders)
SELECT shop_id, user_id, num_orders FROM source;
# Write data to all columns.
INSERT INTO `fluss-catalog`.`my_db`.`my_pk_tbl`
SELECT * FROM source;Log table
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;Update data
-
You can update data only in primary key tables.
-
You can update only a single record at a time based on an equivalent condition for the primary key.
-
In the navigation pane on the left, choose .
-
Write and run the SQL statement.
-- Updates are supported only based on an equivalent condition for the primary key. UPDATE `my-catalog`.`my_db`.`my_pk_tbl` SET total_amount = 2 WHERE shop_id = 10000 and user_id = 123456;
Delete data
-
You can delete data only from primary key tables.
-
You can delete only a single record at a time based on an equivalent condition for the primary key.
-
In the navigation pane on the left, choose .
-
Write and run the SQL statement.
-- Deletions are supported only based on an equivalent condition for the primary key. DELETE FROM `my-catalog`.`my_db`.`my_pk_tbl` WHERE shop_id = 10000 and user_id = 123456;