DROP 语句
This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.

DROP 语句 #

DROP 语句可用于删除指定的 catalog，也可用于从当前或指定的 Catalog 中删除一个已经注册的表、视图或函数。

Flink SQL 目前支持以下 DROP 语句：

  • DROP CATALOG
  • DROP TABLE
  • DROP DATABASE
  • DROP VIEW
  • DROP FUNCTION
  • DROP MODEL

执行 DROP 语句 #

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

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

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

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

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

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

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

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

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

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

TableEnvironment tableEnv = TableEnvironment.create(...);  // 注册名为 “Orders” 的表 tableEnv.executeSql("CREATE TABLE Orders (`user` BIGINT, product STRING, amount INT) WITH (...)");  // 字符串数组： ["Orders"] String[] tables = tableEnv.listTables(); // or tableEnv.executeSql("SHOW TABLES").print();  // 从 catalog 删除 “Orders” 表 tableEnv.executeSql("DROP TABLE Orders");  // 空字符串数组 String[] tables = tableEnv.listTables(); // or tableEnv.executeSql("SHOW TABLES").print(); 
val tableEnv = TableEnvironment.create(...)  // 注册名为 “Orders” 的表 tableEnv.executeSql("CREATE TABLE Orders (`user` BIGINT, product STRING, amount INT) WITH (...)")  // 字符串数组： ["Orders"] val tables = tableEnv.listTables() // or tableEnv.executeSql("SHOW TABLES").print()  // 从 catalog 删除 “Orders” 表 tableEnv.executeSql("DROP TABLE Orders")  // 空字符串数组 val tables = tableEnv.listTables() // or tableEnv.executeSql("SHOW TABLES").print() 
table_env = TableEnvironment.create(...)  # 字符串数组： ["Orders"] tables = table_env.listTables() # or table_env.executeSql("SHOW TABLES").print()  # 从 catalog 删除 “Orders” 表 table_env.execute_sql("DROP TABLE Orders")  # 空字符串数组 tables = table_env.list_tables() # or table_env.execute_sql("SHOW TABLES").print() 
Flink SQL> CREATE TABLE Orders (`user` BIGINT, product STRING, amount INT) WITH (...); [INFO] Table has been created.  Flink SQL> SHOW TABLES; Orders  Flink SQL> DROP TABLE Orders; [INFO] Table has been removed.  Flink SQL> SHOW TABLES; [INFO] Result was empty.

DROP CATALOG # 

DROP CATALOG [IF EXISTS] catalog_name

删除给定名字的 catalog。

IF EXISTS

如果目标 catalog 不存在，则不会执行任何操作。

DROP TABLE # 

DROP TABLE [IF EXISTS] [catalog_name.][db_name.]table_name

根据给定的表名删除某个表。若需要删除的表不存在，则抛出异常。

IF EXISTS

表不存在时不会进行任何操作。

DROP DATABASE # 

DROP DATABASE [IF EXISTS] [catalog_name.]db_name [ (RESTRICT | CASCADE) ]

根据给定的表名删除数据库。若需要删除的数据库不存在会抛出异常 。

IF EXISTS

若数据库不存在，不执行任何操作。

RESTRICT

当删除一个非空数据库时，会触发异常。（默认为开）

CASCADE

删除一个非空数据库时，把相关联的表与函数一并删除。

DROP VIEW # 

DROP [TEMPORARY] VIEW [IF EXISTS] [catalog_name.][db_name.]view_name

删除一个有 catalog 和数据库命名空间的视图。若需要删除的视图不存在，则会产生异常。

TEMPORARY

删除一个有 catalog 和数据库命名空间的临时视图。

IF EXISTS

若视图不存在，则不会进行任何操作。

依赖管理 Flink 没有使用 CASCADE / RESTRICT 关键字来维护视图的依赖关系，当前的方案是在用户使用视图时再提示错误信息，比如在视图的底层表已经被删除等场景。

DROP FUNCTION # 

DROP [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF EXISTS] [catalog_name.][db_name.]function_name;

删除一个有 catalog 和数据库命名空间的 catalog function。若需要删除的函数不存在，则会产生异常。

TEMPORARY

删除一个有 catalog 和数据库命名空间的临时 catalog function。

TEMPORARY SYSTEM

删除一个没有数据库命名空间的临时系统函数。

IF EXISTS

若函数不存在，则不会进行任何操作。

DROP MODEL # 

DROP [TEMPORARY] MODEL [IF EXISTS] [catalog_name.][db_name.]model_name

删除一个有 catalog 和数据库命名空间的模型。若需要删除的模型不存在并且没有用 IF EXISTS，则会产生异常。

TEMPORARY

删除一个有 catalog 和数据库命名空间的临时模型。

IF EXISTS

若模型不存在，则不会进行任何操作。