我是新的python和整个gluescript的事情。我想执行一个删除查询在不同的数据库服务器。我不知道我做错了什么
def remove_from_db(driver, url, dbtable, user, password):
query = "delete from abctable where end_date >='1-11-2023'"
spark.write.format("jdbc") \
.option("driver", driver) \
.option("url", url) \
.option("dbtable", dbtable) \
.option("user", user) \
.option("password", password) \
.option("query", query) \
.load()
字符串
1条答案
按热度按时间3vpjnl9f1#
字符串
用户具有在指定表上执行删除操作所需的权限。此外,在执行删除操作时要小心,因为它们可能会从表中永久删除数据。