Spark可以通过MySQL驱动进行数据交互
发布时间
阅读量：
阅读量
目录
- 将数据保存到MySQL
- 从MySQL读取数据
- 误区
将数据保存到MySQL
方法一：各个字段都是提前定好的
val prop = new java.util.Properties
prop.setProperty("user", "root")
prop.setProperty("password", "123456")
df.write.mode(SaveMode.Append).jdbc("jdbc:mysql://localhost:3306/test", "mytab", prop)方法二：字段可自由添减
df.foreachPartition(p => {
@transient val conn = ConnectionPool.getConnection
p.foreach(x => {
val sql = "insert into app_id(id,date,appid,num) values (" +
"'"+UUID.randomUUID+"'," +
"'"+x.getInt(0)+"'," +
"'"+x.ge全部评论 (0)
还没有任何评论哟~