共計 1439 個字符,預計需要花費 4 分鐘才能閱讀完成。
要在 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 的設置一致。
丸趣 TV 網 – 提供最優質的資源集合!