SHOW 语句

SHOW 语句用于列出所有的 catalog，或者列出当前 catalog 中所有的 database，或者列出当前 catalog 和当前 database 的所有表或视图，或者列出所有的 function，包括：临时系统 function，系统 function，临时 catalog function，当前 catalog 和 database 中的 catalog function。

目前 Flink SQL 支持下列 SHOW 语句：

  • SHOW CATALOGS
  • SHOW DATABASES
  • SHOW TABLES
  • SHOW VIEWS
  • SHOW FUNCTIONS

执行 SHOW 语句

可以使用 TableEnvironment 中的 executeSql() 方法执行 SHOW 语句，也可以在 SQL CLI 中执行 SHOW 语句。 若 SHOW 操作执行成功，executeSql() 方法返回所有对象，否则会抛出异常。

以下的例子展示了如何在 TableEnvironment 和 SQL CLI 中执行一个 SHOW 语句。

  1. StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  2. StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
  4. // show catalogs
  5. tEnv.executeSql("SHOW CATALOGS").print();
  6. // +-----------------+
  7. // |    catalog name |
  8. // +-----------------+
  9. // | default_catalog |
  10. // +-----------------+
  12. // show databases
  13. tEnv.executeSql("SHOW DATABASES").print();
  14. // +------------------+
  15. // |    database name |
  16. // +------------------+
  17. // | default_database |
  18. // +------------------+
  20. // create a table
  21. tEnv.executeSql("CREATE TABLE my_table (...) WITH (...)");
  22. // show tables
  23. tEnv.executeSql("SHOW TABLES").print();
  24. // +------------+
  25. // | table name |
  26. // +------------+
  27. // |   my_table |
  28. // +------------+
  30. // create a view
  31. tEnv.executeSql("CREATE VIEW my_view AS ...");
  32. // show views
  33. tEnv.executeSql("SHOW VIEWS").print();
  34. // +-----------+
  35. // | view name |
  36. // +-----------+
  37. // |   my_view |
  38. // +-----------+
  40. // show functions
  41. tEnv.executeSql("SHOW FUNCTIONS").print();
  42. // +---------------+
  43. // | function name |
  44. // +---------------+
  45. // |           mod |
  46. // |        sha256 |
  47. // |           ... |
  48. // +---------------+
  1. val env = StreamExecutionEnvironment.getExecutionEnvironment()
  2. val tEnv = StreamTableEnvironment.create(env)
  4. // show catalogs
  5. tEnv.executeSql("SHOW CATALOGS").print()
  6. // +-----------------+
  7. // |    catalog name |
  8. // +-----------------+
  9. // | default_catalog |
  10. // +-----------------+
  12. // show databases
  13. tEnv.executeSql("SHOW DATABASES").print()
  14. // +------------------+
  15. // |    database name |
  16. // +------------------+
  17. // | default_database |
  18. // +------------------+
  20. // create a table
  21. tEnv.executeSql("CREATE TABLE my_table (...) WITH (...)")
  22. // show tables
  23. tEnv.executeSql("SHOW TABLES").print()
  24. // +------------+
  25. // | table name |
  26. // +------------+
  27. // |   my_table |
  28. // +------------+
  30. // create a view
  31. tEnv.executeSql("CREATE VIEW my_view AS ...")
  32. // show views
  33. tEnv.executeSql("SHOW VIEWS").print()
  34. // +-----------+
  35. // | view name |
  36. // +-----------+
  37. // |   my_view |
  38. // +-----------+
  40. // show functions
  41. tEnv.executeSql("SHOW FUNCTIONS").print()
  42. // +---------------+
  43. // | function name |
  44. // +---------------+
  45. // |           mod |
  46. // |        sha256 |
  47. // |           ... |
  48. // +---------------+
  1. settings = EnvironmentSettings.new_instance()...
  2. table_env = StreamTableEnvironment.create(env, settings)
  4. # show catalogs
  5. table_env.execute_sql("SHOW CATALOGS").print()
  6. # +-----------------+
  7. # |    catalog name |
  8. # +-----------------+
  9. # | default_catalog |
  10. # +-----------------+
  12. # show databases
  13. table_env.execute_sql("SHOW DATABASES").print()
  14. # +------------------+
  15. # |    database name |
  16. # +------------------+
  17. # | default_database |
  18. # +------------------+
  20. # create a table
  21. table_env.execute_sql("CREATE TABLE my_table (...) WITH (...)")
  22. # show tables
  23. table_env.execute_sql("SHOW TABLES").print()
  24. # +------------+
  25. # | table name |
  26. # +------------+
  27. # |   my_table |
  28. # +------------+
  30. # create a view
  31. table_env.execute_sql("CREATE VIEW my_view AS ...")
  32. # show views
  33. table_env.execute_sql("SHOW VIEWS").print()
  34. # +-----------+
  35. # | view name |
  36. # +-----------+
  37. # |   my_view |
  38. # +-----------+
  40. # show functions
  41. table_env.execute_sql("SHOW FUNCTIONS").print()
  42. # +---------------+
  43. # | function name |
  44. # +---------------+
  45. # |           mod |
  46. # |        sha256 |
  47. # |           ... |
  48. # +---------------+
  1. Flink SQL> SHOW CATALOGS;
  2. default_catalog
  4. Flink SQL> SHOW DATABASES;
  5. default_database
  7. Flink SQL> CREATE TABLE my_table (...) WITH (...);
  8. [INFO] Table has been created.
  10. Flink SQL> SHOW TABLES;
  11. my_table
  13. Flink SQL> CREATE VIEW my_view AS ...;
  14. [INFO] View has been created.
  16. Flink SQL> SHOW VIEWS;
  17. my_view
  19. Flink SQL> SHOW FUNCTIONS;
  20. mod
  21. sha256
  22. ...

SHOW CATALOGS

  1. SHOW CATALOGS

展示所有的 catalog。

SHOW DATABASES

  1. SHOW DATABASES

展示当前 catalog 中所有的 database。

SHOW TABLES

  1. SHOW TABLES

展示当前 catalog 和当前 database 中所有的表。

SHOW VIEWS

  1. SHOW VIEWS

展示当前 catalog 和当前 database 中所有的视图。

SHOW FUNCTIONS

  1. SHOW FUNCTIONS

展示所有的 function，包括：临时系统 function, 系统 function, 临时 catalog function，当前 catalog 和 database 中的 catalog function。