USE 语句

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

运行一个 USE 语句

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

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

  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");
  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")
  1. settings = EnvironmentSettings.new_instance()...
  2. table_env = StreamTableEnvironment.create(env, settings)
  4. # create a catalog
  5. table_env.execute_sql("CREATE CATALOG cat1 WITH (...)")
  6. table_env.execute_sql("SHOW CATALOGS").print()
  7. # +-----------------+
  8. # |    catalog name |
  9. # +-----------------+
  10. # | default_catalog |
  11. # | cat1            |
  12. # +-----------------+
  14. # change default catalog
  15. table_env.execute_sql("USE CATALOG cat1")
  17. table_env.execute_sql("SHOW DATABASES").print()
  18. # databases are empty
  19. # +---------------+
  20. # | database name |
  21. # +---------------+
  22. # +---------------+
  24. # create a database
  25. table_env.execute_sql("CREATE DATABASE db1 WITH (...)")
  26. table_env.execute_sql("SHOW DATABASES").print()
  27. # +---------------+
  28. # | database name |
  29. # +---------------+
  30. # |           db1 |
  31. # +---------------+
  33. # change default database
  34. table_env.execute_sql("USE db1")
  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;

USE CATLOAG

  1. USE CATALOG catalog_name

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

USE

  1. USE [catalog_name.]database_name

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