hive3.1.x：jdbc连接hive-马育民老师

# 准备

### 启动相关服务

[hive3.1.x 启动说明](https://www.malaoshi.top/show_1IX2HLjutY5g.html "hive3.1.x 启动说明")

### 准备数据

https://www.malaoshi.top/show_1IXlN51DbxF.html

# 创建工程

创建maven工程，略

# 添加依赖

修改pom.xml

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

<exclusions>
            <exclusion>
                <groupId>org.apache.logging.log4j</groupId>
                <artifactId>log4j-slf4j-impl</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
</dependencies>
```

# java

可以使用 [DbUtil](https://www.malaoshi.top/show_1EF4t6cK0RGm.html "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