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数据。

相似文章

友情链接
• 网站定制开发
• 帮你发
• 小蓄群站获客
• 雅圣洁家政