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;
可以看到,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;
本条命令是删除表的,不在做详细讲解。
上一篇: LeetCode -- 150. 逆波兰式表达式求值
下一篇: 就是一流医院