SparkSQLJDBC连接mysql的方法
这篇文章主要介绍“SparkSQL JDBC连接MySQL的方法”,在日常操作中,相信很多人在SparkSQL JDBC连接mysql的方法问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”SparkSQL JDBC连接mysql的方法”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
创新互联公司专注于泗水企业网站建设,响应式网站,购物商城网站建设。泗水网站建设公司,为泗水等地区提供建站服务。全流程定制设计,专业设计,全程项目跟踪,创新互联公司专业和态度为您提供的服务
SparkSQL JDBC连接 mysql
1.导入 /home/eric/bigdata/spark-log-analysis/mysql-connector-java-5.1.38.jar
2.代码如下
package log import java.sql.DriverManager import java.sql.Connection /** * SparkSQL JDBC连接 mysql * Created by eric on 16/6/30. */ object ScalaJdbcConnectSelect { def main(args: Array[String]) { val driver = "com.mysql.jdbc.Driver" val url = "jdbc:mysql://127.0.0.1/myapp" val username = "root" val password = "" var connection:Connection = null try { Class.forName(driver) connection = DriverManager.getConnection(url, username, password) val statement = connection.createStatement() val resultSet = statement.executeQuery("SELECT * FROM sys_user_base limit 5") while ( resultSet.next() ) { val id = resultSet.getInt("id") val user_id = resultSet.getString("user_id") println("id = " + id + ", user_id = " + user_id) } } catch { case e => e.printStackTrace } connection.close() } }
3.结果图如下
到此,关于“SparkSQL JDBC连接mysql的方法”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注创新互联网站,小编会继续努力为大家带来更多实用的文章!
本文标题:SparkSQLJDBC连接mysql的方法
本文来源:http://pwwzsj.com/article/jehchi.html