4.9 Spark SQL 操作MySQL

1. 读取MySQL数据库

 val mysqlDF : DataFrame =

 spark.read.jdbc ("jdbc:mysql://192.168.121.134:3306/spark","person",properties)

 2。向MySQL数据库写入数据

personDF.write.mode("append").jdbc(   "jdbc:mysql://192.168.121.134:3306/spark","spark.person",prop)

最后修改: 2021年10月29日 星期五 10:27