Hive - Veritabanı Oluştur

Hive, yapılandırılmış verileri analiz etmek için veritabanları ve tabloları tanımlayabilen bir veritabanı teknolojisidir. Yapılandırılmış veri analizinin teması, verileri tablo şeklinde depolamak ve analiz etmek için sorguları iletmektir. Bu bölüm, Hive veritabanının nasıl oluşturulacağını açıklar. Hive, adında varsayılan bir veritabanı içerirdefault.

Veritabanı İfadesi Oluşturun

Create Database, Hive'da bir veritabanı oluşturmak için kullanılan bir ifadedir. Hive'daki bir veritabanı,namespaceveya bir dizi tablo. syntax bu ifade için aşağıdaki gibidir:

CREATE DATABASE|SCHEMA [IF NOT EXISTS] <database name>

Burada, IF NOT EXISTS, kullanıcıya aynı ada sahip bir veritabanının zaten mevcut olduğunu bildiren isteğe bağlı bir cümledir. Bu komutta DATABASE yerine SCHEMA kullanabiliriz. Aşağıdaki sorgu, adlı bir veritabanı oluşturmak için yürütülür.userdb:

hive> CREATE DATABASE [IF NOT EXISTS] userdb;

or

hive> CREATE SCHEMA userdb;

Aşağıdaki sorgu, bir veritabanları listesini doğrulamak için kullanılır:

hive> SHOW DATABASES;
default
userdb

JDBC Programı

Veritabanı oluşturmaya yönelik JDBC programı aşağıda verilmiştir.

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

public class HiveCreateDb {
   private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
   
   public static void main(String[] args) throws SQLException {
      // Register driver and create driver instance
   
      Class.forName(driverName);
      // get connection
      
      Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/default", "", "");
      Statement stmt = con.createStatement();
      
      stmt.executeQuery("CREATE DATABASE userdb");
      System.out.println(“Database userdb created successfully.”);
      
      con.close();
   }
}

Programı HiveCreateDb.java adlı bir dosyaya kaydedin. Bu programı derlemek ve çalıştırmak için aşağıdaki komutlar kullanılır.

$ javac HiveCreateDb.java
$ java HiveCreateDb

Çıktı:

Database userdb created successfully.