spark实现dataframe数据存储到mysql

首先需要将需要存储的DataFrame转化为一个临时表，然后使用Spark SQL语句将数据写入MySQL中。

下面是一个示例代码：

from pyspark.sql import SparkSession

# 创建SparkSession
spark = SparkSession.builder.appName("Write DataFrame to MySQL").getOrCreate()

# 读取数据到DataFrame中
df = spark.read.format("csv").option("header", "true").load("data.csv")

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

# 定义MySQL连接信息
url = "jdbc:mysql://localhost:3306/mydb"
table_name = "mytable"
properties = {
    "user": "root",
    "password": "password"
}

# 使用Spark SQL将数据写入MySQL中
spark.sql(f"SELECT * FROM temp_table").write.jdbc(url=url, table=table_name, mode="overwrite", properties=properties)

# 关闭SparkSession
spark.stop()

在上面的代码中，首先使用SparkSession读取CSV文件中的数据到DataFrame中，然后将DataFrame注册为一个临时表，接着定义MySQL连接信息，最后使用Spark SQL将数据写入MySQL中。

需要注意的是，如果MySQL中已经存在同名的表，可以使用`mode="overwrite"`来覆盖原有的数据。如果不希望覆盖原有数据，可以使用`mode="append"`来追加数据。

另外，如果需要将DataFrame中的数据写入其他类型的数据库，只需要将连接信息修改为相应的数据库连接信息即可。