1. java 代码
package hive;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class App {
public static void main(String[] args) throws Exception {
Class.forName("org.apache.hive.jdbc.HiveDriver");
// default 为 hive的数据库名
Connection conn = DriverManager.getConnection("jdbc:hive2://hadoop0:10000/default", "", "");
Statement stmt = conn.createStatement();
String querySQL="SELECT * FROM default.t1";
ResultSet res = stmt.executeQuery(querySQL);
while (res.next()) {
System.out.println(res.getInt(1));
}
}
}
2. JDBC 连接 Hive 时遇见的问题
- Java.lang.ClassNotFoundException: org.apache.Hadoop
解决方案:
Class.forName(“org.apache.hive.jdbc.HiveDriver”);
而不是:
Class.forName(“org.apache.hadoop.hive.jdbc.HiveDriver”);
- java.sql.SQLException: No suitable driver found for jdbc:hive://localhost:10000/default
在 hive 1.2.1 需要 jdbc:hive2://localhost:10000/default
而不是 jdbc:hive://localhost:10000/default
- java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://X.X.X.X:10000/default: java.NET.ConnectException: Connection refused
对于 hive 1.2 及以上的版本,hive不再使用,而直接使用 hiveserver2
命令;
[root@node1 ~]# hiveserver2 &