使用pyspark更新mysql表

7eumitmz  于 5个月前  发布在  Spark
关注(0)|答案(1)|浏览(81)

我的要求之一是更新一个表,是目前在mysql数据库。我这样做如下。

update_query = f"""
    UPDATE {table_name}
    SET xxperc = 1.000
    WHERE xxID = ##########
"""
spark.read.format("jdbc") \
    .option("url", jdbc_url1) \
    .option("dbtable", f"({update_query}) as update_query") \
    .option("user", username1) \
    .option("password", password1) \
    .load()

字符串
这会抛出如下错误(conn=175897)您的SQL语法中有错误;请检查与您的MySQL服务器版本对应的手册,以获得正确的语法来使用'UPDATE'问题
我该怎么办?

qoefvg9y

qoefvg9y1#

我终于找到了答案,更新在下面。

connection = mysql.connector.connect(
    host=host,
    port=port,
    user=user,
    password=password,
    database=database
)
cursor = connection.cursor()
update_query = f""" """
cursor.execute(update_query)
connection.commit()
cursor.close()
connection.close()

字符串

相关问题