在Azure数据块中从包含示例数据的SQL表中删除行时

的数据
下面的代码：

from pyspark.sql import SparkSession          
spark = SparkSession.builder.getOrCreate()    
Host = "<serverName>.database.windows.net"    
Port = 1433    
Database = "<dbName>"    
Username = "<userName>"    
Password = "<password>"    
Driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"    
table = "<table>"    
Url = f"jdbc:sqlserver://{Host}:{Port};databaseName={Database}"

connectionProperties = {    
   "user": Username,    
    "password": Password,   
    "driver": Driver
}

query = f"(Delete {table} where Id = 1) AS subquery"
df = spark.read.jdbc(url=Url, table=query, properties=connectionProperties)
df.show()

字符串
我得到了同样的错误：

的
我尝试了下面的过程从表中删除行。我已经使用filter函数删除行：

from pyspark.sql.functions import *
df2 = df.filter(col("<condition>") 
df2.show()

型

的
我使用以下代码将 Dataframe 写入SQL表：

df2.write.format("jdbc").mode("overwrite").option("url", "<Url>").option("dbtable", ""<table>").option("user", "<Username>").option("password", "<Password>").save()

型
表已成功更新。

的

更新时间：

你可以使用下面的代码来执行删除查询：

import pyodbc
conn = pyodbc.connect( 'DRIVER={ODBC Driver 17 for SQL Server};'
                       'SERVER=<serverNmae>.database.windows.net;'
                       'DATABASE=<db>;UID=<userName>;'
                       'PWD=<password>')
conn.execute('DELETE <tableName> WHERE <condition>')

型