Colmeia - Alterar Tabela

Este capítulo explica como alterar os atributos de uma tabela, como alterar o nome da tabela, alterar os nomes das colunas, adicionar colunas e excluir ou substituir colunas.

Alterar declaração da tabela

É usado para alterar uma tabela no Hive.

Sintaxe

A instrução assume qualquer uma das seguintes sintaxes com base nos atributos que desejamos modificar em uma tabela.

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 ...])

Renomear para… Declaração

A consulta a seguir renomeia a tabela de employee para emp.

hive> ALTER TABLE employee RENAME TO emp;

Programa JDBC

O programa JDBC para renomear uma tabela é o seguinte.

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

Salve o programa em um arquivo denominado HiveAlterRenameTo.java. Use os seguintes comandos para compilar e executar este programa.

$ javac HiveAlterRenameTo.java
$ java HiveAlterRenameTo

Resultado:

Table renamed successfully.

Declaração de mudança

A tabela a seguir contém os campos de employee tabela e mostra os campos a serem alterados (em negrito).

As consultas a seguir renomeiam o nome da coluna e o tipo de dados da coluna usando os dados acima:

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

Programa JDBC

A seguir está o programa JDBC para alterar uma coluna.

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

Salve o programa em um arquivo denominado HiveAlterChangeColumn.java. Use os seguintes comandos para compilar e executar este programa.

$ javac HiveAlterChangeColumn.java
$ java HiveAlterChangeColumn

Resultado:

Change column successful.

Adicionar declaração de colunas

A consulta a seguir adiciona uma coluna chamada dept à tabela de funcionários.

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

Programa JDBC

O programa JDBC para adicionar uma coluna a uma tabela é fornecido abaixo.

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

Salve o programa em um arquivo denominado HiveAlterAddColumn.java. Use os seguintes comandos para compilar e executar este programa.

$ javac HiveAlterAddColumn.java
$ java HiveAlterAddColumn

Resultado:

Add column successful.

Substituir Declaração

A consulta a seguir exclui todas as colunas do employee mesa e substitui-a por emp e name colunas:

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

Programa JDBC

Abaixo está o programa JDBC para substituir eid coluna com empid e ename coluna com 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();
   }
}

Salve o programa em um arquivo denominado HiveAlterReplaceColumn.java. Use os seguintes comandos para compilar e executar este programa.

$ javac HiveAlterReplaceColumn.java
$ java HiveAlterReplaceColumn

Resultado:

Replace column successful.