PySpark通过JDBC执行MySQL DROP TABLE语句是否可行？

你之前的代码无法工作，原因很明确：sparkSession.read.format("jdbc")是专门用于读取数据生成DataFrame的API，它要求传入的query必须能返回结果集，而DROP TABLE这类DDL（数据定义语言）语句没有返回结果，自然会报错。

下面提供两种可行的解决方案：

方案1：直接用Python的MySQL驱动执行（推荐） #

这种方式不需要依赖Spark的DataFrame API，直接通过Python的MySQL驱动连接数据库执行DDL，简单高效。

首先安装依赖：

pip install mysql-connector-python

示例代码：

import mysql.connector

# 配置数据库连接参数
db_config = {
    'user': '你的用户名',
    'password': '你的密码',
    'host': '192.168.100.100',
    'database': 'temp',
    'raise_on_warnings': True
}

# 建立连接并执行DDL语句
conn = mysql.connector.connect(**db_config)
cursor = conn.cursor()
cursor.execute("DROP TABLE IF EXISTS temp.random_people")
# DDL语句通常不需要commit，但为了确保操作生效，可按需添加
conn.commit()

# 关闭资源
cursor.close()
conn.close()

方案2：通过Spark的JVM底层API执行 #

如果你的场景必须在Spark作业内完成操作，可以利用Spark的JVM层API直接获取JDBC连接，执行DDL语句。

注意：执行前需要确保Spark的JVM环境中存在MySQL的JDBC驱动包（可以在提交Spark作业时通过--jars mysql-connector-java-8.0.30.jar参数指定）。

示例代码：

# 获取Spark JVM中的DriverManager类
driver_manager = spark._sc._jvm.java.sql.DriverManager
# 构造带认证信息的JDBC URL
jdbc_url = "jdbc:mysql://192.168.100.100:3306/temp?user=你的用户名&password=你的密码"

# 建立连接并执行DDL
conn = driver_manager.getConnection(jdbc_url)
stmt = conn.createStatement()
stmt.execute("DROP TABLE IF EXISTS temp.random_people")

# 关闭资源
stmt.close()
conn.close()

内容的提问来源于stack exchange，提问作者David Sánche