如何用sparksql删除配置单元数据库?

w80xi6nr  于 2021-06-27  发布在  Hive
关注(0)|答案(2)|浏览(845)

在我的用例中,我想从sparksql“创建或替换”一个配置单元数据库。我想知道这是否可能?或者我必须先在for循环中手动删除数据库中的所有表,然后删除空数据库吗?

50few1ms

50few1ms1#

要删除数据库和所有表:

spark_session.sql(f'DROP DATABASE IF EXISTS {db_name} CASCADE')

要删除特定表:

spark_session.sql(f'DROP TABLE IF EXISTS {db_name}.{table_name}')
pgpifvop

pgpifvop2#

试试下面的

DROP DATABASE IF EXISTS <database_name> CASCADE;
``` `CASCADE` 将删除数据库中的所有表。
默认情况下,模式为 `RESTRICT` 如果数据库中存在某些表,配置单元将不会删除数据库。
一旦你删除了数据库 `create a new database` 使用sparksql。
有关更多信息,请参阅create/drop/alter/usedatabase页。
下一个选择是你在帖子中建议的方式( `delete all tables then drop the database` )

相关问题