This post shows you how to connect to HiveServer2 via Hive JDBC driver in Java.
*The way to connect to HiveServer1 is very similar though the driver names are different:
| Version | Driver Name |
|---|---|
| HiveServer1 | org.apache.hadoop.hive.jdbc.HiveDriver |
| HiveServer2 | org.apache.hive.jdbc.HiveDriver |
The JDBC connection URL will also be different:
| Version | Driver Name |
|---|---|
| HiveServer1 | jdbc:hive://… |
| HiveServer2 | jdbc:hive2://… |
Add dependency
First we need to add dependency in your project pom file (if you are using Maven):
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>app.kontext.tech</groupId> <artifactId>examples</artifactId> <version>0.0.1-SNAPSHOT</version> <dependencies> <dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-jdbc</artifactId> <version>3.1.1</version> </dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-jdbc</artifactId> <version>3.1.1</version> </dependency> </dependencies> </project>
Or you need to directly reference Hive JAR file.
Create a Java class to connect to HiveServer2
Now, we can connect to HiveServer2 as you can do with any other supported databases.
The following is a sample class for your reference:
package examples;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement;public class HiveJdbcExample { /** * HiveServer2 JDBC driver name */ private static String driverName = "org.apache.hive.jdbc.HiveDriver"; public static void main(String[] args) throws SQLException { try { Class.forName(driverName); } catch (ClassNotFoundException e) { e.printStackTrace(); System.exit(1); } Connection conn = DriverManager.getConnection("jdbc:hive2://localhost:10000", "hive", ""); Statement stmt = conn.createStatement(); // show tables String sql = "SHOW databases"; System.out.println("Running: " + sql); ResultSet rs = stmt.executeQuery(sql); while (rs.next()) { System.out.println(rs.getString(1)); } rs.close(); String sql2 = "select * from test_db.test_table"; System.out.println("Running: " + sql2); ResultSet rs2 = stmt.executeQuery(sql2); ResultSetMetaData rsmd = rs2.getMetaData(); int columnsNumber = rsmd.getColumnCount(); while (rs2.next()) { for (int i = 1; i <= columnsNumber; i++) { if (i > 1) System.out.print(", "); String columnValue = rs2.getString(i); System.out.print(rsmd.getColumnName(i) + " " + columnValue); } System.out.println(""); } rs2.close(); conn.close(); }}
For detailed information about connection URLs (as HiveServer2 service can run in different modes), please refer to the following page published by Apache:
Sample output
In HiveServer2 Web UI, we can also find the query history:
Clicking Drilldown link, you can also view the query detailed information:
