Java API如何操作Hive

這篇文章給大家分享的是有關Java API如何操作Hive的內容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

環境:

   IDEA2017.3+Maven-3.3.9+Hive1.1.0

1. pom.xml里面的依賴包配置

<properties>

  <hive.version>1.1.0</hive.version>
</properties>
<dependencies>

  <!-- 添加Hive-jdbc的dependency -->

  <dependency>

    <groupId>org.apache.hive</groupId>

    <artifactId>hive-jdbc</artifactId>

    <version>${hive.version}</version>

  </dependency>
</dependencies>

2. 新建HiveJdbcClient.java 文件
package com.ruozedata.day6;

import java.sql.*;

public class HiveJdbcClient {

    /**

     * 需要把：org.apache.hadoop.hive.jdbc.HiveDriver

     * 改成：org.apache.hive.jdbc.HiveDriver

     */

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


    public static void main(String[] args) throws SQLException {

        try {

            Class.forName(driverName);

        } catch (ClassNotFoundException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

            System.exit(1);

        }

        /**

         * 需要把：jdbc:hive://localhost:10000/default

         * 改成：jdbc:hive2://192.168.1.108:10000/ruozedata_test

         */

        Connection con = DriverManager.getConnection("jdbc:hive2://192.168.1.108:10000/ruozedata_test", "root", "root");

        Statement stmt = con.createStatement();

        String tableName = "a";

        String sql = "" ;

        /**

         * a的表結構：

         * # col_name              data_type

         * id                      int

         * name                    string

         * age                     int

         * select id,name,age query

         */


        sql = "select id,name,age  from " + tableName;

        System.out.println("Running: " + sql);

        ResultSet  res = stmt.executeQuery(sql);

        while (res.next()) {

            System.out.println(String.valueOf(res.getInt(1)) + "\t"

                    + res.getString(2)+ "\t"

                    + res.getInt(3));

        }

    }
}

需要注意2點：

 1.官網的驅動名稱driverName： org.apache.hadoop.hive.jdbc.HiveDriver

 需要改成：org.apache.hive.jdbc.HiveDriver

 

 2.官網的數據庫連接URL：jdbc:hive://localhost:10000/default

 需要改成：jdbc:hive2://localhost:10000/default   

 其中localhost改成數據庫的IP，default改成需要連接的數據名

 
3. 需要開啟Hive的 hiveserver2 服務。

   如果不開啟hiveserver2 服務，運行程序的時候就會報錯：

   Exception in thread "main" java.sql.SQLException: Could not open client transport with JDBC Uri: jdbc:hive2://192.168.1.108:10000/ruozedata_test: java.net.SocketException: Connection reset

4. 運行程序的結果：
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/D:/software/apache-maven-3.3.9/repository/org/slf4j/slf4j-log4j12/1.7.5/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/D:/software/apache-maven-3.3.9/repository/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
log4j:WARN No appenders could be found for logger (org.apache.hive.jdbc.Utils).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Running: select id,name,age  from a
1	zhangsan	15

Process finished with exit code 0

感謝各位的閱讀！關于“Java API如何操作Hive”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！