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数据库操作表数据
猜你喜欢
转载自www.cnblogs.com/wuzaipei/p/12623880.html
今日推荐
周排行