从 Azure Databricks 删除 SQL 数据库中的表

Question

我需要使用 Azure Databricks (PySpark) 在 SQL 数据库中删除一个表。

我必须不使用 PySpark 之外的任何东西来实现这一点。这可以通过使用 DataFrameWriter 来完成吗？下面的代码（内部我相信）首先删除表，然后创建一个具有相同名称的新表，然后将数据帧数据写入表中。

MyDataFrame.write.format("jdbc").option("url", "jdbc:sqlserver://<SQLServerHost>.windows.net:1433").option("database", 'MyDBName').option("dbtable", 'MyTableName').option("user", "MyUsername").option("password", "MyPassword").mode('overwrite').save()

我只想完全删除该表。有没有代码可以做同样的事情？

问候， 斯里

Answer 1

df = spark.read.format('jdbc')\
.option("url", "jdbc:sqlserver://MyServerName:MyPort")\
.option("database", 'MyDBName')\
.option("user", "MyUser")\
.option("password", "MyPassword")\
.option('query', 'drop table tablename')

这成功了。

Answer 2

您可以尝试以下方法。

#Setup the JDBC connection. 
jdbcUrl = "jdbc:mysql://{0}:{1}/{2}".format(jdbcHostname, jdbcPort, jdbcDatabase)
connectionProperties = {
      "user" : jdbcUsername,
      "password" : jdbcPassword,
      "driver" : "com.mysql.jdbc.Driver"
    }

#Create a query to drop the required table
pushdown_query = "DROP table tablename"

#run the query
df = spark.read.jdbc(url=jdbcUrl, table=pushdown_query, properties=connectionProperties)
display(df)

我希望这会有所帮助。