Realtime Compute for Apache Flink:Manage database

Batasan

Fitur ini hanya didukung di Ververica Runtime (VVR) 11.2 dan versi yang lebih baru.

Create a database

1. Masuk ke Konsol Streaming Compute Flink.

2. Temukan ruang kerja Streaming Compute Flink yang dituju, lalu klik Console pada kolom Operation.

3. Di panel navigasi sebelah kiri, klik Development > Scripts > New Temporary Script.

4. Tulis dan jalankan pernyataan SQL.

-- Create a database in the current catalog
USE CATALOG `<catalog-name>`;
CREATE DATABASE `<db-name>`; 

-- Create a database in a specified catalog
CREATE DATABASE `<catalog-name>`.`<db-name>`; 

Delete a database

-- Delete a database from the current catalog
USE CATALOG `<catalog-name>`;
DROP DATABASE `<db-name>`; 

-- Delete an empty database from a specified catalog
DROP DATABASE `<catalog-name>`.`<db-name>`; 

-- Delete a database and all tables in it.
DROP DATABASE `<catalog-name>`.`<db-name>` CASCADE;