java链接hive数据库实现增删改查操作

要在Java中连接Hive数据库并实现增删改查操作，需要使用Hive JDBC驱动程序。

首先，确保已经安装了Hive，并且Hadoop集群正在运行。

然后，根据Hive版本下载相应的Hive JDBC驱动程序。可以从Apache Hive官方网站下载。

接下来，编写Java代码来连接Hive数据库和执行增删改查操作。

以下是一个示例代码：

import java.sql.*;

public class HiveExample {
  
  public static void main(String[] args) {
    try {
      // 连接Hive数据库
      Class.forName("org.apache.hive.jdbc.HiveDriver");
      Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "", "");

      // 创建Statement
      Statement stmt = con.createStatement();

      // 创建表
      String createTableQuery = "CREATE TABLE IF NOT EXISTS employee (id int, name string, age int) row format delimited fields terminated by ',' stored as textfile";
      stmt.execute(createTableQuery);

      // 插入数据
      String insertQuery = "INSERT INTO employee VALUES (1, 'John', 25)";
      stmt.executeUpdate(insertQuery);

      // 查询数据
      String selectQuery = "SELECT * FROM employee";
      ResultSet rs = stmt.executeQuery(selectQuery);
      while (rs.next()) {
        System.out.println(rs.getInt("id") + ", " + rs.getString("name") + ", " + rs.getInt("age"));
      }

      // 更新数据
      String updateQuery = "UPDATE employee SET age = 30 WHERE id = 1";
      stmt.executeUpdate(updateQuery);

      // 删除数据
      String deleteQuery = "DELETE FROM employee WHERE id = 1";
      stmt.executeUpdate(deleteQuery);

      con.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

此示例代码中，首先使用Class.forName方法加载Hive驱动程序，并使用DriverManager.getConnection方法连接Hive数据库。

然后，创建Statement对象，并使用execute方法执行DDL语句创建表。

接下来，使用executeUpdate方法执行DML语句插入、更新和删除数据。

最后，使用executeQuery方法执行查询语句，并使用ResultSet对象遍历结果集并输出查询结果。

请注意，此示例代码中的连接字符串jdbc:hive2://localhost:10000/default可以根据实际情况进行更改，以匹配Hive服务器的主机和端口。

另外，还可以在连接字符串中提供用户名和密码以进行身份验证，例如：jdbc:hive2://localhost:10000/default;user=admin;password=123456。