Show 语句
— 焉知非鱼Show Statements
SHOW 语句
SHOW 语句用于列出所有目录，或列出当前目录中的所有数据库，或列出当前目录和当前数据库中的所有表/视图，或列出当前目录和当前数据库中的所有函数，包括临时系统函数、系统函数、临时目录函数和目录函数。
Flink SQL 目前支持以下 SHOW 语句。
- SHOW CATALOGS
- SHOW DATABASES
- SHOW TABLES
- SHOW VIEWS
- SHOW FUNCTIONS
运行 SHOW 语句 #
SHOW 语句可以用 TableEnvironment 的 executeSql()方法执行，也可以在 SQL CLI 中执行。executeSql()方法会对成功的 SHOW 操作返回对象，否则会抛出一个异常。
下面的例子展示了如何在 TableEnvironment 和 SQL CLI 中运行 SHOW 语句。
Flink SQL> SHOW CATALOGS;
default_catalog
Flink SQL> SHOW DATABASES;
default_database
Flink SQL> CREATE TABLE my_table (...) WITH (...);
[INFO] Table has been created.
Flink SQL> SHOW TABLES;
my_table
Flink SQL> CREATE VIEW my_view AS ...;
[INFO] View has been created.
Flink SQL> SHOW VIEWS;
my_view
Flink SQL> SHOW FUNCTIONS;
mod
sha256
...
val env = StreamExecutionEnvironment.getExecutionEnvironment()
val tEnv = StreamTableEnvironment.create(env)
// show catalogs
tEnv.executeSql("SHOW CATALOGS").print()
// +-----------------+
// | catalog name |
// +-----------------+
// | default_catalog |
// +-----------------+
// show databases
tEnv.executeSql("SHOW DATABASES").print()
// +------------------+
// | database name |
// +------------------+
// | default_database |
// +------------------+
// create a table
tEnv.executeSql("CREATE TABLE my_table (...) WITH (...)")
// show tables
tEnv.executeSql("SHOW TABLES").print()
// +------------+
// | table name |
// +------------+
// | my_table |
// +------------+
// create a view
tEnv.executeSql("CREATE VIEW my_view AS ...")
// show views
tEnv.executeSql("SHOW VIEWS").print()
// +-----------+
// | view name |
// +-----------+
// | my_view |
// +-----------+
// show functions
tEnv.executeSql("SHOW FUNCTIONS").print()
// +---------------+
// | function name |
// +---------------+
// | mod |
// | sha256 |
// | ... |
// +---------------+
SHOW CATALOGS #
SHOW CATALOGS
显示所有目录。
SHOW DATABASES #
SHOW DATABASES
显示当前目录中的所有数据库。
SHOW TABLES #
SHOW TABLES
显示当前目录和当前数据库中的所有表。
SHOW VIEWS #
SHOW VIEWS
显示当前目录和当前数据库中的所有视图。
SHOW FUNCTIONS #
SHOW FUNCTIONS
显示当前目录和当前数据库中的所有功能，包括临时系统功能、系统功能、临时目录功能和目录功能。
原文链接: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/show.html