首页 > 数据库技术 > 详细

SparkSQL——通过JDBC的方式访问

时间:2019-01-25 10:08:59      阅读:330      评论:0      收藏:0      [点我收藏+]

1.前提

  首先是hadoop的两个服务要开启

  然后是hive 的metastore

  然后启动spark-shell,如果没有启动hive的metastore,则会在这一步报错,说找不到hive的9083端口。至于启动spark-shell,则是为了看4040端口上的JDBS/ODBC服务

  然后启动hive thriftservice

 

实例代码

package com.spark

import java.sql.DriverManager

/*
   通过JDBC的方式访问
 */
object SparkSQLThriftServer {

  def main(args: Array[String]): Unit = {

    Class.forName("org.apache.hive.jdbc.HiveDriver")

    val conn=DriverManager.getConnection("","","")
    val pstmt=conn.prepareStatement("select * from table")
    val rs=pstmt.executeQuery()
    while(rs.next())
      {
        println("name"+rs.getInt("name"))
      }

    rs.close()
    pstmt.close()
    conn.close()

  }
}

 

SparkSQL——通过JDBC的方式访问

原文:https://www.cnblogs.com/aishanyishi/p/10317925.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!