sparksql连接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()            }        }    }}