实现代码

excel所需的pom依赖 

案例实现 


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()

    // 读取Excelval 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()
  }
}


        <dependency>
            <groupId&gt;com.crealytics</groupId&gt;
            <artifactId&gt;spark-excel_2.12</artifactId&gt;
            <version&gt;0.13.7</version&gt;
        </dependency>

        准备excel表: 

        放在路径下面: 

 

 执行代码:

 在mysql查看

 

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注