Flink基礎（三十四）：FLINK-SQL語法(十)DDL(六)USE 語句

USE 語句用來設置當前的 catalog 或者 database。

1 運行一個 USE 語句

可以使用 TableEnvironment 中的 executeSql() 方法執行 USE 語句，也可以在 SQL CLI 中執行 USE 語句。 若 USE 操作執行成功，executeSql() 方法返回 ‘OK’，否則會拋出異常。

以下的例子展示了如何在 TableEnvironment 和 SQL CLI 中執行一個 USE 語句。

val env = StreamExecutionEnvironment.getExecutionEnvironment()
val tEnv = StreamTableEnvironment.create(env)

// create a catalog
tEnv.executeSql("CREATE CATALOG cat1 WITH (...)")
tEnv.executeSql("SHOW CATALOGS").print()
// +-----------------+
// |    catalog name |
// +-----------------+
// | default_catalog |
// | cat1            |
// +-----------------+

// change default catalog
tEnv.executeSql("USE CATALOG cat1")

tEnv.executeSql("SHOW DATABASES").print()
// databases are empty
// +---------------+
// | database name |
// +---------------+
// +---------------+

// create a database
tEnv.executeSql("CREATE DATABASE db1 WITH (...)")
tEnv.executeSql("SHOW DATABASES").print()
// +---------------+
// | database name |
// +---------------+
// |        db1    |
// +---------------+

// change default database
tEnv.executeSql("USE db1")

Flink SQL> CREATE CATALOG cat1 WITH (...);
[INFO] Catalog has been created.

Flink SQL> SHOW CATALOGS;
default_catalog
cat1

Flink SQL> USE CATALOG cat1;

Flink SQL> SHOW DATABASES;

Flink SQL> CREATE DATABASE db1 WITH (...);
[INFO] Database has been created.

Flink SQL> SHOW DATABASES;
db1

Flink SQL> USE db1;

2 USE CATLOAG

USE CATALOG catalog_name

設置當前的 catalog。所有后續命令未顯式指定 catalog 的將使用此 catalog。如果指定的的 catalog 不存在，則拋出異常。默認的當前 catalog 是 default_catalog。

3 USE

USE [catalog_name.]database_name

設置當前的 database。所有后續命令未顯式指定 database 的將使用此 database。如果指定的的 database 不存在，則拋出異常。默認的當前 database 是 default_database。