Hive提供了jdbc驅動，使得我們可以用java程式碼來連線Hive並進行一些類關係型資料庫的sql語句查詢等操作。首先，我們必須將Hive的服務，也就是HiveServe開啟。在Hive 0.11.0版本前，只有HiveServer服務可用，但是HiveServer本身存在很多問題（比如：安全性、併發性等）；針對這些問題，Hive-0.11.0版本後提供了一個全新的服務：HiveServer2,這個很好的解決HiveServer存在的安全性、併發性等問題。

兩種服務的啟動方式基本一樣。如下：

1. ./bin/hive --service hiveserver  
2. ./bin/hive --service hiveserver2  

./bin/hive --service hiveserver

./bin/hive --service hiveserver2

啟動hiveserver（2）服務後，你就可以通過java程式碼來連線hiveserver並進行相應的hive操作了。示例程式碼如下：

1. package com.aturbo.hadoop;  
2. import java.sql.Connection;  
3. import java.sql.DriverManager;  
4. import java.sql.ResultSet;  
5. import java.sql.Statement;  
6. public class Hive {  
7.     public static void main(String args[])throws Exception{  
8.         Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");  
9.         //String dropSQL = "drop table javabloger";  
10.         //String createSQL = "create table javabloger(key int,value string)";
      
11.         //String insertSQL = "load data local inpath '/home/congcong.ai/hive/kv1.txt'"  
12.         //      + "overwrite into table javabloger";  
13.          // String querySQL = "select a.* from javabloger a";  
14.           String querySQL = "select * from pokes";  
15.           Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/default", "", "");  
16.           Statement stmt = con.createStatement();  
17.           //stmt.executeQuery(dropSQL);  
18.           //stmt.executeQuery(createSQL);  
19.           //stmt.executeQuery(insertSQL);  
20.           ResultSet res = stmt.executeQuery(querySQL);  
21.           while(res.next()){  
22.               System.out.println("Result: key:"+res.getString(1) +"  –>  value:" +res.getString(2));  
23.           }  
24.     }  
25. }  

package com.aturbo.hadoop;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class Hive {

	public static void main(String args[])throws Exception{
		Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");
		
		//String dropSQL = "drop table javabloger";
		//String createSQL = "create table javabloger(key int,value string)";
		//String insertSQL = "load data local inpath '/home/congcong.ai/hive/kv1.txt'"
		//		+ "overwrite into table javabloger";
		 // String querySQL = "select a.* from javabloger a";
		  String querySQL = "select * from pokes";
		  Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/default", "", "");
		  Statement stmt = con.createStatement();
		  //stmt.executeQuery(dropSQL);
		  //stmt.executeQuery(createSQL);
		  //stmt.executeQuery(insertSQL);
		  ResultSet res = stmt.executeQuery(querySQL);
		  while(res.next()){
			  System.out.println("Result: key:"+res.getString(1) +"  –>  value:" +res.getString(2));
		  }
	}
}

上面程式碼是針對hiveserver的。如果是hiveserver2。那有兩處需要修改，具體修改如下：

org.apache.hadoop.hive.jdbc.HiveDriver

改為：

org.apache.hive.jdbc.HiveDriver

jdbc:hive://localhost:10000/default

改為：

jdbc:hive2://localhost:10000/default

其中’localhost’是主機地址，10000是埠後，default是預設的db。

接下來就可以編譯、執行上面的程式碼了。

本人使用的開發環境是linux(centos 7)。沒有安裝eclipse。所以這裡只講用指令碼的方式執行。

1） 首先建立一個資料夾/hive。(本人建立的該資料夾絕對路徑：/home/workspace/hive)

2）    在hive下面分別建立三資料夾：src/、classes/、lib/。其中，src儲存原始碼（也就是上面的程式碼，命名為Hive.java），classes儲存編譯後的.class檔案。lib存放依賴的jar包。

3）    在lib下存放依賴jar包:

4）     編譯Hive.java,並保持到/classes目錄下：

5）    將/classes/打包成jar,並放在當前路徑下（/home/workspace/hive）：

