java操作hive查询当前数据库

在Java中操作Hive查询并获取当前数据库，通常需要使用Hive JDBC驱动或Hive Thrift API。首先，你需要添加相应的JAR包到项目的构建路径中。然后，你可以按照以下步骤进行操作：

1. **连接Hive Server**: 创建一个`HiveConnection`或`Configuration`对象，并设置相关的连接信息，如主机名、端口、用户名和密码。

Properties properties = new Properties();
properties.setProperty("javax.jdo.option.ConnectionURL", "jdbc:hive2://<host>:<port>/<default_database>");
properties.setProperty("hive.server2.use.SSL", "false"); // 如果SSL启用，则调整此配置

// 或者使用Configuration，适用于Hadoop环境
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "<hdfs_namenode_uri>");
conf.set("hive.metastore.uris", "thrift://<host>:<port>");

2. **建立连接**:
使用上述配置创建`DriverManager.getConnection()`或`ThriftHiveClient`实例。

String url = properties.getProperty("javax.jdo.option.ConnectionURL");
Connection conn = DriverManager.getConnection(url, properties);
// 或者
TConfiguration config = new TConfiguration(conf);
THriftHiveServer2 server = new ThriftHiveServer2(config);

3. **执行查询**:
创建`Statement`对象，发送SQL查询并获取结果。

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("<your_query_here>");
// 处理结果集，例如遍历每一行
while (rs.next()) {
    System.out.println(rs.getString(1), rs.getString(2)); // 根据列索引获取值
}

4. **关闭资源**:
使用完资源后记得关闭`ResultSet`, `Statement`, 和`Connection`。

rs.close();
stmt.close();
conn.close();