scala链接mysql

val tableDF = sqlContext.jdbc("jdbc:mysql://mysql_hostname:mysql_port/testDF?user=your_username&password=your_password", "user")

//查询mySql数据库
val tableDF = sqlContext.jdbc("jdbc:mysql://10.1.2.190:8066/mq_sale_disc?user=kr.user&password=user@85263382", "tmp_enterprise")

注意：execute、executeUpdate、executeQuery三者区别

查询用executeQuery

插入、更新、删除用executeUpdate

scala链接mysql

标签：