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

简介: 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

相关文章
|
24天前
|
Java 数据库连接 数据库
hibernate正向生成数据库表以及配置——TestStu.java
hibernate正向生成数据库表以及配置——TestStu.java
16 1
|
24天前
|
Java 数据库连接 数据库
hibernate正向生成数据库表以及配置——Teacher.java
hibernate正向生成数据库表以及配置——Teacher.java
11 0
|
24天前
|
Java 数据库连接 数据库
hibernate正向生成数据库表以及配置——Student.java
hibernate正向生成数据库表以及配置——Student.java
10 0
|
27天前
|
SQL 数据库连接 数据库
你不知道ADo.Net中操作数据库的步骤【超详细整理】
你不知道ADo.Net中操作数据库的步骤【超详细整理】
15 0
|
28天前
Servlet使用适配器模式进行增删改查案例(IDeptService.java)
Servlet使用适配器模式进行增删改查案例(IDeptService.java)
13 0
|
28天前
Servlet使用适配器模式进行增删改查案例(EmpDaoImpl.java)
Servlet使用适配器模式进行增删改查案例(EmpDaoImpl.java)
11 0
|
28天前
Servlet使用适配器模式进行增删改查案例(DeptDaoImpl.java)
Servlet使用适配器模式进行增删改查案例(DeptDaoImpl.java)
10 0
|
15天前
|
存储 NoSQL Java
Java数据库编程指南:实现高效数据存储与访问
【4月更文挑战第2天】Java开发者必须掌握数据库编程,尤其是JDBC,它是连接数据库的标准接口。使用Spring JDBC或JPA能简化操作。选择合适的JDBC驱动,如MySQL Connector/J,对性能至关重要。最佳实践包括事务管理、防SQL注入、优化索引和数据库设计。NoSQL数据库如MongoDB也日益重要,Java有对应的驱动支持。理解这些概念和技术是构建高效数据库应用的基础。
Java数据库编程指南:实现高效数据存储与访问
|
28天前
Servlet使用适配器模式进行增删改查案例(IEmpService.java)
Servlet使用适配器模式进行增删改查案例(IEmpService.java)
13 0
|
2天前
|
SQL 缓存 Java
Java数据库连接池:优化数据库访问性能
【4月更文挑战第16天】本文探讨了Java数据库连接池的重要性和优势,它能减少延迟、提高效率并增强系统的可伸缩性和稳定性。通过选择如Apache DBCP、C3P0或HikariCP等连接池技术,并进行正确配置和集成,开发者可以优化数据库访问性能。此外,批处理、缓存、索引优化和SQL调整也是提升性能的有效手段。掌握数据库连接池的使用是优化Java企业级应用的关键。