Skip to content

Commit 86540e9

Browse files
tuhaihetuhaihe
committed
Update schedule0 tests
1 parent 6e13a69 commit 86540e9

26 files changed

Lines changed: 2626 additions & 64 deletions

‎src/test/binary_swap/expected/upgrading_compatibility/create_index.out‎

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
-- Create Indexes
2+
-- B-tree
3+
CREATE INDEX btree_idx_sales_heap_1 ON sales_heap(product_id);
4+
CREATE INDEX btree_idx_sales_heap_2 ON sales_heap(customer_name);
5+
CREATE INDEX btree_idx_sales_ao_1 ON sales_ao(product_id);
6+
CREATE INDEX btree_idx_sales_ao_2 ON sales_ao(customer_name);
7+
CREATE INDEX btree_idx_sales_aocs_1 ON sales_aocs(product_id);
8+
CREATE INDEX btree_idx_sales_aocs_2 ON sales_aocs(product_id, sale_date);
9+
CREATE INDEX btree_idx_sales_partition_heap_1 ON sales_partition_heap(product_id);
10+
CREATE INDEX btree_idx_sales_partition_heap_2 ON sales_partition_heap(customer_name);
11+
CREATE INDEX btree_idx_sales_partition_ao_1 ON sales_partition_ao(product_id);
12+
CREATE INDEX btree_idx_sales_partition_ao_2 ON sales_partition_ao(product_id, sale_date);
13+
CREATE INDEX btree_idx_sales_partition_ao_3 ON sales_partition_ao(customer_name);
14+
CREATE INDEX btree_idx_sales_partition_aocs1 ON sales_partition_aocs(product_id);
15+
CREATE INDEX btree_idx_sales_partition_aocs2 ON sales_partition_aocs(customer_name, product_id);
16+
-- Unique
17+
CREATE UNIQUE INDEX on sales_ao(product_id);
18+
CREATE UNIQUE INDEX on sales_aocs(product_id,description);
19+
CREATE UNIQUE INDEX on sales_partition_ao(product_id,order_date);
20+
-- CREATE UNIQUE INDEX on sales_partition_aocs(product_id,description); blocked by issue #557
21+
-- Bitmap
22+
CREATE INDEX bmp_idx_sales_ao ON sales_ao USING bitmap(is_audited);
23+
CREATE INDEX bmp_idx_sales_partition_aocs ON sales_partition_aocs USING bitmap(status);
24+
CREATE INDEX bmp_idx_sales_heap ON sales_heap USING bitmap(status);
25+
-- Brin
26+
-- CREATE INDEX brin_idx_sales_ao ON sales_ao USING brin (sale_date) with (pages_per_range = 1); blocked by issue #558
27+
CREATE INDEX brin_idx_sales_partition_heap ON sales_partition_heap USING brin (sale_date) with (pages_per_range = 1);
28+
-- CREATE INDEX brin_idx_sales_aocs ON sales_aocs USING brin (sale_date) with (pages_per_range = 1); blocked by issue #558

‎src/test/binary_swap/expected/upgrading_compatibility/create_table.out‎

