springboot项目连hive 集群配置

在Spring Boot项目中连接Hive集群，你可以按照以下步骤进行配置：

1. 添加Hive依赖：在项目的pom.xml文件中添加Hive相关的依赖，例如：

<dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>hive-jdbc</artifactId>
    <version>3.1.2</version>
</dependency>

2. 配置Hive连接信息：在项目的配置文件（如application.properties或application.yml）中添加Hive连接的相关配置，包括Hive的JDBC URL、用户名和密码等，例如：

spring.datasource.url=jdbc:hive2://hive-server:10000/default
spring.datasource.username=hiveuser
spring.datasource.password=hivepassword

3. 创建Hive连接：在代码中创建Hive连接，可以使用JDBC来实现。示例代码如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class HiveConnectionUtil {
    public static Connection getConnection() throws SQLException {
        String url = "jdbc:hive2://hive-server:10000/default";
        String username = "hiveuser";
        String password = "hivepassword";
        
        return DriverManager.getConnection(url, username, password);
    }
}

4. 使用Hive连接：通过获取到的Hive连接，可以执行Hive的SQL语句或者操作Hive表等。示例代码如下：

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class HiveExample {
    public static void main(String[] args) {
        try {
            Connection connection = HiveConnectionUtil.getConnection();
            Statement statement = connection.createStatement();
            
            // 执行Hive查询
            ResultSet resultSet = statement.executeQuery("SELECT * FROM my_table");
            
            // 处理查询结果
            while (resultSet.next()) {
                // 处理每一行数据
                String column1 = resultSet.getString("column1");
                int column2 = resultSet.getInt("column2");
                // ...
            }
            
            // 关闭连接
            resultSet.close();
            statement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

这样，你就可以在Spring Boot项目中成功连接Hive集群并进行操作了。