- 应用开发
- Table API & SQL
- SQL
- DROP 语句
DROP 语句
本文档是 Apache Flink 的旧版本。建议访问 最新的稳定版本。
DROP 语句用于从当前或指定的 Catalog 中删除一个已经注册的表、视图或函数。
Flink SQL 目前支持以下 DROP 语句:
- DROP TABLE
- DROP DATABASE
- DROP FUNCTION
执行 DROP 语句
可以使用 TableEnvironment
中的 sqlUpdate()
方法执行 DROP 语句,也可以在 SQL CLI 中执行 DROP 语句。 若 DROP 操作执行成功,sqlUpdate()
方法不返回任何内容,否则会抛出异常。
以下的例子展示了如何在 TableEnvironment
和 SQL CLI 中执行一个 DROP 语句。
DROP TABLE
根据给定的表名删除某个表。若需要删除的表不存在,则抛出异常。
IF EXISTS
表不存在时不会进行任何操作。
DROP DATABASE
根据给定的表名删除数据库。若需要删除的数据库不存在会抛出异常 。
IF EXISTS
若数据库不存在,不执行任何操作。
RESTRICT
当删除一个非空数据库时,会触发异常。(默认为开)
CASCADE
删除一个非空数据库时,把相关联的表与函数一并删除。
DROP FUNCTION
删除一个有 catalog 和数据库命名空间的 catalog function。若需要删除的函数不存在,则会产生异常。
TEMPORARY
删除一个有 catalog 和数据库命名空间的临时 catalog function。
TEMPORARY SYSTEM
删除一个没有数据库命名空间的临时系统函数。
IF EXISTS
若函数不存在,则不会进行任何操作。