首先需要使用Navicat在資料庫建庫santi，在santi內建表santi_001
表的格式需要與santi_001(lal: String,count:Int,time:String)相同。
程式碼如下。
使用SQL語句寫入資料庫

import java.sql.{DriverManager, Connection}
import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkContext, SparkConf}

object ToMysql{
/**
*’host’: “192.168.137.131”,
*’user’: “root”,
*’password’: “password”,
*’database’: “santi”,
*’charset’: ‘utf8’
* */

case class santi_001(lal: String,count:Int,time:String)
//模式匹配,測試後不模式匹配也寫入成功
val url=”jdbc:mysql://192.168.137.131:3306/santi”
def myFun(iterator: Iterator[(String, Int,String)]): Unit = {
var conn: Connection= null
var ps:java.sql.PreparedStatement=null
//比Statement方便，S執行一條Sql就得執行一次Statement,而PS效能體現在多次執行Sql，而且引數設定更加方便
val sql=”insert into santi_001(lal, count,time) values (?,?,?)”

conn=DriverManager.getConnection(url,”root”,”password”)
ps = conn.prepareStatement(sql)
iterator.foreach(data => {
ps.setString(1, data._1)
ps.setInt(2, data._2)
ps.setString(3, data._3)
ps.executeUpdate() //執行了Sql語句
}
)
}

def main(args: Array[String]) {
//建立環境變數
val sparkConf = new SparkConf().setAppName(“PeakTimePeople”)
//建立環境變數例項
val sc = new SparkContext(sparkConf)
val a=List((“

執行結果