package org.conan.myhadoop.mr;

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

public class HiveJDBCConnection {

    private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
    // Hive 0.11.0版本以後org.apache.hive.jdbc.HiveDriver
    private static String url = "jdbc:hive://localhost:10000/default";
    // Hive 0.11.0版本以後jdbc:hive2://localhost:10000/default
    private static String userName = "";
    private static String passWord = "";

    public static void main(String[] args) {
        try {
            Class.forName(driverName);
            Connection con = DriverManager.getConnection("url", "userName",
                    "passWord");
            Statement stmt = con.createStatement();
            // 如果存在了就刪除
            String tableName = "jdbc_table";
            String sql = "drop table if exists " + tableName;
            stmt.execute(sql);
            // 建立表
            sql = "create table"
                    + tableName
                    + " (key string,value string) row format delimited fields terminated by ','  stored as textfile ";
            stmt.execute(sql);
            //載入資料
            String Path="/home/hive_1.txt";
            sql ="load data local inpath '"+Path+"' into table "+tableName;
            stmt.execute(sql);
            // 查詢資料
            sql ="select * from "+tableName;
            ResultSet res = stmt.executeQuery(sql);
            while(res.next()){
                System.out.println(res.getString(1)+"\t"+res.getString(1));
                
            }
            
        } catch (ClassNotFoundException e) {
            System.out.println("沒有找到驅動類");
            e.printStackTrace();
        } catch (SQLException e) {
            System.out.println("連線Hive的資訊有問題");
            e.printStackTrace();
        }

    }
}
 

上面是用Java連線HiveServer，而HiveServer本身存在很多問題（比如：安全性、併發性等）；針對這些問題，Hive0.11.0版本提供了一個全新的服務：HiveServer2，這個很好的解決HiveServer存在的安全性、併發性等問題。

上面的userName和passWord是hive元資料mysql的使用者名稱和密碼

Use Cases: Hive CLI versus Beeline

The following section focuses on the common uses of Hive CLI/HiveServer1 and how you can migrate to Beeline/HiveServer2 in each case.

參考文章：