sparksql写mysql数据库

<dependency>
    <groupId>org.apache.spark</groupId>
    <artifactId>spark-sql_2.12</artifactId>
    <version>3.1.2</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version>
</dependency>

import org.apache.spark.sql.*;

SparkSession spark = SparkSession.builder()
    .appName("Spark SQL MySQL Example")
    .config("spark.some.config.option", "some-value")
    .getOrCreate();

Dataset<Row> df = spark.read()
    .format("jdbc")
    .option("url", "jdbc:mysql://localhost:3306/mydatabase")
    .option("dbtable", "mytable")
    .option("user", "myuser")
    .option("password", "mypassword")
    .load();

df.createOrReplaceTempView("mytable");

Dataset<Row> result = spark.sql("SELECT * FROM mytable WHERE age > 30");

result.show();

result.write()
    .format("jdbc")
    .option("url", "jdbc:mysql://localhost:3306/mydatabase")
    .option("dbtable", "mytable_new")
    .option("user", "myuser")
    .option("password", "mypassword")
    .save();