"dbtable" -> "crm_order")).load()
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
标签：