Pyspark能否使用JDBC传递Alter Table

from pyspark.sql import SparkSession

# 创建SparkSession
spark = SparkSession.builder \
    .appName("JDBC Alter Table Example") \
    .getOrCreate()

# 创建DataFrame
data = [("Alice", 25), ("Bob", 30), ("Charlie", 35)]
df = spark.createDataFrame(data, ["name", "age"])

# 将DataFrame写入数据库表
df.write \
    .format("jdbc") \
    .option("url", "jdbc:mysql://localhost:3306/mydatabase") \
    .option("dbtable", "mytable") \
    .option("user", "myuser") \
    .option("password", "mypassword") \
    .mode("overwrite") \
    .save()

# 使用JDBC传递Alter Table语句修改表结构
spark.read \
    .format("jdbc") \
    .option("url", "jdbc:mysql://localhost:3306/mydatabase") \
    .option("dbtable", "mytable") \
    .option("user", "myuser") \
    .option("password", "mypassword") \
    .option("customSchema", "ALTER TABLE mytable ADD COLUMN email STRING") \
    .load()