准备

启动相关服务

hive3.1.x 启动说明

准备数据

https://malaoshi.top/show_1IXlN51DbxF.html

创建工程

创建maven工程，略

添加依赖

修改pom.xml

<dependencies>
    <dependency>
        <groupId>org.apache.hive</groupId>
        <artifactId>hive-jdbc</artifactId>
        <version>3.1.2</version>

        <!-- log4j-slf4j-impl-2.10.0.jar 与 slf4j-log4j12-1.6.1.jar 冲突，都有 org.slf4j.impl.StaticLoggerBinder.class 文件 -->
        <exclusions>
            <exclusion>
                <groupId>org.apache.logging.log4j</groupId>
                <artifactId>log4j-slf4j-impl</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
</dependencies>

java

可以使用 DbUtil 类

public static void main(String[] args) throws Exception {
    String driver="org.apache.hive.jdbc.HiveDriver";
    String url="jdbc:hive2://hadoop1:10000/default";
    String username="root";
    String password="";
    String sql="select empno,ename from emp";
    //加载驱动类
    Class.forName(driver);
    //创建连接
    Connection conn = DriverManager.getConnection(url,username,password);
    //预编译
    PreparedStatement ps = conn.prepareStatement(sql);
    //查询
    ResultSet rs = ps.executeQuery();
    //从rs中取出结果
    while (rs.next()) {
        System.out.println(rs.getInt(1) + "," + rs.getString(2));
    }
    rs.close();
    ps.close();
    conn.close();
}

原文出处：/show_1IXmUTeK8UE.html