要在Java代码中添加Hive数据库，你可以使用Java JDBC API与Hive的JDBC驱动程序进行交互。以下是示例代码，演示如何连接到Hive并添加数据库：
import java.sql.*;
public class HiveDatabaseAddition {
private static String driverName = “org.apache.hive.jdbc.HiveDriver”;
private static String connectionString = “jdbc:hive2://localhost:10000/default”;
private static String username = “your_username”;
private static String password = “your_password”;
public static void main(String[] args) {
try {
// 加载Hive的JDBC驱动程序
Class.forName(driverName);
// 建立连接
Connection connection = DriverManager.getConnection(connectionString, username,
password);
// 创建一个Statement对象
Statement statement = connection.createStatement();
// 执行添加数据库的SQL语句
String databaseName = “your_database_name”;
String addDatabaseQuery = "CREATE DATABASE " + databaseName;
statement.execute(addDatabaseQuery);
System.out.println(“Database added successfully.”);
// 关闭连接
statement.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
在以上代码中，你需要将your_username和your_password替换为你的Hive用户名和密码，your_database_name替换为你想要添加的数据库名称。
请确保你已经将Hive的JDBC驱动程序添加到你的Java项目的类路径中。你可以从Apache Hive的官方网站下载并获取JDBC驱动程序。
此外，还需要确保HiveServer2正在运行，并且连接字符串jdbc:hive2://localhost:10000/default中的主机和端口与你的HiveServer2的设置一致。
