hive jdbc需要的jars

hive-jdbc-2.3.4.jar
hive-service-2.3.4.jar
hive-service-rpc-2.3.4.jar
libthrift-0.9.3.jar
hive-common-2.3.4.jar
hive-serde-2.3.4.jar

import java.sql.DriverManager
val conStr = "jdbc:hive2://host:port/default"
Class.forName("org.apache.hive.jdbc.HiveDriver")
val con = DriverManager.getConnection(conStr, "user", "password")
val stmt = con.createStatement
val resultSet = stmt.executeQuery("show databases")

val rsmd = resultSet.getMetaData
val columnsNumber = rsmd.getColumnCount
while (resultSet.next) {
  for (i <- 1 to columnsNumber) {
    if (i > 1) System.out.print(",  ")
    val columnValue = resultSet.getString(i)
    System.out.print(columnValue + " " + rsmd.getColumnName(i))
  }
  System.out.println("")
}
System.out.println("show database successfully.")
    val hikariConfig = new HikariConfig()

    hikariConfig.setPoolName("HikariCP 连接池");
    hikariConfig.setDriverClassName("org.apache.hive.jdbc.HiveDriver");
    hikariConfig.setUsername( "hive");
    hikariConfig.setPassword( "00000")
    hikariConfig.setJdbcUrl( "00000")
    hikariConfig.setMaximumPoolSize(15)

    val hikariDataSource = new HikariDataSource(hikariConfig);

    val connection = hikariDataSource.getConnection();
    val st = connection.createStatement();
    val rs = st.executeQuery("show databases");
    if (rs.next()) {
      println(rs.getString(1));
    }

版权声明:本文为weixin_42756361原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。