| set hive.support.concurrency=true; |
| set hive.txn.manager=org.apache.hadoop.hive.ql.lockmgr.DbTxnManager; |
| set hive.acid.direct.insert.enabled=true; |
| |
| -- SORT_QUERY_RESULTS |
| |
| drop table if exists analyze_acid_table; |
| create table analyze_acid_table (id int) stored as orc tblproperties('transactional'='true'); |
| |
| explain analyze insert into analyze_acid_table values (1),(2),(3),(4); |
| select * from analyze_acid_table; |
| |
| insert into analyze_acid_table values (1),(2),(3),(4); |
| select * from analyze_acid_table; |
| |
| explain analyze update analyze_acid_table set id=11 where id=1; |
| select * from analyze_acid_table; |
| |
| update analyze_acid_table set id=22 where id=2; |
| select * from analyze_acid_table; |
| |
| explain analyze delete from analyze_acid_table where id=3; |
| select * from analyze_acid_table; |
| |
| delete from analyze_acid_table where id=1; |
| select * from analyze_acid_table; |
| |
| drop table if exists analyze_acid_table; |
| |
| |
| create table tmp_table (a int, b int); |
| insert into tmp_table values (1, 1), (2, 1), (3, 2), (4, 3), (5, 3), (6, 3); |
| |
| drop table if exists analyze_part_table; |
| create table analyze_part_table (a int) partitioned by (b int) stored as orc tblproperties('transactional'='true'); |
| |
| explain analyze insert into analyze_part_table select * from tmp_table; |
| select * from analyze_part_table; |
| show partitions analyze_part_table; |
| |
| insert into analyze_part_table select * from tmp_table; |
| select * from analyze_part_table; |
| show partitions analyze_part_table; |
| |
| explain analyze update analyze_part_table set a=11 where b=3; |
| select * from analyze_part_table; |
| |
| explain analyze delete from analyze_part_table where b=1; |
| select * from analyze_part_table; |
| show partitions analyze_part_table; |
| |
| update analyze_part_table set a=22 where b=3; |
| select * from analyze_part_table; |
| |
| delete from analyze_part_table where b=1; |
| select * from analyze_part_table; |
| show partitions analyze_part_table; |
| drop table if exists analyze_part_table; |
| |
| |
| |
| set hive.acid.direct.insert.enabled=false; |
| |
| drop table if exists analyze_acid_table; |
| create table analyze_acid_table (id int) stored as orc tblproperties('transactional'='true'); |
| |
| explain analyze insert into analyze_acid_table values (1),(2),(3),(4); |
| select * from analyze_acid_table; |
| |
| insert into analyze_acid_table values (1),(2),(3),(4); |
| select * from analyze_acid_table; |
| |
| explain analyze update analyze_acid_table set id=11 where id=1; |
| select * from analyze_acid_table; |
| |
| update analyze_acid_table set id=22 where id=2; |
| select * from analyze_acid_table; |
| |
| explain analyze delete from analyze_acid_table where id=3; |
| select * from analyze_acid_table; |
| |
| delete from analyze_acid_table where id=1; |
| select * from analyze_acid_table; |
| |
| drop table if exists analyze_acid_table; |
| |
| |
| drop table if exists analyze_part_table; |
| create table analyze_part_table (a int) partitioned by (b int) stored as orc tblproperties('transactional'='true'); |
| |
| explain analyze insert into analyze_part_table select * from tmp_table; |
| select * from analyze_part_table; |
| show partitions analyze_part_table; |
| |
| insert into analyze_part_table select * from tmp_table; |
| select * from analyze_part_table; |
| show partitions analyze_part_table; |
| |
| explain analyze update analyze_part_table set a=11 where b=3; |
| select * from analyze_part_table; |
| |
| explain analyze delete from analyze_part_table where b=1; |
| select * from analyze_part_table; |
| show partitions analyze_part_table; |
| |
| update analyze_part_table set a=22 where b=3; |
| select * from analyze_part_table; |
| |
| delete from analyze_part_table where b=1; |
| select * from analyze_part_table; |
| show partitions analyze_part_table; |
| drop table if exists analyze_part_table; |
| drop table tmp_table; |