我們可以通過CLI、Client、Web UI等Hive提供的使用者介面來和Hive通訊，但這三種方式最常用的是CLI；Client 是Hive的客戶端，使用者連線至 Hive Server。在啟動 Client 模式的時候，需要指出Hive Server所在節點，並且在該節點啟動 Hive Server。 WUI 是通過瀏覽器訪問 Hive。今天我們來談談怎麼通過HiveServer來操作Hive。

<?xml version="1.0"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
 
<configuration>
<property>
  <name>hive.metastore.local</name>
  <value>true</value>
</property>
 
<property>
  <name>javax.jdo.option.ConnectionURL</name>
  <value>jdbc:mysql://localhost:3306/hive</value>
</property>
 
<property>
  <name>javax.jdo.option.ConnectionDriverName</name>
  <value>com.mysql.jdbc.Driver</value>
</property>
 
<property>
  <name>javax.jdo.option.ConnectionUserName</name>
  <value>hive</value>
</property>
 
<property>
  <name>javax.jdo.option.ConnectionPassword</name>
  <value>hive</value>
</property>
<property>
  <name>datanucleus.fixedDatastore</name>
  <value>false</value>
</property>
 
</configuration>
 

　　Hive提供了jdbc驅動，使得我們可以用Java程式碼來連線Hive並進行一些類關係型資料庫的sql語句查詢等操作。同關係型資料庫一樣，我們也需要將Hive的服務開啟；在Hive 0.11.0版本之前，只有HiveServer服務可用，你得在程式操作Hive之前，必須在Hive安裝的伺服器上開啟HiveServer服務，如下：

[[email protected] /home/q/hive-0.11.0]$ bin/hive --service hiveserver -p 10002
Starting Hive Thrift Server

上面代表你已經成功的在埠為10002（預設的埠是10000）啟動了hiveserver服務。這時候，你就可以通過Java程式碼來連線hiveserver，程式碼如下：

package com.wyp;

import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
 
public class HiveJdbcTest {
    
  private static String driverName =
                   "org.apache.hadoop.hive.jdbc.HiveDriver";
	   
	    public static void main(String[] args)	                            throws SQLException {
	        try {
	            Class.forName(driverName);
	        } catch (ClassNotFoundException e) {
	            e.printStackTrace();
	            System.exit(1);
	        }
	 
	        Connection con = DriverManager.getConnection(
	                           "jdbc:hive://localhost:10002/default", "wyp", "");
	        Statement stmt = con.createStatement();
	        String tableName = "wyphao";
	        stmt.execute("drop table if exists " + tableName);
	        stmt.execute("create table " + tableName +
	                                     " (key int, value string)");
	        System.out.println("Create table success!");
	        // show tables
	        String sql = "show tables '" + tableName + "'";
	        System.out.println("Running: " + sql);
	        ResultSet res = stmt.executeQuery(sql);
	        if (res.next()) {
	            System.out.println(res.getString(1));
	        }
	 
	        // describe table
	        sql = "describe " + tableName;
	        System.out.println("Running: " + sql);
	        res = stmt.executeQuery(sql);
	        while (res.next()) {
	            System.out.println(res.getString(1) + "\t" + res.getString(2));
	        }
	 
	 
	        sql = "select * from " + tableName;
	        res = stmt.executeQuery(sql);
	        while (res.next()) {
	            System.out.println(String.valueOf(res.getInt(1)) + "\t"
	                                               + res.getString(2));
	        }
	 
	        sql = "select count(1) from " + tableName;
	        System.out.println("Running: " + sql);
	        res = stmt.executeQuery(sql);
	        while (res.next()) {
	            System.out.println(res.getString(1));
	        }
	    }
	}

編譯上面的程式碼，之後就可以執行(我是在整合開發環境下面執行這個程式的)，結果如下：

Create table success!
Running: show tables 'wyphao'
wyphao
Running: describe wyphao
key                     int                
value                   string             
Running: select count(1) from wyphao
0 
Process finished with exit code 0

　　如果你想在腳本里面執行，請將上面的程式打包成jar檔案，並將上面的依賴庫放在/home/wyp/lib/（這個根據你自己的情況弄）中，同時加入到執行的環境變數，指令碼如下：

#!/bin/bash
HADOOP_HOME=/home/q/hadoop-2.2.0
HIVE_HOME=/home/q/hive-0.11.0-bin
 
CLASSPATH=$CLASSPATH:
 
for i in /home/wyp/lib/*.jar ; do
    CLASSPATH=$CLASSPATH:$i
done
 
echo $CLASSPATH
/home/q/java/jdk1.6.0_20/bin/java -cp  \
   $CLASSPATH:/export1/tmp/yangping.wu/OutputText.jar  com.wyp.HiveJdbcTest

上面是用Java連線HiveServer，而HiveServer本身存在很多問題（比如：安全性、併發性等）；針對這些問題，Hive0.11.0版本提供了一個全新的服務：HiveServer2，這個很好的解決HiveServer存在的安全性、併發性等問題。這個服務啟動程式在${HIVE_HOME}/bin/hiveserver2裡面，你可以通過下面的方式來啟動HiveServer2服務：

$HIVE_HOME/bin/hiveserver2

也可以通過下面的方式啟動HiveServer2

$HIVE_HOME/bin/hive --service hiveserver2

兩種方式效果都一樣的。但是以前的程式需要修改兩個地方，如下所示：

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

Connection con = DriverManager.getConnection(
	                           "jdbc:hive://localhost:10002/default", "wyp", "");
	改為
	Connection con = DriverManager.getConnection(
	                           "jdbc:hive2://localhost:10002/default", "wyp", "");

其他的不變就可以了。

　　這裡順便說說本程式所依賴的jar包，一共有以下幾個：

hadoop-2.2.0/share/hadoop/common/hadoop-common-2.2.0.jar
$HIVE_HOME/lib/hive-exec-0.11.0.jar
$HIVE_HOME/lib/hive-jdbc-0.11.0.jar
$HIVE_HOME/lib/hive-metastore-0.11.0.jar 
$HIVE_HOME/lib/hive-service-0.11.0.jar  
$HIVE_HOME/lib/libfb303-0.9.0.jar  
$HIVE_HOME/lib/commons-logging-1.0.4.jar 
$HIVE_HOME/lib/slf4j-api-1.6.1.jar

　　如果你是用Maven，加入以下依賴

<dependency>
	        <groupId>org.apache.hive</groupId>
	        <artifactId>hive-jdbc</artifactId>
	        <version>0.11.0</version>
	</dependency>
	 
	<dependency>
	        <groupId>org.apache.hadoop</groupId>
	        <artifactId>hadoop-common</artifactId>
        <version>2.2.0</version>
</dependency>