rakulang, dartlang, nimlang, golang, rustlang, lang lang no see

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