Hive - Datenbank erstellen

Hive ist eine Datenbanktechnologie, die Datenbanken und Tabellen definieren kann, um strukturierte Daten zu analysieren. Das Thema für die strukturierte Datenanalyse besteht darin, die Daten tabellarisch zu speichern und Abfragen zur Analyse zu übergeben. In diesem Kapitel wird erläutert, wie Sie eine Hive-Datenbank erstellen. Hive enthält eine Standarddatenbank mit dem Namendefault.

Datenbankanweisung erstellen

Datenbank erstellen ist eine Anweisung zum Erstellen einer Datenbank in Hive. Eine Datenbank in Hive ist anamespaceoder eine Sammlung von Tabellen. Dassyntax für diese Aussage ist wie folgt:

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

Hier ist IF NOT EXISTS eine optionale Klausel, die den Benutzer darüber informiert, dass bereits eine Datenbank mit demselben Namen vorhanden ist. In diesem Befehl können wir SCHEMA anstelle von DATABASE verwenden. Die folgende Abfrage wird ausgeführt, um eine Datenbank mit dem Namen zu erstellenuserdb::

hive> CREATE DATABASE [IF NOT EXISTS] userdb;

or

hive> CREATE SCHEMA userdb;

Die folgende Abfrage wird zum Überprüfen einer Datenbankliste verwendet:

hive> SHOW DATABASES;
default
userdb

JDBC-Programm

Das JDBC-Programm zum Erstellen einer Datenbank ist unten angegeben.

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();
   }
}

Speichern Sie das Programm in einer Datei mit dem Namen HiveCreateDb.java. Die folgenden Befehle werden zum Kompilieren und Ausführen dieses Programms verwendet.

$ javac HiveCreateDb.java
$ java HiveCreateDb

Ausgabe:

Database userdb created successfully.