Hive的Thrift服务
Hive有一个可选组件叫HiveServer或HiveThrift。可以通过指定的端口让其他访问访问hive。
在hive1.x版本为hiveServer2。
1、启动hiveserver2
$ hive --service hiveserver2 &
2、连接到hiveserver2
先启动beeline
然后再使用：
beeline> !connect jdbc:hive2://hadoop81:10000/db01 wangjian 123456
其中：wangjian 123456是linux登录的用户名和密码。
执行更多的查询：
3、JDBC连接到hiveserver2
需要以下依赖：
<dependency>
<groupId>org.apache.hive</groupId>
<artifactId>hive-beeline</artifactId>
<version>1.2.2</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.6</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-common</artifactId>
<version>2.7.6</version>
</dependency>
Java代码：
@Test
public void test1() throws Exception {
Class.forName("org.apache.hive.jdbc.HiveDriver");
String url = "jdbc:hive2://hadoop81:10000/db01";
Connection con =
DriverManager.getConnection(url, "wangjian", "123456");
System.err.println(con);
Statement st = con.createStatement();
ResultSet rs = st.executeQuery("select * from stud");
while(rs.next()) {
String id = rs.getString("id");
String name =rs.getString("name");
System.err.println(id+","+name);
}
rs.close();
st.close();
con.close();
}
输出：（表的数据）
1,Jack
2,Mary
3,Alex
Java代码执行一个聚合查询：
@Test
public void test1() throws Exception {
Class.forName("org.apache.hive.jdbc.HiveDriver");
String url = "jdbc:hive2://hadoop81:10000/db01";
Connection con =
DriverManager.getConnection(url, "wangjian", "123456");
System.err.println(con);
Statement st = con.createStatement();
ResultSet rs = st.executeQuery("select count(1) from stud");
rs.next();
Long rows = rs.getLong(1);
System.err.println("rows :"+rows);
rs.close();
st.close();
con.close();
}
后台就会执行一个MR:
最后在JDBC客户方显示结果：
rows :5
