基于java API 实现hive读写操作实验详细步骤

基于Java API实现Hive读写操作通常涉及Apache Hive JDBC驱动，以下是基本的实验步骤：

1. **添加依赖**:
首先，在你的项目中引入Hive JDBC驱动（hadoop-hive-jdbc.jar）。如果你使用Maven，可以在pom.xml中添加以下依赖：

   <dependency>
       <groupId>org.apache.hive</groupId>
       <artifactId>hive-jdbc</artifactId>
       <version>版本号</version>
   </dependency>

替换`版本号`为你实际使用的Hive版本。

2. **配置环境**:
配置`HIVE_HOME`环境变量指向Hive安装目录，这将帮助JDBC找到必要的库文件。

3. **加载驱动**:
在Java代码中，通过Class.forName()加载Hive JDBC驱动：

   Class.forName("org.apache.hive.jdbc.HiveDriver");

4. **创建连接**:
使用`DriverManager.getConnection()`函数创建到Hive的连接，需要提供URL（包括主机名、端口、仓库路径等）、用户名和密码：

   String url = "jdbc:hive2://localhost:10000/default"; // 根据实际情况修改
   String username = "your_username";
   String password = "your_password";
   Connection conn = DriverManager.getConnection(url, username, password);

5. **执行查询**:
使用`Statement`或`PreparedStatement`执行SQL查询。例如，获取`emp_info_1`表的数据：

   Statement stmt = conn.createStatement();
   ResultSet rs = stmt.executeQuery("SELECT * FROM emp_info_1");
   
   while (rs.next()) {
       System.out.println(rs.getInt("id") + ", " + rs.getString("name") + ", " + rs.getInt("age"));
   }

6. **执行插入操作**:
对于插入操作，可以创建PreparedStatement，设置值，然后调用`executeUpdate()`方法：

   PreparedStatement insertStmt = conn.prepareStatement("INSERT INTO emp_info_1 VALUES (?, ?, ?)");
   insertStmt.setInt(1, 1);
   insertStmt.setString(2, "John Doe");
   insertStmt.setInt(3, 30);
   int rowsInserted = insertStmt.executeUpdate();

7. **关闭资源**:
执行完操作后，记得关闭`ResultSet`, `Statement`以及`Connection`。

8. **异常处理**:
考虑可能遇到的错误和异常，如网络问题、权限不足等，并进行适当的处理。