源码

package com.zc.hive;

import java.sql.*;

public class HiveJDBCTest {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        String driver="org.apache.hive.jdbc.HiveDriver";                       //驱动名称
        String url="jdbc:hive2://centos1:10000/marketing";                     //连接地址，使用默认端口10000，使用marketing数据库
        String username="";                                                    //Hadoop集群登录用户名
        String password="";                                                    //Hadoop集群登录密码

        Class.forName(driver);                                                 //加载jdbc驱动

        Connection conn= DriverManager.getConnection(url,username,password);   //获得连接
        Statement stmt=conn.createStatement();

        ResultSet res=stmt.executeQuery("show tables");                        //执行查询

        while(res.next()){                                                     //处理结果
            System.out.println(res.getString(1));
        }

        res.close();                                                           //关闭连接
        stmt.close();
        conn.close();
    }
}

pom.xml文件添加依赖

<!--            kafka客户端依赖库-->
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>2.0.0</version>
        </dependency>

<!--        hive jdbc依赖包-->
        <dependency>
            <groupId>org.apache.hive</groupId>
            <artifactId>hive-jdbc</artifactId>
            <version>2.3.3</version>
        </dependency>
<!--        指定jdk工具包位置，需要本地配置好环境变量-->
        <dependency>
            <groupId>jdk.tools</groupId>
            <artifactId>jdk.tools</artifactId>
            <version>1.8</version>
            <scope>system</scope>
            <systemPath>${JAVA_HOME}/lib/tools.jar</systemPath>
        </dependency>