jdbc连接hive数据库

JDBC连接Hive数据库，是一种基于Java开发的数据库客户端连接方式。它是一个应用程序接口，允许Java程序通过标准的JDBC API来访问Hive数据库，实现数据的读写操作。

以下是连接Hive数据库的步骤：

1. 配置Hive服务器

在连接Hive数据库之前，首先需要确保已经安装好了Hive服务器，并在Hive配置文件中指定了Hive服务端口，例如：

hive.server2.thrift.port=10000

2. 导入Hive JDBC驱动

在Java项目中导入Hive JDBC驱动，例如：

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

3. 建立JDBC连接

通过JDBC API的getConnection方法创建与Hive数据库的连接：

Connection connection = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "", "");

其中，jdbc:hive2表示使用Hive2进行连接，localhost:10000为Hive服务器所在主机IP和端口号，default为数据库名，最后两个参数分别是Hive服务器的用户名和密码。

4. 执行SQL操作

通过JDBC API的Statement接口、PreparedStatement接口等来执行Hive SQL语句操作：

查询数据：

Statement statement = connection.createStatement();
ResultSet rs = statement.executeQuery("SELECT * FROM my_table WHERE id > 100");
while (rs.next()) {
    int id = rs.getInt("id");
    String name = rs.getString("name");
    // ...
}

更新数据：

PreparedStatement pstmt = connection.prepareStatement("UPDATE my_table SET name = ? WHERE id = ?");
pstmt.setString(1, "Lucy");
pstmt.setInt(2, 101);
pstmt.executeUpdate();

5. 断开连接

在使用完毕后，通过JDBC API的close方法关闭与Hive数据库的连接：

connection.close();

需要注意的是，JDBC连接Hive数据库需要保证Hive服务及JDBC客户端的版本一致性，否则可能会出现连接失败等问题。此外，在操作过程中也需要注意线程安全等问题。

示例代码：

import java.sql.*;

public class JDBCHiveDemo {
    public static void main(String[] args) {
        try {
            // 导入驱动
            Class.forName("org.apache.hive.jdbc.HiveDriver");

            // 建立连接
            Connection connection = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "", "");

            // 查询数据