Este tema describe cómo escribir, actualizar y eliminar datos en una tabla de Fluss.
Escritura de datos
Las tablas con clave primaria procesan todos los tipos de mensajes, como INSERT, UPDATE y DELETE.
Las tablas de registros solo aceptan mensajes INSERT. No es posible actualizar ni eliminar registros.
Inicie sesión en la consola de Real-time Compute for Apache Flink.
En la columna Actions del espacio de trabajo de Streaming Compute Flink que desee, haga clic en Console.
En el panel de navegación izquierdo, seleccione .
Creación de tabla primaria
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;Tabla de registros
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;Actualización de datos
Los datos solo se pueden actualizar en tablas con clave primaria.
Solo es posible actualizar un registro a la vez mediante una condición de igualdad en la clave primaria.
En el panel de navegación izquierdo, seleccione .
-
Escriba y ejecute la sentencia SQL.
-- 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;
Eliminación de datos
Los datos solo se pueden eliminar de tablas con clave primaria.
Solo es posible eliminar un registro a la vez mediante una condición de igualdad en la clave primaria.
En el panel de navegación izquierdo, seleccione .
-
Escriba y ejecute la sentencia SQL.
-- 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;