DataFrame使用mysql数据

错误提示:

 Exception in thread "main" java.sql.SQLException: No suitable driver found for jdbc:mysql://localhost:3306/sparkSql?user=root&password=123 

配置驱动的时候有两个大坑

1.首先你要在SPARK_CLASSSPATH中加入mysql的驱动。

2.如果你已经在CP中加入了驱动,又在spark-submit的时候使用--driver-class-path  
 或是在代码的spark-conf中使用spark.driver.extraClassPath属性都会报错。

之后就可以轻松调用API操作Mysql的数据啦

val mysqlData = sqlContext.jdbc("jdbc:mysql://master:3306/sparkSql?user=root&password=123","people")
mysqlData.show()
上一篇:WordCount扩展与优化


下一篇:构建ASP.NET MVC4+EF5+EasyUI+Unity2.x注入的后台管理系统(5)-EF增删改查by糟糕的代码