在写入dataframe - pyspark之前从表中删除记录

from pyspark.sql import SparkSession

# 创建SparkSession对象
spark = SparkSession.builder \
    .appName("Delete Records from Table") \
    .getOrCreate()

# 从数据库加载表格数据到dataframe
df = spark.read.format("jdbc") \
    .option("url", "jdbc:mysql://localhost:3306/mydatabase") \
    .option("dbtable", "mytable") \
    .option("user", "myuser") \
    .option("password", "mypassword") \
    .load()

# 删除满足条件的记录
df = df.filter(df.age < 30)

# 将更新后的dataframe写回到数据库表中
df.write.format("jdbc") \
    .option("url", "jdbc:mysql://localhost:3306/mydatabase") \
    .option("dbtable", "mytable") \
    .option("user", "myuser") \
    .option("password", "mypassword") \
    .mode("overwrite") \
    .save()