如何顶周期向mysql写数据，并覆盖原来的表

现在代码如下：
[mw_shl_code=scala,true]
import java.sql.{DriverManager, PreparedStatement, Connection}
import org.apache.spark.{SparkContext, SparkConf}
import org.dmg.pmml.False

object RDDtoMysql {
case class Blog(name: String, count: Int)

  def myFun(iterator: Iterator[(String, Int)]): Unit = {
var ps:PreparedStatement = null
var conn: Connection = null
val sql = "insert into blog(name, count) values (?, ?)"
try {
   conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mysql","root", "123456")
   iterator.foreach(data => {
      ps = conn.prepareStatement(sql)
      ps.setString(1, data._1)
      ps.setInt(2, data._2)
      ps.executeUpdate()
   }
   )
   }
catch {
   case e: Exception => println("Mysql Exception")
} finally {
   if (ps != null) {
      ps.close()
   }
   if (conn != null) {
      conn.close()
   }
}
  }

  def main(args: Array[String]) {
//设置运行模式和应该名称
val conf = new SparkConf().setAppName("RDDToMysql").setMaster("local")
val sc = new SparkContext(conf)
val file=sc.textFile("hdfs://master:9000/weblog/access.log.10")
val count=file.flatMap(line => line.split(" ")).map(word => (word,1)).reduceByKey(_+_).sortBy(_._2, false)

val data = sc.parallelize(count.collect())
data.foreachPartition(myFun)
  }
}[/mw_shl_code]

请问下怎么修改为顶周期并覆盖原来的表呢谢谢哈