HiveServer2可以通过JDBC访问,首先确定JDBC驱动,并加载驱动
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
创建数据连接,指定连接路径、用户名、密码
Connection con = DriverManager.getConnection("jdbc:hive2://10.110.18.216:10000/sparktest", "root", "root");
创建Statement
Statement stmt = con.createStatement();
创建表
String tableName = "wyphao";
stmt.execute("drop table if exists " + tableName);
stmt.execute("create table " + tableName + " (key int, value string)");
查询数据
sql = "select * from " + tableName;
res = stmt.executeQuery(sql);
while (res.next()) {
System.out.println(String.valueOf(res.getInt(1)) + "\t" + res.getString(2));
}