实现代码
package excel_mysql
import org.apache.spark.sql.SparkSession
import java.util.Properties
object t1 {
def main(args: Array[String]): Unit = {
val spark = SparkSession.builder()
.appName("ExcelToMySQL") //项目名
.master("local[*]")
.getOrCreate()
// 读取Excel表
val df = spark.read
.format("com.crealytics.spark.excel") //需要的包
.option("header", "true")
.load("file:///D:\sparks\src\main\datas\d.xlsx") //本地excel文件路径
// 创建MySQL连接配置
val jdbcHostname = "192.168.10.137" //连接主机ip
val jdbcPort = 3306 //端口
val jdbcDatabase = "test" //数据库名
val jdbcUsername = "root" //用户名
val jdbcPassword = "123456" //mysql密码
val jdbcUrl = s"jdbc:mysql://${jdbcHostname}:${jdbcPort}/${jdbcDatabase}"
val connectionProperties = new Properties()
connectionProperties.put("user", s"${jdbcUsername}")
connectionProperties.put("password", s"${jdbcPassword}")
// 将DataFrame写入MySQL表中
df.write
.mode("overwrite")
.jdbc(jdbcUrl, "user_info", connectionProperties) //导入目标的mysql数据库下的表名
spark.stop()
}
}
excel所需的pom依赖
<dependency>
<groupId>com.crealytics</groupId>
<artifactId>spark-excel_2.12</artifactId>
<version>0.13.7</version>
</dependency>
案例实现
放在路径下面:
执行代码:
原文地址:https://blog.csdn.net/dafsq/article/details/134701211
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_32264.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。