Lines changed: 144 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,27 @@
1-
DROP TABLE IF EXISTS sales_heap;
2-
DROP TABLE
1+
-- Create various types of tables for migration compatibility test
2+
--
3+
-- List of tables in Summary
4+
-- Name | Type | Partition by | Storage
5+
------------------------------+-------------------+--------------+----------------------
6+
-- sales_ao | table | | append only
7+
-- sales_aocs | table | | append only columnar
8+
-- sales_heap | table | | heap
9+
-- sales_partition_ao | partitioned table | range |
10+
-- sales_partition_aocs | partitioned table | hash |
11+
-- sales_partition_heap | partitioned table | list |
12+
-- sales_partition_ao_part1 | table | | append only
13+
-- sales_partition_ao_part2 | table | | append only
14+
-- sales_partition_ao_part3 | table | | append only
15+
-- sales_partition_aocs_part1 | table | | append only columnar
16+
-- sales_partition_aocs_part2 | table | | append only columnar
17+
-- sales_partition_aocs_part3 | table | | append only columnar
18+
-- sales_partition_heap_part1 | table | | heap
19+
-- sales_partition_heap_part2 | table | | heap
20+
-- sales_partition_heap_part3 | table | | heap
21+
--
22+
-- Heap Table
23+
DROP TABLE IF EXISTS sales_heap;
24+
NOTICE: table "sales_heap" does not exist, skipping
325
CREATE TABLE IF NOT EXISTS sales_heap
426
(
527
product_id INT,
@@ -14,13 +36,13 @@ CREATE TABLE IF NOT EXISTS sales_heap
1436
status CHAR(10),
1537
customer_name VARCHAR(20),
1638
price DECIMAL(20, 10)
17-
) DISTRIBUTED BY (product_id);
18-
CREATE TABLE
19-
---
39+
)
40+
DISTRIBUTED BY (product_id);
41+
-- Heap Table, Partition by LIST
2042
DROP TABLE IF EXISTS sales_partition_heap;
21-
DROP TABLE
43+
NOTICE: table "sales_partition_heap" does not exist, skipping
2244
CREATE TABLE IF NOT EXISTS sales_partition_heap
23-
(
45+
(
2446
product_id INT,
2547
is_audited BOOLEAN DEFAULT FALSE,
2648
quantity SMALLINT,
@@ -33,18 +55,128 @@ CREATE TABLE IF NOT EXISTS sales_partition_heap
3355
status CHAR(10),
3456
customer_name VARCHAR(20),
3557
price DECIMAL(20, 10)
36-
) DISTRIBUTED BY (product_id)
58+
)
59+
DISTRIBUTED BY (product_id)
3760
PARTITION BY LIST (status);
38-
CREATE TABLE
3961
CREATE TABLE sales_partition_heap_part1
4062
PARTITION OF sales_partition_heap
4163
FOR VALUES IN ('Cancelled');
42-
CREATE TABLE
64+
NOTICE: table has parent, setting distribution columns to match parent table
4365
CREATE TABLE sales_partition_heap_part2
4466
PARTITION OF sales_partition_heap
4567
FOR VALUES IN ('Closed');
46-
CREATE TABLE
68+
NOTICE: table has parent, setting distribution columns to match parent table
4769
CREATE TABLE sales_partition_heap_part3
4870
PARTITION OF sales_partition_heap
4971
FOR VALUES IN ('Processing');
50-
CREATE TABLE
72+
NOTICE: table has parent, setting distribution columns to match parent table
73+
-- AO Table
74+
DROP TABLE IF EXISTS sales_ao;
75+
NOTICE: table "sales_ao" does not exist, skipping
76+
CREATE TABLE IF NOT EXISTS sales_ao
77+
(
78+
product_id INT,
79+
is_audited BOOLEAN DEFAULT FALSE,
80+
quantity SMALLINT,
81+
total_sales BIGINT,
82+
unit_price REAL,
83+
discount DOUBLE PRECISION,
84+
description TEXT,
85+
sale_date TIMESTAMP,
86+
order_date DATE,
87+
status CHAR(10),
88+
customer_name VARCHAR(20),
89+
price DECIMAL(20, 10)
90+
)
91+
WITH (appendonly=true)
92+
DISTRIBUTED BY (product_id);
93+
-- AO Table, Partition by Range
94+
DROP TABLE IF EXISTS sales_partition_ao;
95+
NOTICE: table "sales_partition_ao" does not exist, skipping
96+
CREATE TABLE IF NOT EXISTS sales_partition_ao
97+
(
98+
product_id INT,
99+
is_audited BOOLEAN DEFAULT FALSE,
100+
quantity SMALLINT,
101+
total_sales BIGINT,
102+
unit_price REAL,
103+
discount DOUBLE PRECISION,
104+
description TEXT,
105+
sale_date TIMESTAMP,
106+
order_date DATE,
107+
status CHAR(10),
108+
customer_name VARCHAR(20),
109+
price DECIMAL(20, 10)
110+
)
111+
DISTRIBUTED BY (product_id)
112+
PARTITION BY RANGE (order_date);
113+
CREATE TABLE sales_partition_ao_part1
114+
PARTITION OF sales_partition_ao
115+
FOR VALUES FROM ('2023-01-01') TO ('2024-01-01')
116+
WITH (appendonly=true);
117+
NOTICE: table has parent, setting distribution columns to match parent table
118+
CREATE TABLE sales_partition_ao_part2
119+
PARTITION OF sales_partition_ao
120+
FOR VALUES FROM ('2024-01-01') TO ('2025-01-01')
121+
WITH (appendonly=true);
122+
NOTICE: table has parent, setting distribution columns to match parent table
123+
CREATE TABLE sales_partition_ao_part3
124+
PARTITION OF sales_partition_ao
125+
FOR VALUES FROM ('2025-01-01') TO ('2026-01-01')
126+
WITH (appendonly=true);
127+
NOTICE: table has parent, setting distribution columns to match parent table
128+
-- AOCS Table
129+
DROP TABLE IF EXISTS sales_aocs;
130+
NOTICE: table "sales_aocs" does not exist, skipping
131+
CREATE TABLE IF NOT EXISTS sales_aocs
132+
(
133+
product_id INT,
134+
is_audited BOOLEAN DEFAULT FALSE,
135+
quantity SMALLINT,
136+
total_sales BIGINT,
137+
unit_price REAL,
138+
discount DOUBLE PRECISION,
139+
description TEXT,
140+
sale_date TIMESTAMP,
141+
order_date DATE,
142+
status CHAR(10),
143+
customer_name VARCHAR(20),
144+
price DECIMAL(20, 10)
145+
)
146+
WITH (appendonly=true, orientation=column)
147+
DISTRIBUTED BY (product_id);
148+
-- AOCS Table, Partition by Hash
149+
DROP TABLE IF EXISTS sales_partition_aocs;
150+
NOTICE: table "sales_partition_aocs" does not exist, skipping
151+
CREATE TABLE IF NOT EXISTS sales_partition_aocs
152+
(
153+
product_id INT,
154+
is_audited BOOLEAN DEFAULT FALSE,
155+
quantity SMALLINT,
156+
total_sales BIGINT,
157+
unit_price REAL,
158+
discount DOUBLE PRECISION,
159+
description TEXT,
160+
sale_date TIMESTAMP,
161+
order_date DATE,
162+
status CHAR(10),
163+
customer_name VARCHAR(20),
164+
price DECIMAL(20, 10)
165+
)
166+
DISTRIBUTED BY (product_id)
167+
PARTITION BY HASH(description);
168+
CREATE TABLE sales_partition_aocs_part1
169+
PARTITION OF sales_partition_aocs
170+
FOR VALUES WITH (MODULUS 3, REMAINDER 0)
171+
WITH (appendonly=true, orientation=column);
172+
NOTICE: table has parent, setting distribution columns to match parent table
173+
CREATE TABLE sales_partition_aocs_part2
174+
PARTITION OF sales_partition_aocs
175+
FOR VALUES WITH (MODULUS 3, REMAINDER 1)
176+
WITH (appendonly=true, orientation=column);
177+
NOTICE: table has parent, setting distribution columns to match parent table
178+
CREATE TABLE sales_partition_aocs_part3
179+
PARTITION OF sales_partition_aocs
180+
FOR VALUES WITH (MODULUS 3, REMAINDER 2)
181+
WITH (appendonly=true, orientation=column);
182+
NOTICE: table has parent, setting distribution columns to match parent table

