在應用Hive之前，首先搭建Hive環境，關於Hive的搭建 參考之前的搭建文件

java程式碼執行Hive指令碼

java程式碼執行Hive指令碼，需要啟動Hive的內部服務，供其他或者java程式碼連結，Hive內部服務啟動命令

# ./hive --service hiveserver2

啟動成功後tcp會自動監聽 一個10000的埠

但是這裡監聽的IP是127.0.0.1,是不能供其它連結的，需要修改配置檔案，指定服務地址，IP或者伺服器名稱

• 需改 Hive-site.xml 的配置檔案

# vi ../conf/hive-site.xml 

需要把如下value的localhost 改為伺服器名稱或者IP

<property>
  <name>hive.server2.thrift.bind.host</name>
  <value>centos-node6</value>
  <description>Bind host on which to run the HiveServer2 Thrift interface.
  Can be overridden by setting $HIVE_SERVER2_THRIFT_BIND_HOST</description>
</property>

再次啟動Hive的內部服務，檢視監聽的tcp和埠號服務

內部服務開啟成功，現在可以供其它連結Hive，本地測試 命令進入/bin目錄下

# ./beeline 

beeline> !connect jdbc:hive2://centos-node6/default;

使用者名稱預設：root 密碼：無

登陸成功後命令檢視default資料庫中的表

show tables

出現錯誤 5000L，這是Hive的一個bug，需要修改配置檔案

修改配置檔案 hive-site.xml，修改value值為5000

<property>
  <name>hive.server2.long.polling.timeout
 
</name>
  <value>5000</value>
  <description>Time in milliseconds that HiveServer2 will wait, before responding to asynchronous calls that use long polling</description>
</property>

再次命令檢視default 中的表 show tables

遠端連結Hive測試成功！

java程式碼JDBC連結Hive

• jdbc測試連結Hive程式碼如下

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

/**
 * Hive遠端測試連線
 * @author llh
 *
 */
public class HiveTest {

    public static void main(String[] args) throws Exception{
        Class.forName("org.apache.hive.jdbc.HiveDriver");
        Connection conn = DriverManager.getConnection("jdbc:hive2://centos-node6/default", "root", "");
        try {
            Statement st = conn.createStatement();
            ResultSet re = st.executeQuery("select count(*) from t_emp"); 
            if(re.next()){
                System.err.println("t_emp資料條數:"+re.getInt(1));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            conn.close();
        }
    }

}

測試成功