Java通过JDBC连接Hive

本文是通过JDBC连接HiveServer2。

首先需要开启Hive远程服务接口。具体操作请百度。

然后是找到各种jar包。

我之前多次出错的原因就在于jar包不对，选用的jar包只能连接HiveServer。

我整理的jar下载网址为：http://download.csdn.net/detail/q2011zhuce/9467164

Java连接Hive示例代码

import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
import java.text.ParseException;

public class testHive
{

private static String driverName =
"org.apache.hive.jdbc.HiveDriver";

public static void main(String[] args)
throws SQLException, ParseException {
try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.exit(1);
}

Connection con = DriverManager.getConnection("jdbc:hive2://192.168.0.1:10000/default", "hive", "");
Statement stmt = con.createStatement();
// table name
String tableName = "test";
// show tables
String sql = "show tables '" + tableName + "'";
System.out.println("Running sql" + sql);
ResultSet res = stmt.executeQuery(sql);
System.out.println(res.getString(1));
System.out.println(res.last());
while (res.next()) {
System.out.println(res.getString(1));
}

}
}