‎src/test/binary_swap/expected/upgrading_compatibility/delete.out‎

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,42 @@
11
DELETE FROM sales_heap WHERE product_id > 1000000;
2+
DELETE FROM sales_ao WHERE product_id > 1000000;
3+
DELETE FROM sales_aocs WHERE product_id > 1000000;
24
DELETE FROM sales_partition_heap WHERE product_id > 1000000;
5+
DELETE FROM sales_partition_ao WHERE product_id > 1000000;
6+
DELETE FROM sales_partition_aocs WHERE product_id > 1000000;
37
SELECT COUNT(*) FROM sales_heap;
48
count
59
-------
610
10000
711
(1 row)
812

13+
SELECT COUNT(*) FROM sales_ao;
14+
count
15+
-------
16+
10000
17+
(1 row)
18+
19+
SELECT COUNT(*) FROM sales_aocs;
20+
count
21+
-------
22+
10000
23+
(1 row)
24+
925
SELECT COUNT(*) FROM sales_partition_heap;
1026
count
1127
-------
1228
10000
1329
(1 row)
1430

31+
SELECT COUNT(*) FROM sales_partition_ao;
32+
count
33+
-------
34+
10000
35+
(1 row)
36+
37+
SELECT COUNT(*) FROM sales_partition_aocs;
38+
count
39+
-------
40+
10000
41+
(1 row)
42+

0 commit comments

Comments
 (0)