1. [[email protected] hive]# jar cvf hive.jar -C ./classes/ .  
2. 已新增清單  
3. 正在新增: com/(輸入 = 0) (輸出 = 0)(儲存了 0%)  
4. 正在新增: com/aturbo/(輸入 = 0) (輸出 = 0)(儲存了 0%)  
5. 正在新增: com/aturbo/hadoop/(輸入 = 0) (輸出 = 0)(儲存了 0%)  
6. 正在新增: com/aturbo/hadoop/Hive.class(輸入 = 1596) (輸出 = 926)(壓縮了 41%)  

[[email protected] hive]# jar cvf hive.jar -C ./classes/ .
已新增清單
正在新增: com/(輸入 = 0) (輸出 = 0)(儲存了 0%)
正在新增: com/aturbo/(輸入 = 0) (輸出 = 0)(儲存了 0%)
正在新增: com/aturbo/hadoop/(輸入 = 0) (輸出 = 0)(儲存了 0%)
正在新增: com/aturbo/hadoop/Hive.class(輸入 = 1596) (輸出 = 926)(壓縮了 41%)

6)建立指令碼——run.sh,內容如下：

1.    #!/bin/bash  
2. HADOOP_HOME=/home/aturbo/hadoop/hadoop-1.2.1  
3. HIVE_HOME=/home/aturbo/hive/hive.1.2.1  
4. CLASSPATH=$CLASSPATH:  
5. for i in /home/workspace/hive/lib/*.jar;do  
6.      CLASSPATH=$CLASSPATH:$i  
7. done  
8. echo $CLASSPATH  
9. java -cp $CLASSPATH:/home/workspace/hive/hive.jar com.aturbo.hadoop.Hive  

   #!/bin/bash
HADOOP_HOME=/home/aturbo/hadoop/hadoop-1.2.1
HIVE_HOME=/home/aturbo/hive/hive.1.2.1

CLASSPATH=$CLASSPATH:

for i in /home/workspace/hive/lib/*.jar;do
     CLASSPATH=$CLASSPATH:$i
done

echo $CLASSPATH
java -cp $CLASSPATH:/home/workspace/hive/hive.jar com.aturbo.hadoop.Hive

7)給run.sh賦予可執行許可權，或直接sourcerun.sh,開始連線hive，並執行程式碼。如果執行成功，服務端後輸出：OK。客戶端輸出：

1. 15/10/16 15:04:23 INFO jdbc.Utils: Supplied authorities: localhost:10000  
2. 15/10/16 15:04:23 INFO jdbc.Utils: Resolved authority: localhost:10000  
3. 15/10/16 15:04:23 INFO jdbc.HiveConnection: Will try to open client transport with JDBC Uri: jdbc:hive2://localhost:10000/default  
4. Result: key:1  –>  value:wyp  
5. Result: key:2  –>  value:test  
6. Result: key:3  –>  value:zs  
7. Result: key:1  –>  value:wyp  
8. Result: key:2  –>  value:test  
9. Result: key:3  –>  value:zs  
10. Result: key:1  –>  value:wyp  
11. Result: key:2  –>  value:test  
12. Result: key:3  –>  value:zs  
13. Result: key:1  –>  value:wyp  
14. Result: key:2  –>  value:test  
15. Result: key:3  –>  value:zs  

15/10/16 15:04:23 INFO jdbc.Utils: Supplied authorities: localhost:10000
15/10/16 15:04:23 INFO jdbc.Utils: Resolved authority: localhost:10000
15/10/16 15:04:23 INFO jdbc.HiveConnection: Will try to open client transport with JDBC Uri: jdbc:hive2://localhost:10000/default
Result: key:1  –>  value:wyp
Result: key:2  –>  value:test
Result: key:3  –>  value:zs
Result: key:1  –>  value:wyp
Result: key:2  –>  value:test
Result: key:3  –>  value:zs
Result: key:1  –>  value:wyp
Result: key:2  –>  value:test
Result: key:3  –>  value:zs
Result: key:1  –>  value:wyp
Result: key:2  –>  value:test
Result: key:3  –>  value:zs

至此，整個通過JDBC驅動連線hive並操作的例項就完成了。

注意：

Hive是基於Hadoop的，所以，在連線hive時，務必已經啟動了hadoop。具體hadoop的安裝啟動等，推薦下載閱讀

此外，如果出現連線

com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:Communications link failure。

說明，hive元資料關聯的mysql資料庫沒有啟動。