hive> select * from student;
OK10 zhao
12NULLTimetaken:0.134 seconds, Fetched:2 row(s)
INSERTOVERWRITE local directory '/hadoop/asiainfo/zhaopy/hivetest' select * from student;
------------------------省略一堆输出------------------
[ochadoop@server7 hivetest]$ ls
000000_0.snappy 000001_0.snappy
[ochadoop@server7 hivetest]$ cat 000000_0.snappy
10zhao
[ochadoop@server7 hivetest]$ cat 000001_0.snappy
12\N
通过insert values插入数据
命令格式
Standard Syntax:
INSERT INTO TABLE tablename [PARTITION (partcol1[=val1], partcol2[=val2] ...)] VALUES values_row [, values_row ...]
Where values_row is:
( value [, value ...] )
where a value is either null or any valid SQL literal
语句说明
不同于标准SQL,此处不支持插入部分列,即,所有的列都需要插入。缺失的列需要用null代替。
分区:以后补充。
使用例子
hive> select * from student;
OK
10 zhao
12NULLTime taken: 0.137 seconds, Fetched: 2 row(s)
hive> insert into table student values (50, null);
----------------省略一堆输出
hive> select * from student;
OK
10 zhao
12NULL50NULLTime taken: 0.126 seconds, Fetched: 3 row(s)
删
命令格式
Standard Syntax:
DELETEFROM tablename [WHERE expression]
语句说明
该语句在hive0.14之后可用,只能用于支持ACID的表中。
使用例子
与普通SQL相同。
改
命令格式
Standard Syntax:
UPDATE tablename SET column = value [, column = value ...] [WHERE expression]
语句说明
该语句只能用于支持ACID的表中
Bucketing 列和Partitioning 列无法被更新。
该语句可用在hive0.14版本 。
使用例子
与普通SQL相同。
混合操作
所谓混合操作,就是将以上语句写入一个语句中,加入条件进行操作
语句格式
Standard Syntax:
MERGEINTO <target table> AS T USING <source expression/table> AS S
ON <boolean expression1>
WHENMATCHED [AND <boolean expression2>] THENUPDATESET <set clause list>
WHENMATCHED [AND <boolean expression3>] THENDELETEWHENNOTMATCHED [AND <boolean expression4>] THENINSERTVALUES<value list>
语句说明
该语句只能用于支持ACID的表中
Bucketing 列和Partitioning 列无法被更新。
该语句可用在hive 2.2版本 。
使用例子
MERGEINTO merge_data.transactions AS T
USING merge_data.merge_source AS S
ON T.ID = S.ID and T.tran_date = S.tran_date
WHENMATCHEDAND (T.TranValue != S.TranValue AND S.TranValue ISNOTNULL) THENUPDATESET TranValue = S.TranValue, last_update_user = 'merge_update'WHENMATCHEDAND S.TranValue ISNULLTHENDELETEWHENNOTMATCHEDTHENINSERTVALUES (S.ID, S.TranValue, 'merge_insert', S.tran_date);