SparkSQL——通过JDBC的方式访问

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()

  }
}