spark sql 连接mysql报错

一、场景描述

用spark sql计算业务逻辑，将计算结果插入hive，并将计算任务成功是否的日志插入到mysql。

二、报错信息

spark sql计算业务逻辑，将计算结果插入hive，这步运算成功。

计算任务成功是否的日志插入到mysql这步运行失败。报错信息如下：

三、解决问题

添加加载驱动代码：Class.forName("com.mysql.cj.jdbc.Driver")

四、代码展示

object  SqlUtils  {
  
    var conn: Connection = null
    var url="jdbc:mysql://ip:3306/databasename?characterEncoding=utf8"
    var user="username"
    var password="userpassword"
    
    
    def getConnection():Connection = {
      Class.forName("com.mysql.cj.jdbc.Driver")
      DriverManager.getConnection(url, user, password)  
    }

    
    def relaseSource(conn :Connection,pst:PreparedStatement): Unit ={
        try{
            if(pst!=null){
                pst.close()
            }
        }catch{
            case e:Exception =>{
                 e.printStackTrace()
            }
        }finally {
            if(conn!=null){
                conn.close()
            }
        }
    }
}