scala 連接 hive

原文:

https://blog.csdn.net/weixin_42181917/article/details/82842707

簡易版代碼:

需要POM里面添加 jdbc-hive , 另外 需要啟動 hive的 service2,

package hive
import java.sql.DriverManager
import java.sql.Connection
import java.sql.ResultSet
import java.sql.Statement

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

    val driverName:String = "org.apache.hive.jdbc.HiveDriver"
    try {
      Class.forName(driverName)
    } catch{
      case e: ClassNotFoundException =>
        println("Missing Class",e)
    }

    val con: Connection = DriverManager.getConnection("jdbc:hive2://192.168.1.11/hadoop")
    val stmt: Statement = con.createStatement()
    val res: ResultSet = stmt.executeQuery("show tables")
    while (res.next()) {
      println(res.getString(1))
    }


  }
}