从Databricks(python)对Azure SQL数据库中的表执行更新/覆盖

2024-10-01 11:33:13 发布

您现在位置:Python中文网/ 问答频道 /正文

在azuredatabricks中,表已经在azuresql仓库中创建,我想对azuresql数据库中的现有表执行更新,或者在作业运行时覆盖它的内容

我可以附加,但我面临执行etl的更新/覆盖问题。 我尝试了下面的,但它放弃了表,并试图重新创建一套新的记录,这不是我想要的。你知道吗

def insupd(df,tabname):
df.write.mode("overwrite") \
.format("jdbc") \
.option("url", jdbcUrl) \
.option("dbtable", tabname) \
.option("user",jdbcUsername) \
.option("password", jdbcPassword) \
.option("driver", "com.microsoft.sqlserver.jdbc.SQLServerDriver") \
.save()
 return True

需要知道如何在我的情况下执行更新/覆盖。也请让我知道需要库导入。你知道吗


Tags: 数据库内容dfdef作业记录etl仓库