欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Hive修改数据表

程序员文章站 2022-04-04 09:52:24
...

Alter Table命令用来修改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 ...])

1、重命名表命令:

ALTER TABLE employee RENAME TO emp;

Hive修改数据表
可以看到,employee表已经被改成了emp表。
2、使用python操作hive,修改表名,代码如下:

    # coding:utf-8
    from pyhive import hive
    from TCLIService.ttypes import TOperationState

    # 打开hive连接
    hiveConn = hive.connect(host='192.168.83.135',port=11111,username='hadoop')
    cursor = hiveConn.cursor()

    # 执行sql语句
    sql = ''' USE userdbbypy '''
    cursor.execute(sql, async=True)
    # 得到执行语句的状态
    status = cursor.poll().operationState
    print "status:",status

    sql = ''' ALTER TABLE employee RENAME TO emp '''
    cursor.execute(sql, async=True)

    # 得到执行语句的状态
    status = cursor.poll().operationState
    print "status:",status

    # 关闭hive连接
    cursor.close()
    hiveConn.close()

执行程序,然后去beeline里面进行查看验证,如图:
Hive修改数据表

3、更改表的字段和类型:

ALTER TABLE emp CHANGE name ename String;
ALTER TABLE emp CHANGE salary salary DOUBLE;

执行语句,查询结果,如图所示:
Hive修改数据表

4、使用python操作hive,修改emp表的字段名和字段类型:

    # coding:utf-8
    from pyhive import hive
    from TCLIService.ttypes import TOperationState

    # 打开hive连接
    hiveConn = hive.connect(host='192.168.83.135',port=11111,username='hadoop',database='userdbbypy')
    cursor = hiveConn.cursor()

    sql = '''   ALTER TABLE emp CHANGE name ename String '''
    cursor.execute(sql, async=True)

    # 得到执行语句的状态
    status = cursor.poll().operationState
    print "status:",status

    sql = ''' ALTER TABLE emp CHANGE salary salary DOUBLE '''
    cursor.execute(sql, async=True)

    # 得到执行语句的状态
    status = cursor.poll().operationState
    print "status:",status

    # 关闭hive连接
    cursor.close()
    hiveConn.close()

执行代码,查看运行结果:
Hive修改数据表
5、添加一列:

ALTER TABLE emp ADD COLUMNS(dept String COMMENT 'Department name');

执行命令,结果如下:
Hive修改数据表
6、使用python操作hive,为emp表添加一列dept,代码如下:

    # coding:utf-8
    from pyhive import hive
    from TCLIService.ttypes import TOperationState

    # 打开hive连接
    hiveConn = hive.connect(host='192.168.83.135',port=11111,username='hadoop',database='userdbbypy')
    cursor = hiveConn.cursor()

    sql = ''' ALTER TABLE emp ADD COLUMNS(dept String COMMENT 'Department name') '''
    cursor.execute(sql, async=True)

    # 得到执行语句的状态
    status = cursor.poll().operationState
    print "status:",status

    # 关闭hive连接
    cursor.close()
    hiveConn.close()

执行代码,查看结果如图所示:
Hive修改数据表
7、删除表
DROP TABLE [IF EXISTS] table_name;
本条命令是删除表的,不在做详细讲解。

相关标签: hive 数据库