91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

HIVE JDBC連接詳解

發布時間:2020-04-14 01:45:18 來源:網絡 閱讀:5322 作者:jethai 欄目:大數據


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.

http://blog.cloudera.com/blog/2014/02/migrating-from-hive-cli-to-beeline-a-primer/?utm_source=tuicool&utm_medium=referral


參考文章:

http://www.iteblog.com/archives/846


向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

牡丹江市| 乌拉特前旗| 哈密市| 苗栗县| 万盛区| 上饶县| 裕民县| 普陀区| 东源县| 盘山县| 灵川县| 庄浪县| 四平市| 绵阳市| 天柱县| 澄迈县| 张家港市| 长乐市| 东莞市| 隆安县| 平顶山市| 淅川县| 阿鲁科尔沁旗| 祁阳县| 婺源县| 瑞安市| 陇南市| 南靖县| 静海县| 青神县| 长治市| 西充县| 黑山县| 吴川市| 河曲县| 广汉市| 宝坻区| 兴安盟| 海南省| 内丘县| 舟山市|