我正在学习 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)