Use 语句
— 焉知非鱼Use Statements
USE 语句
USE 语句用于设置当前数据库或目录。
运行 USE 语句 #
USE 语句可以通过 TableEnvironment 的 executeSql() 方法执行,也可以在 SQL CLI 中执行。executeSql() 方法会对一个成功的 USE 操作返回 ‘OK’, 否则会抛出一个异常。
下面的例子展示了如何在 TableEnvironment 和 SQL CLI 中运行一条 USE 语句。
val env = StreamExecutionEnvironment.getExecutionEnvironment()
val tEnv = StreamTableEnvironment.create(env)
// create a catalog
tEnv.executeSql("CREATE CATALOG cat1 WITH (...)")
tEnv.executeSql("SHOW CATALOGS").print()
// +-----------------+
// | catalog name |
// +-----------------+
// | default_catalog |
// | cat1 |
// +-----------------+
// change default catalog
tEnv.executeSql("USE CATALOG cat1")
tEnv.executeSql("SHOW DATABASES").print()
// databases are empty
// +---------------+
// | database name |
// +---------------+
// +---------------+
// create a database
tEnv.executeSql("CREATE DATABASE db1 WITH (...)")
tEnv.executeSql("SHOW DATABASES").print()
// +---------------+
// | database name |
// +---------------+
// | db1 |
// +---------------+
// change default database
tEnv.executeSql("USE db1")
USE CATLOAG #
USE CATALOG catalog_name
设置当前目录。所有没有明确指定目录的后续命令将使用这个目录。如果所提供的目录不存在,则会抛出一个异常。默认的当前目录是default_catalog。
USE #
USE [catalog_name.]database_name
设置当前数据库。所有没有明确指定数据库的后续命令将使用这个数据库。如果提供的数据库不存在,则会抛出一个异常。默认的当前数据库是default_database。
原文链接: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/use.html