使用PySpark和数据库环境通过另一个临时表更新临时表

from pyspark.sql import SparkSession

spark = SparkSession.builder \
    .appName("Update Temporary Table") \
    .config("spark.jars.packages", "mysql:mysql-connector-java:8.0.26") \
    .getOrCreate()

# 连接数据库
url = "jdbc:mysql://localhost:3306/db_name"
user = "username"
password = "password"

df = spark.read \
    .format("jdbc") \
    .option("url", url) \
    .option("dbtable", "temporary_table") \
    .option("user", user) \
    .option("password", password) \
    .load()

# 将DataFrame注册为一个临时表
df.createOrReplaceTempView("temp_table")

# 创建另一个临时表
another_temp_table = spark.sql("SELECT * FROM another_temp_table")

# 将另一个临时表的数据插入到当前临时表中
spark.sql("INSERT INTO temp_table SELECT * FROM another_temp_table")

# 将更新后的临时表数据保存回数据库
df.write \
    .format("jdbc") \
    .option("url", url) \
    .option("dbtable", "temporary_table") \
    .option("user", user) \
    .option("password", password) \
    .mode("overwrite") \
    .save()