码迷,mamicode.com
首页 > 数据库 > 详细

spark2.0 连接mysql8.0数据库操作表数据

时间:2020-04-03 00:21:17      阅读:126      评论:0      收藏:0      [点我收藏+]

标签:enc   div   nic   mysql   localhost   reading   pack   apache   load   

package operationMysql
import config.conf.{sc, spark_session}
import org.apache.spark.sql.DataFrame
object readingMysqlOperation {
  def main(args: Array[String]): Unit = {

    val df: DataFrame = spark_session.read
      .format("jdbc")
      .option("url", "jdbc:mysql://localhost:3306/junsheng?useUnicode=true&characterEncoding=utf-8")
      .option("dbtable", "订单")
      .option("user", "root")
      .option("password", "123456")
      .load()
    df.show()

  }
}

 

spark2.0 连接mysql8.0数据库操作表数据

标签:enc   div   nic   mysql   localhost   reading   pack   apache   load   

原文地址:https://www.cnblogs.com/wuzaipei/p/12623880.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!