设为首页 加入收藏

TOP

Hive修改数据表
2018-12-07 01:26:46 】 浏览:16
Tags:Hive 修改 数据
版权声明:本文为博主原创文章,转载请注明出处 https://blog.csdn.net/yidu_fanchen/article/details/77683479

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;

这里写图片描述
可以看到,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里面进行查看验证,如图:
这里写图片描述

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

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

执行语句,查询结果,如图所示:
这里写图片描述

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

执行代码,查看运行结果:
这里写图片描述
5、添加一列:

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

执行命令,结果如下:
这里写图片描述
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()

执行代码,查看结果如图所示:
这里写图片描述
7、删除表
DROP TABLE [IF EXISTS] table_name;
本条命令是删除表的,不在做详细讲解。


编程开发网
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Hive正则表达式对数据过滤 下一篇Hive调用python脚本实现数据清洗..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

array(4) { ["type"]=> int(8) ["message"]=> string(24) "Undefined variable: jobs" ["file"]=> string(32) "/mnt/wp/cppentry/do/bencandy.php" ["line"]=> int(214) }