Hive - Zmień tabelę

W tym rozdziale wyjaśniono, jak zmienić atrybuty tabeli, takie jak zmiana nazwy tabeli, zmiana nazw kolumn, dodawanie kolumn oraz usuwanie lub zastępowanie kolumn.

Alter Table Statement

Służy do zmiany tabeli w Hive.

Składnia

Instrukcja przyjmuje dowolną z poniższych składni w oparciu o atrybuty, które chcemy zmodyfikować w tabeli.

ALTER TABLE name RENAME TO new_name
ALTER TABLE name ADD COLUMNS (col_spec[, col_spec ...])
ALTER TABLE name DROP [COLUMN] column_name
ALTER TABLE name CHANGE column_name new_name new_type
ALTER TABLE name REPLACE COLUMNS (col_spec[, col_spec ...])

Rename To… Statement

Następujące zapytanie zmienia nazwę tabeli z employee do emp.

hive> ALTER TABLE employee RENAME TO emp;

Program JDBC

Program JDBC do zmiany nazwy tabeli jest następujący.

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

public class HiveAlterRenameTo {
   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/userdb", "", "");
      
      // create statement
      Statement stmt = con.createStatement();
      
      // execute statement
      stmt.executeQuery("ALTER TABLE employee RENAME TO emp;");
      System.out.println("Table Renamed Successfully");
      con.close();
   }
}

Zapisz program w pliku o nazwie HiveAlterRenameTo.java. Użyj następujących poleceń, aby skompilować i wykonać ten program.

$ javac HiveAlterRenameTo.java
$ java HiveAlterRenameTo

Wynik:

Table renamed successfully.

Zmiana oświadczenia

Poniższa tabela zawiera pola employee tabela i pokazuje pola do zmiany (pogrubione).

Nazwa pola	Konwertuj z typu danych	Zmień nazwę pola	Konwertuj na typ danych
eid	int	eid	int
name	Strunowy	ename	Strunowy
wynagrodzenie	Float	wynagrodzenie	Double
Przeznaczenie	Strunowy	Przeznaczenie	Strunowy

Poniższe zapytania zmieniają nazwę kolumny i typ danych kolumny przy użyciu powyższych danych:

hive> ALTER TABLE employee CHANGE name ename String;
hive> ALTER TABLE employee CHANGE salary salary Double;

Program JDBC

Poniżej podano program JDBC do zmiany kolumny.

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

public class HiveAlterChangeColumn {
   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/userdb", "", "");
      
      // create statement
      Statement stmt = con.createStatement();
      
      // execute statement
      stmt.executeQuery("ALTER TABLE employee CHANGE name ename String;");
      stmt.executeQuery("ALTER TABLE employee CHANGE salary salary Double;");
      
      System.out.println("Change column successful.");
      con.close();
   }
}

Zapisz program w pliku o nazwie HiveAlterChangeColumn.java. Użyj następujących poleceń, aby skompilować i wykonać ten program.

$ javac HiveAlterChangeColumn.java
$ java HiveAlterChangeColumn

Wynik:

Change column successful.

Add Columns Statement

Następujące zapytanie dodaje kolumnę o nazwie dział do tabeli pracowników.

hive> ALTER TABLE employee ADD COLUMNS ( 
dept STRING COMMENT 'Department name');

Program JDBC

Program JDBC do dodawania kolumny do tabeli podano poniżej.

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

public class HiveAlterAddColumn {
   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/userdb", "", "");

      // create statement
      Statement stmt = con.createStatement();
      
      // execute statement
      stmt.executeQuery("ALTER TABLE employee ADD COLUMNS " + " (dept STRING COMMENT 'Department name');");
      System.out.prinln("Add column successful.");
      
      con.close();
   }
}

Zapisz program w pliku o nazwie HiveAlterAddColumn.java. Użyj następujących poleceń, aby skompilować i wykonać ten program.

$ javac HiveAlterAddColumn.java
$ java HiveAlterAddColumn

Wynik:

Add column successful.

Zastąp instrukcję

Następujące zapytanie usuwa wszystkie kolumny z employee table i zastępuje go emp i name kolumny:

hive> ALTER TABLE employee REPLACE COLUMNS ( 
eid INT empid Int, 
ename STRING name String);

Program JDBC

Poniżej podano program JDBC do wymiany eid kolumna z empid i ename kolumna z name.

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

public class HiveAlterReplaceColumn {

   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/userdb", "", "");
      
      // create statement
      Statement stmt = con.createStatement();
      
      // execute statement
      stmt.executeQuery("ALTER TABLE employee REPLACE COLUMNS "
         +" (eid INT empid Int,"
         +" ename STRING name String);");
         
      System.out.println(" Replace column successful");
      con.close();
   }
}

Zapisz program w pliku o nazwie HiveAlterReplaceColumn.java. Użyj następujących poleceń, aby skompilować i wykonać ten program.

$ javac HiveAlterReplaceColumn.java
$ java HiveAlterReplaceColumn

Wynik:

Replace column successful.