USE 语句

USE 语句用来设置当前的 catalog 或者 database。

运行一个 USE 语句

Java

可以使用 TableEnvironment 中的 executeSql() 方法执行 USE 语句。 若 USE 操作执行成功，executeSql() 方法返回 ‘OK’，否则会抛出异常。

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

Scala

可以使用 TableEnvironment 中的 executeSql() 方法执行 USE 语句。 若 USE 操作执行成功，executeSql() 方法返回 ‘OK’，否则会抛出异常。

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

Python

可以使用 TableEnvironment 中的 execute_sql() 方法执行 USE 语句。 若 USE 操作执行成功，execute_sql() 方法返回 ‘OK’，否则会抛出异常。

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

SQL CLI

可以在 SQL CLI 中执行 USE 语句。

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

Java

  1. StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  2. StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
  4. // create a catalog
  5. tEnv.executeSql("CREATE CATALOG cat1 WITH (...)");
  6. tEnv.executeSql("SHOW CATALOGS").print();
  7. // +-----------------+
  8. // |    catalog name |
  9. // +-----------------+
  10. // | default_catalog |
  11. // | cat1            |
  12. // +-----------------+
  14. // change default catalog
  15. tEnv.executeSql("USE CATALOG cat1");
  17. tEnv.executeSql("SHOW DATABASES").print();
  18. // databases are empty
  19. // +---------------+
  20. // | database name |
  21. // +---------------+
  22. // +---------------+
  24. // create a database
  25. tEnv.executeSql("CREATE DATABASE db1 WITH (...)");
  26. tEnv.executeSql("SHOW DATABASES").print();
  27. // +---------------+
  28. // | database name |
  29. // +---------------+
  30. // |        db1    |
  31. // +---------------+
  33. // change default database
  34. tEnv.executeSql("USE db1");
  36. // change module resolution order and enabled status
  37. tEnv.executeSql("USE MODULES hive");
  38. tEnv.executeSql("SHOW FULL MODULES").print();
  39. // +-------------+-------+
  40. // | module name |  used |
  41. // +-------------+-------+
  42. // |        hive |  true |
  43. // |        core | false |
  44. // +-------------+-------+

Scala

  1. val env = StreamExecutionEnvironment.getExecutionEnvironment()
  2. val tEnv = StreamTableEnvironment.create(env)
  4. // create a catalog
  5. tEnv.executeSql("CREATE CATALOG cat1 WITH (...)")
  6. tEnv.executeSql("SHOW CATALOGS").print()
  7. // +-----------------+
  8. // |    catalog name |
  9. // +-----------------+
  10. // | default_catalog |
  11. // | cat1            |
  12. // +-----------------+
  14. // change default catalog
  15. tEnv.executeSql("USE CATALOG cat1")
  17. tEnv.executeSql("SHOW DATABASES").print()
  18. // databases are empty
  19. // +---------------+
  20. // | database name |
  21. // +---------------+
  22. // +---------------+
  24. // create a database
  25. tEnv.executeSql("CREATE DATABASE db1 WITH (...)")
  26. tEnv.executeSql("SHOW DATABASES").print()
  27. // +---------------+
  28. // | database name |
  29. // +---------------+
  30. // |        db1    |
  31. // +---------------+
  33. // change default database
  34. tEnv.executeSql("USE db1")
  36. // change module resolution order and enabled status
  37. tEnv.executeSql("USE MODULES hive")
  38. tEnv.executeSql("SHOW FULL MODULES").print()
  39. // +-------------+-------+
  40. // | module name |  used |
  41. // +-------------+-------+
  42. // |        hive |  true |
  43. // |        core | false |
  44. // +-------------+-------+

Python

  1. table_env = StreamTableEnvironment.create(...)
  3. # create a catalog
  4. table_env.execute_sql("CREATE CATALOG cat1 WITH (...)")
  5. table_env.execute_sql("SHOW CATALOGS").print()
  6. # +-----------------+
  7. # |    catalog name |
  8. # +-----------------+
  9. # | default_catalog |
  10. # | cat1            |
  11. # +-----------------+
  13. # change default catalog
  14. table_env.execute_sql("USE CATALOG cat1")
  16. table_env.execute_sql("SHOW DATABASES").print()
  17. # databases are empty
  18. # +---------------+
  19. # | database name |
  20. # +---------------+
  21. # +---------------+
  23. # create a database
  24. table_env.execute_sql("CREATE DATABASE db1 WITH (...)")
  25. table_env.execute_sql("SHOW DATABASES").print()
  26. # +---------------+
  27. # | database name |
  28. # +---------------+
  29. # |           db1 |
  30. # +---------------+
  32. # change default database
  33. table_env.execute_sql("USE db1")
  35. # change module resolution order and enabled status
  36. table_env.execute_sql("USE MODULES hive")
  37. table_env.execute_sql("SHOW FULL MODULES").print()
  38. # +-------------+-------+
  39. # | module name |  used |
  40. # +-------------+-------+
  41. # |        hive |  true |
  42. # |        core | false |
  43. # +-------------+-------+

SQL CLI

  1. Flink SQL> CREATE CATALOG cat1 WITH (...);
  2. [INFO] Catalog has been created.
  4. Flink SQL> SHOW CATALOGS;
  5. default_catalog
  6. cat1
  8. Flink SQL> USE CATALOG cat1;
  10. Flink SQL> SHOW DATABASES;
  12. Flink SQL> CREATE DATABASE db1 WITH (...);
  13. [INFO] Database has been created.
  15. Flink SQL> SHOW DATABASES;
  16. db1
  18. Flink SQL> USE db1;
  20. Flink SQL> USE MODULES hive;
  21. [INFO] Use modules succeeded!
  22. Flink SQL> SHOW FULL MODULES;
  23. +-------------+-------+
  24. | module name |  used |
  25. +-------------+-------+
  26. |        hive |  true |
  27. |        core | false |
  28. +-------------+-------+
  29. 2 rows in set

USE CATALOG

  1. USE CATALOG catalog_name

设置当前的 catalog。所有后续命令未显式指定 catalog 的将使用此 catalog。如果指定的的 catalog 不存在，则抛出异常。默认的当前 catalog 是 default_catalog。

USE MODULES

  1. USE MODULES module_name1[, module_name2, ...]

Set the enabled modules with declared order. All subsequent commands will resolve metadata(functions/user-defined types/rules, etc.) within enabled modules and follow resolution order. A module is used by default when it is loaded. Loaded modules will become disabled if not used by USE MODULES statement. The default loaded and enabled module is core.

USE

  1. USE [catalog_name.]database_name

设置当前的 database。所有后续命令未显式指定 database 的将使用此 database。如果指定的的 database 不存在，则抛出异常。默认的当前 database 是 default_database。