Java程序如何访问Hive数据库 |21xrx.com

Java程序如何访问Hive数据库

2023-06-19 05:24:38 深夜i 26 0

Java程序访问 Hive数据库

Hive是基于Hadoop的数据仓库工具，允许用户将结构化数据映射到Hadoop上并提供查询语言HQL（类似于SQL）。Java程序可以通过JDBC或Hive客户端API访问Hive数据库。下面演示使用JDBC的方式访问Hive。

1. 准备工作

首先需要确保Hadoop和Hive已经安装并启动，进入Hive的命令行终端，创建一个名为“mytable”的表，如下所示：

CREATE TABLE mytable (
 id INT,
 name STRING
);

2. 编写Java程序

在Java项目中使用Maven依赖，引入以下依赖关系：

org.apache.hive hive-jdbc 3.1.1 org.apache.hadoop hadoop-common 3.2.1

编写Java代码访问Hive数据库，查询“mytable”表中的数据：

import java.sql.*;
public class AccessHive {
  public static void main(String[] args) throws SQLException, ClassNotFoundException {
    Class.forName("org.apache.hive.jdbc.HiveDriver");
    Connection connection = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "hive", "");
    Statement statement = connection.createStatement();
    ResultSet resultSet = statement.executeQuery("SELECT * FROM mytable");
    while (resultSet.next()) {
      System.out.println(resultSet.getInt("id") + "\t" + resultSet.getString("name"));
    }
    resultSet.close();
    statement.close();
    connection.close();
  }
}

3. 运行程序

连接到Hive的JDBC URL包含三个部分：协议，主机和端口以及数据库名。一般情况下，端口为10000，数据库名为Hive的默认数据库“default”。

将Java程序打包为JAR文件，然后使用如下命令运行：

java -cp /path/to/jar:/path/to/hive-jdbc.jar AccessHive

4. 总结

通过以上步骤，Java程序就可以成功访问Hive数据库，查询其中的表数据。Hive提供的JDBC驱动程序和API使得Java程序更加灵活便捷地操作和处理Hive数据。

上一篇: idea打包java可执行jar包

下一篇: 用Java编写小游戏，轻松学习语言

评论区

相似文章