spark 存入mysql乱码

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("Spark MySQL Example")
  .config("spark.sql.catalogImplementation", "hive")
  .config("spark.sql.parquet.writeLegacyFormat", "true")
  .config("spark.sql.shuffle.partitions", "200")
  .config("spark.driver.extraClassPath", "/path/to/mysql-connector-java.jar")
  .config("spark.executor.extraClassPath", "/path/to/mysql-connector-java.jar")
  .getOrCreate()

CREATE DATABASE IF NOT EXISTS mydb CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
USE mydb;

CREATE TABLE IF NOT EXISTS mytable (
  id INT PRIMARY KEY,
  name VARCHAR(255)
) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;

import org.apache.spark.sql.types.{StructType, StructField, StringType}
import org.apache.spark.sql.{SparkSession, DataFrame}

val schema = new StructType()
  .add(StructField("id", StringType, nullable = false))
  .add(StructField("name", StringType, nullable = false))

val data = Seq(("1", "张三"), ("2", "李四"))
val df = spark.createDataFrame(spark.sparkContext.parallelize(data), schema)

df.write
  .format("jdbc")
  .option("url", "jdbc:mysql://localhost:3306/mydb")
  .option("dbtable", "mytable")
  .option("user", "username")
  .option("password", "password")
  .option("driver", "com.mysql.cj.jdbc.Driver")
  .option("charset", "utf8mb4")
  .save()