Skip to main content

use

介绍​

USE语句用于设置当前数据库或catalog，或更改模块的解析顺序和启用状态。

USE CATALOG​

USE CATALOG catalog_name

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

在flink sql中创建了hive catalog，再用use语句使用了hive catalog之后，flink 就连接上了 hive 的元数据， 之后的create创建的非临时表，其元数据就会被保存到 hive 的元数据。

如果不想在每个flink sql任务中重复创建连接外部系统的虚拟表，就可以只在第一个flink sql任务中创建一次表，之后的flink sql任务就不再需要编写建表语句了， 只要有创建hive catalog和use catalog hive语句即可。

USE MODULES​

USE MODULES module_name1[, module_name2, ...]

按照声明的顺序设置已启用的模块。所有后续命令将解析启用模块中的元数据(函数/用户定义类型/规则等)，并遵循声明顺序。

模块在加载时被默认使用。如果没有使用USE modules语句，加载的模块将被禁用。默认加载和启用的模块是core。如果使用了该语句启动模块，则不在该语句中的模块都将被禁用。

案例​

use hive, core;

表示后续使用到的函数/用户定义类型/规则等，会先按照 hive 来解析，如果 hive 解析不了的，再用 flink 来解析。

USE​

USE [catalog_name.]database_name

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