如何将rdd导入数据库中【简单实例】

package com.henuimport java.sql.DriverManagerimport org.apache.spark.{SparkConf, SparkContext}
//将rdd导入数据库中
object ToMysql {def main(args: Array[String]): Unit = {val conf = new SparkConf().setMaster("local[3]").setAppName("tm")val sc = new SparkContext(conf)sc.setLogLevel("error")val list = List(1,2,3,4,5)val data = sc.parallelize(list)data.foreachPartition(itor => {try{Class.forName("com.mysql.jdbc.Driver")val url="jdbc:mysql://henu1:3306/second?useSSL=false"val conn = DriverManager.getConnection(url,"root","123")val insert = "insert into data values(?)"val stmt = conn.prepareStatement(insert)itor.foreach(x=>{stmt.setInt(1,x)stmt.addBatch()//stmt.executeUpdate()})stmt.executeBatch()stmt.close()conn.close()}catch {case ex:Exception=>println(ex.getMessage)}})sc.stop()}
}

如何将rdd导入数据库中【简单实例】相关推荐

solr使用网页浏览器批量导入数据库中数据（本案例是mysql）
如果想要知道如何安装solr,集成IKAnalyzer中文分词器,批量导入数据库数据,java使用参照以下本博主博文: 安装solr https://blog.csdn.net/u013294097/ ...
如何将.FRM,.MYD,MYI文件转换为.SQL导入数据库中
先说说这几种文件是干什么的: *.frm是描述了表的结构, *.myd保存了表的数据记录, *.myi则是表的索引. 其实一个.frm文件就是对应的数据库中的一个表,表示数据表的表结构. . ...
excel导入数据库的简单方法
一个简单的方法将excel导入数据库 private void Plan_Import_Execl() { OpenFileDialog fileDialog ...
mysql导入数据库某张表_MSSQLServer2005 导出导入数据库中某张表的数据
备注:在工作中我们经常会遇到,将数据库中某张数据表中的内容或数据导出来:今天我们就介绍怎样快速有效的进行数据导出,导入.使用的数据库版本为:mssqlserver2005.首先进行登录mssqlser ...
Spark Core (TopN、mysql写入、读取文件通过RDD结合数据库中的表)练习3套
pom.xml文件 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="h ...
mysql 导入设置编码_从MySQL导出导入数据库的命令实例及设置会话字符编码
1.导入导出 1.mysql导出整个数据库 mysqldump -u 用户名 -p 数据库名 > 导出的文件名 mysqldump -u wcnc -p smgp_apps_wcnc > ...
Java 将excel中的内容导入数据库中
ExcelReader类,用来从excel中读取数据的,网上版本的修改版. package dataDML;import java.io.IOException; import java.io.Inp ...
将Excel文档中的数据导入数据库中
一.效果:点击导出按钮,弹出导入模态窗体:在模态窗体中,①点击下载,会实现下载一个 Excel文件下载功能:②选择下载的Excel文件:③点击上传,Excel文档中的数据 ...
Excel 导入数据库中java.lang.StringIndexOutOfBoundsException: String index out of range: -50提示解决原因...
dbf文件另存为.xls然后导入到sql数据库里会报错. java.lang.StringIndexOutOfBoundsException: String index out of range: - ...

如何将rdd导入数据库中【简单实例】

如何将rdd导入数据库中【简单实例】相关推荐

最新文章

热门文章