Hive 变更表

本章介绍如何更改表的属性，例如更改表名、更改列名、添加列以及删除或替换列。

更改表语句

它用于更改 Hive 中的表。

语法

该语句根据我们希望在表中修改的属性采用以下任何语法。

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

重命名为... 语句

以下查询将表重命名为 employee to emp .

hive> ALTER TABLE employee RENAME TO emp;

JDBC程序

重命名表的 JDBC 程序如下。

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 {
   
        // 注册驱动并创建驱动实例
        Class.forName(driverName);
      
        // 获取连接
        Connection con = DriverManager.getConnection("jdbc:hive:// localhost:10000/userdb", "", "");
      
        // 创建语句
        Statement stmt = con.createStatement();
      
        // 执行语句
        stmt.executeQuery("ALTER TABLE employee RENAME TO emp;");
        System.out.println("Table Renamed Successfully");
        con.close();
    }
}

将程序保存在名为 HiveAlterRenameTo.java 的文件中。使用以下命令编译并执行该程序。

$ javac HiveAlterRenameTo.java
$ java HiveAlterRenameTo

输出:

Table renamed successfully.

变更声明

下表包含以下字段 employee 表，它显示要更改的字段(粗体)。

以下查询使用上述数据重命名列名和列数据类型：

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

JDBC程序

下面给出的是更改列的 JDBC 程序。

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 {
   
        // 注册驱动并创建驱动实例
        Class.forName(driverName);
      
        // 获取连接
        Connection con = DriverManager.getConnection("jdbc:hive:// localhost:10000/userdb", "", "");
      
        // 创建语句
        Statement stmt = con.createStatement();
      
        // 执行语句
        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();
    }
}

将程序保存在名为 HiveAlterChangeColumn.java 的文件中。使用以下命令编译并执行该程序。

$ javac HiveAlterChangeColumn.java
$ java HiveAlterChangeColumn

输出:

Change column successful.

添加列语句

以下查询将名为 dept 的列添加到员工表中。

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

JDBC程序

下面给出了向表中添加列的 JDBC 程序。

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 {
   
        // 注册驱动并创建驱动实例
        Class.forName(driverName);

        // 获取连接
        Connection con = DriverManager.getConnection("jdbc:hive:// localhost:10000/userdb", "", "");

        // 创建语句
        Statement stmt = con.createStatement();
      
        // 执行语句
        stmt.executeQuery("ALTER TABLE employee ADD COLUMNS " + " (dept STRING COMMENT 'Department name');");
        System.out.prinln("Add column successful.");
      
        con.close();
    }
}

将程序保存在名为 HiveAlterAddColumn.java 的文件中。使用以下命令编译并执行该程序。

$ javac HiveAlterAddColumn.java
$ java HiveAlterAddColumn

输出:

Add column successful.

替换语句

以下查询从 employee 表并将其替换为 emp and name columns:

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

JDBC程序

下面给出的是要替换的 JDBC 程序 eid 列 empid and ename 列 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 {
   
        // 注册驱动并创建驱动实例
        Class.forName(driverName);
      
        // 获取连接
        Connection con = DriverManager.getConnection("jdbc:hive:// localhost:10000/userdb", "", "");
      
        // 创建语句
        Statement stmt = con.createStatement();
      
        // 执行语句
        stmt.executeQuery("ALTER TABLE employee REPLACE COLUMNS "
            +" (eid INT empid Int,"
            +" ename STRING name String);");
         
        System.out.println(" Replace column successful");
        con.close();
    }
}

将程序保存在名为 HiveAlterReplaceColumn.java 的文件中。使用以下命令编译并执行该程序。

$ javac HiveAlterReplaceColumn.java
$ java HiveAlterReplaceColumn

输出:

Replace column successful.