Topik ini menjelaskan cara menulis, memperbarui, dan menghapus data dalam tabel Fluss.
Menulis data
-
Tabel primary key dapat memproses semua jenis pesan, seperti INSERT, UPDATE, dan DELETE.
-
Tabel log hanya menerima pesan INSERT. Anda tidak dapat memperbarui atau menghapus record.
-
Pada kolom Actions ruang kerja Streaming Compute Flink yang diinginkan, klik Console.
-
Di panel navigasi sebelah kiri, pilih .
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');
# Menulis data ke kolom tertentu.
INSERT INTO `fluss-catalog`.`my_db`.`my_pk_tbl` (shop_id, user_id, num_orders)
SELECT shop_id, user_id, num_orders FROM source;
# Menulis data ke semua kolom.
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;Memperbarui data
-
Anda hanya dapat memperbarui data pada tabel primary key.
-
Anda hanya dapat memperbarui satu record dalam satu waktu berdasarkan kondisi ekuivalen untuk primary key.
-
Di panel navigasi sebelah kiri, pilih .
-
Tulis dan jalankan pernyataan SQL.
-- Pembaruan hanya didukung berdasarkan kondisi ekuivalen untuk primary key. UPDATE `my-catalog`.`my_db`.`my_pk_tbl` SET total_amount = 2 WHERE shop_id = 10000 and user_id = 123456;
Menghapus data
-
Anda hanya dapat menghapus data dari tabel primary key.
-
Anda hanya dapat menghapus satu record dalam satu waktu berdasarkan kondisi ekuivalen untuk primary key.
-
Di panel navigasi sebelah kiri, pilih .
-
Tulis dan jalankan pernyataan SQL.
-- Penghapusan hanya didukung berdasarkan kondisi ekuivalen untuk primary key. DELETE FROM `my-catalog`.`my_db`.`my_pk_tbl` WHERE shop_id = 10000 and user_id = 123456;