首页 > 数据库技术 > 详细

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

时间:2020-04-03 00:16:14      阅读:162      评论:0      收藏:0      [点我收藏+]
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数据库操作表数据

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

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!