小编rak*_*sht的帖子

无法从 pyspark 连接到 Mysql 数据库,出现 jdbc 错误

我正在学习 pyspark,并尝试连接到 mysql 数据库。

但是我java.lang.ClassNotFoundException: com.mysql.jdbc.Driver在运行代码时遇到异常。我花了一整天试图修复它,任何帮助将不胜感激:)

我正在使用带有 anaconda 和 python 3.6.3 的 pycharm 社区版

这是我的代码:

from pyspark import SparkContext,SQLContext
sc= SparkContext()
sqlContext= SQLContext(sc)

df = sqlContext.read.format("jdbc").options(
url ="jdbc:mysql://192.168.0.11:3306/my_db_name",
driver = "com.mysql.jdbc.Driver",
dbtable = "billing",
user="root",
password="root").load()
Run Code Online (Sandbox Code Playgroud)

这是错误:

py4j.protocol.Py4JJavaError: An error occurred while calling o27.load.
: java.lang.ClassNotFoundException: com.mysql.jdbc.Driver
Run Code Online (Sandbox Code Playgroud)

mysql jdbc python-3.x apache-spark-sql pyspark-sql

6
推荐指数
1
解决办法
8809
查看次数

标签 统计

apache-spark-sql ×1

jdbc ×1

mysql ×1

pyspark-sql ×1

python-3.x ×1