javaでHiveデータベースを追加する方法

2年 ago
蓮, 翼
1 minute

HiveデータベースをJavaコードに追加するには、HiveのJDBCドライバーを介してJavaのJDBC APIを利用します。以下は、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 プロジェクトのクラスパスに追加されていることを確認してください。JDBC ドライバーは、Apache Hive の公式サイトからダウンロードして取得できます。また、HiveServer2 が実行中で、接続文字列 jdbc:hive2://localhost:10000/default のホストとポートが HiveServer2 の設定と一致していることも確認する必要があります。

        


        
        

			        

    


	



		            	                        

        


    

















  
    bannerAds