mirror of https://github.com/citusdata/citus.git
Not print metapage.reserved_offset in regression tests (#5168)
* We were anyway not testing reserved_offset in any of those tests but other fields. * This only happens with compressed columnar tables and is because the libzstd/liblz4 versions that we have on exttester ci image might be different than what we might have on our local environments.pull/5203/head
parent
2b93f8af56
commit
5af839ada0
|
@ -13,11 +13,11 @@ INSERT INTO test_alter_table SELECT * FROM sample_data;
|
||||||
-- drop a column
|
-- drop a column
|
||||||
ALTER TABLE test_alter_table DROP COLUMN a;
|
ALTER TABLE test_alter_table DROP COLUMN a;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 2 | 150001 | 16402
|
2 | 0 | 2 | 150001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- test analyze
|
-- test analyze
|
||||||
|
@ -68,11 +68,11 @@ SELECT * FROM test_alter_table;
|
||||||
(5 rows)
|
(5 rows)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 4 | 450001 | 32724
|
2 | 0 | 4 | 450001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- add a fixed-length column with default value
|
-- add a fixed-length column with default value
|
||||||
|
@ -100,11 +100,11 @@ SELECT * from test_alter_table;
|
||||||
(6 rows)
|
(6 rows)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 5 | 600001 | 40906
|
2 | 0 | 5 | 600001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- add a variable-length column with default value
|
-- add a variable-length column with default value
|
||||||
|
|
|
@ -54,19 +54,19 @@ select count(*) from t_compressed;
|
||||||
|
|
||||||
-- check storage
|
-- check storage
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 1 | 1 | 16336
|
2 | 0 | 1 | 1
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 1 | 1 | 16336
|
2 | 0 | 1 | 1
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- explain
|
-- explain
|
||||||
|
@ -104,19 +104,19 @@ vacuum full t_compressed;
|
||||||
vacuum full t_uncompressed;
|
vacuum full t_uncompressed;
|
||||||
-- check storage
|
-- check storage
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 1 | 1 | 16336
|
2 | 0 | 1 | 1
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 1 | 1 | 16336
|
2 | 0 | 1 | 1
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- analyze
|
-- analyze
|
||||||
|
@ -130,19 +130,19 @@ alter table t_uncompressed alter column a type text;
|
||||||
alter table t_compressed alter column a type text;
|
alter table t_compressed alter column a type text;
|
||||||
-- check storage
|
-- check storage
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 1 | 1 | 16336
|
2 | 0 | 1 | 1
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 1 | 1 | 16336
|
2 | 0 | 1 | 1
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- verify cost of scanning an empty table is zero, not NaN
|
-- verify cost of scanning an empty table is zero, not NaN
|
||||||
|
|
|
@ -46,11 +46,11 @@ select count(*) from test_insert_command;
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_insert_command');
|
from columnar_test_helpers.columnar_storage_info('test_insert_command');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 4 | 450001 | 32686
|
2 | 0 | 4 | 450001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
@ -150,11 +150,11 @@ FROM test_toast_columnar;
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_toast_columnar');
|
from columnar_test_helpers.columnar_storage_info('test_toast_columnar');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 2 | 150001 | 16428
|
2 | 0 | 2 | 150001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
@ -190,11 +190,11 @@ INSERT INTO zero_col_heap SELECT * FROM zero_col_heap;
|
||||||
INSERT INTO zero_col_heap SELECT * FROM zero_col_heap;
|
INSERT INTO zero_col_heap SELECT * FROM zero_col_heap;
|
||||||
INSERT INTO zero_col SELECT * FROM zero_col_heap;
|
INSERT INTO zero_col SELECT * FROM zero_col_heap;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('zero_col');
|
from columnar_test_helpers.columnar_storage_info('zero_col');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 6 | 750001 | 16336
|
2 | 0 | 6 | 750001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
SELECT relname, stripe_num, chunk_group_count, row_count FROM columnar.stripe a, pg_class b
|
SELECT relname, stripe_num, chunk_group_count, row_count FROM columnar.stripe a, pg_class b
|
||||||
|
|
|
@ -15,11 +15,11 @@ SELECT count(*) FROM t;
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 1 | 150001 | 16336
|
2 | 0 | 1 | 150001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- check stripe metadata also have been rolled-back
|
-- check stripe metadata also have been rolled-back
|
||||||
|
@ -55,11 +55,11 @@ SELECT count(*) FROM t; -- force flush
|
||||||
SAVEPOINT s1;
|
SAVEPOINT s1;
|
||||||
INSERT INTO t SELECT i, i+1 FROM generate_series(1, 10) i;
|
INSERT INTO t SELECT i, i+1 FROM generate_series(1, 10) i;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 3 | 600001 | 24606
|
2 | 0 | 3 | 600001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
SELECT count(*) FROM t;
|
SELECT count(*) FROM t;
|
||||||
|
@ -85,11 +85,11 @@ SELECT count(*) FROM t;
|
||||||
INSERT INTO t SELECT i, i+1 FROM generate_series(1, 10) i;
|
INSERT INTO t SELECT i, i+1 FROM generate_series(1, 10) i;
|
||||||
COMMIT;
|
COMMIT;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 5 | 750001 | 40942
|
2 | 0 | 5 | 750001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
SELECT count(*) FROM t;
|
SELECT count(*) FROM t;
|
||||||
|
|
|
@ -44,20 +44,20 @@ SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('columnar_truncate_test');
|
from columnar_test_helpers.columnar_storage_info('columnar_truncate_test');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 2 | 150001 | 16438
|
2 | 0 | 2 | 150001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
TRUNCATE TABLE columnar_truncate_test;
|
TRUNCATE TABLE columnar_truncate_test;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('columnar_truncate_test');
|
from columnar_test_helpers.columnar_storage_info('columnar_truncate_test');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 1 | 1 | 16336
|
2 | 0 | 1 | 1
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
|
|
@ -26,11 +26,11 @@ SELECT count(*) FROM t_stripes;
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 4 | 450001 | 32756
|
2 | 0 | 4 | 450001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- vacuum full should merge stripes together
|
-- vacuum full should merge stripes together
|
||||||
|
@ -54,11 +54,11 @@ SELECT count(*) FROM t_stripes;
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 2 | 150001 | 16584
|
2 | 0 | 2 | 150001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- test the case when all data cannot fit into a single stripe
|
-- test the case when all data cannot fit into a single stripe
|
||||||
|
@ -83,11 +83,11 @@ SELECT count(*) FROM t_stripes;
|
||||||
|
|
||||||
VACUUM FULL t;
|
VACUUM FULL t;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 4 | 3001 | 53382
|
2 | 0 | 4 | 3001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
@ -115,12 +115,12 @@ FROM columnar.chunk a, pg_class b
|
||||||
WHERE a.storage_id = columnar_test_helpers.columnar_relation_storageid(b.oid) AND b.relname='t' ORDER BY 1, 2, 3;
|
WHERE a.storage_id = columnar_test_helpers.columnar_relation_storageid(b.oid) AND b.relname='t' ORDER BY 1, 2, 3;
|
||||||
stripe_num | attr_num | chunk_group_num | ?column? | ?column?
|
stripe_num | attr_num | chunk_group_num | ?column? | ?column?
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
1 | 1 | 0 | f | f
|
1 | 1 | 0 | f | f
|
||||||
1 | 2 | 0 | f | f
|
1 | 2 | 0 | f | f
|
||||||
2 | 1 | 0 | f | f
|
2 | 1 | 0 | f | f
|
||||||
2 | 2 | 0 | f | f
|
2 | 2 | 0 | f | f
|
||||||
3 | 1 | 0 | f | f
|
3 | 1 | 0 | f | f
|
||||||
3 | 2 | 0 | f | f
|
3 | 2 | 0 | f | f
|
||||||
(6 rows)
|
(6 rows)
|
||||||
|
|
||||||
VACUUM FULL t;
|
VACUUM FULL t;
|
||||||
|
@ -129,12 +129,12 @@ FROM columnar.chunk a, pg_class b
|
||||||
WHERE a.storage_id = columnar_test_helpers.columnar_relation_storageid(b.oid) AND b.relname='t' ORDER BY 1, 2, 3;
|
WHERE a.storage_id = columnar_test_helpers.columnar_relation_storageid(b.oid) AND b.relname='t' ORDER BY 1, 2, 3;
|
||||||
stripe_num | attr_num | chunk_group_num | ?column? | ?column?
|
stripe_num | attr_num | chunk_group_num | ?column? | ?column?
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
1 | 1 | 0 | t | t
|
1 | 1 | 0 | t | t
|
||||||
1 | 2 | 0 | f | f
|
1 | 2 | 0 | f | f
|
||||||
2 | 1 | 0 | t | t
|
2 | 1 | 0 | t | t
|
||||||
2 | 2 | 0 | f | f
|
2 | 2 | 0 | f | f
|
||||||
3 | 1 | 0 | t | t
|
3 | 1 | 0 | t | t
|
||||||
3 | 2 | 0 | f | f
|
3 | 2 | 0 | f | f
|
||||||
(6 rows)
|
(6 rows)
|
||||||
|
|
||||||
-- Make sure we cleaned-up the transient table metadata after VACUUM FULL commands
|
-- Make sure we cleaned-up the transient table metadata after VACUUM FULL commands
|
||||||
|
@ -240,11 +240,11 @@ total row count: 5530, stripe count: 5, average rows per stripe: 1106
|
||||||
chunk count: 7, containing data for dropped columns: 0, none compressed: 5, pglz compressed: 2
|
chunk count: 7, containing data for dropped columns: 0, none compressed: 5, pglz compressed: 2
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 16 | 21001 | 50686
|
2 | 0 | 16 | 21001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
|
|
@ -16,7 +16,7 @@ COPY contestant FROM '@abs_srcdir@/data/contestants.1.csv' WITH CSV;
|
||||||
COPY contestant FROM PROGRAM 'cat @abs_srcdir@/data/contestants.2.csv' WITH CSV;
|
COPY contestant FROM PROGRAM 'cat @abs_srcdir@/data/contestants.2.csv' WITH CSV;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('contestant');
|
from columnar_test_helpers.columnar_storage_info('contestant');
|
||||||
|
|
||||||
-- COPY into compressed table
|
-- COPY into compressed table
|
||||||
|
@ -27,7 +27,7 @@ COPY contestant_compressed FROM PROGRAM 'cat @abs_srcdir@/data/contestants.2.csv
|
||||||
WITH CSV;
|
WITH CSV;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('contestant_compressed');
|
from columnar_test_helpers.columnar_storage_info('contestant_compressed');
|
||||||
|
|
||||||
-- Test column list
|
-- Test column list
|
||||||
|
|
|
@ -15,11 +15,11 @@ COPY contestant FROM '@abs_srcdir@/data/contestants.1.csv' WITH CSV;
|
||||||
-- COPY into uncompressed table from program
|
-- COPY into uncompressed table from program
|
||||||
COPY contestant FROM PROGRAM 'cat @abs_srcdir@/data/contestants.2.csv' WITH CSV;
|
COPY contestant FROM PROGRAM 'cat @abs_srcdir@/data/contestants.2.csv' WITH CSV;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('contestant');
|
from columnar_test_helpers.columnar_storage_info('contestant');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 3 | 300001 | 24742
|
2 | 0 | 3 | 300001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- COPY into compressed table
|
-- COPY into compressed table
|
||||||
|
@ -28,11 +28,11 @@ COPY contestant_compressed FROM '@abs_srcdir@/data/contestants.1.csv' WITH CSV;
|
||||||
COPY contestant_compressed FROM PROGRAM 'cat @abs_srcdir@/data/contestants.2.csv'
|
COPY contestant_compressed FROM PROGRAM 'cat @abs_srcdir@/data/contestants.2.csv'
|
||||||
WITH CSV;
|
WITH CSV;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('contestant_compressed');
|
from columnar_test_helpers.columnar_storage_info('contestant_compressed');
|
||||||
version_major | version_minor | reserved_stripe_id | reserved_row_number | reserved_offset
|
version_major | version_minor | reserved_stripe_id | reserved_row_number
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
2 | 0 | 3 | 300001 | 24704
|
2 | 0 | 3 | 300001
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- Test column list
|
-- Test column list
|
||||||
|
|
|
@ -18,7 +18,7 @@ INSERT INTO test_alter_table SELECT * FROM sample_data;
|
||||||
ALTER TABLE test_alter_table DROP COLUMN a;
|
ALTER TABLE test_alter_table DROP COLUMN a;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
||||||
|
|
||||||
-- test analyze
|
-- test analyze
|
||||||
|
@ -41,7 +41,7 @@ INSERT INTO test_alter_table (SELECT 3, 5, 8);
|
||||||
SELECT * FROM test_alter_table;
|
SELECT * FROM test_alter_table;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
||||||
|
|
||||||
|
|
||||||
|
@ -52,7 +52,7 @@ INSERT INTO test_alter_table (SELECT 1, 2, 4, 8);
|
||||||
SELECT * from test_alter_table;
|
SELECT * from test_alter_table;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
from columnar_test_helpers.columnar_storage_info('test_alter_table');
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -21,10 +21,10 @@ select count(*) from t_compressed;
|
||||||
|
|
||||||
-- check storage
|
-- check storage
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
||||||
|
|
||||||
-- explain
|
-- explain
|
||||||
|
@ -41,10 +41,10 @@ vacuum full t_uncompressed;
|
||||||
|
|
||||||
-- check storage
|
-- check storage
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
||||||
|
|
||||||
-- analyze
|
-- analyze
|
||||||
|
@ -61,10 +61,10 @@ alter table t_compressed alter column a type text;
|
||||||
|
|
||||||
-- check storage
|
-- check storage
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
from columnar_test_helpers.columnar_storage_info('t_compressed');
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
from columnar_test_helpers.columnar_storage_info('t_uncompressed');
|
||||||
|
|
||||||
-- verify cost of scanning an empty table is zero, not NaN
|
-- verify cost of scanning an empty table is zero, not NaN
|
||||||
|
|
|
@ -23,7 +23,7 @@ insert into test_insert_command select * from test_insert_command_data;
|
||||||
select count(*) from test_insert_command;
|
select count(*) from test_insert_command;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_insert_command');
|
from columnar_test_helpers.columnar_storage_info('test_insert_command');
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
@ -104,7 +104,7 @@ SELECT
|
||||||
FROM test_toast_columnar;
|
FROM test_toast_columnar;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('test_toast_columnar');
|
from columnar_test_helpers.columnar_storage_info('test_toast_columnar');
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
@ -137,7 +137,7 @@ INSERT INTO zero_col_heap SELECT * FROM zero_col_heap;
|
||||||
INSERT INTO zero_col SELECT * FROM zero_col_heap;
|
INSERT INTO zero_col SELECT * FROM zero_col_heap;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('zero_col');
|
from columnar_test_helpers.columnar_storage_info('zero_col');
|
||||||
|
|
||||||
SELECT relname, stripe_num, chunk_group_count, row_count FROM columnar.stripe a, pg_class b
|
SELECT relname, stripe_num, chunk_group_count, row_count FROM columnar.stripe a, pg_class b
|
||||||
|
|
|
@ -14,7 +14,7 @@ ROLLBACK;
|
||||||
SELECT count(*) FROM t;
|
SELECT count(*) FROM t;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
|
|
||||||
-- check stripe metadata also have been rolled-back
|
-- check stripe metadata also have been rolled-back
|
||||||
|
@ -34,7 +34,7 @@ SAVEPOINT s1;
|
||||||
INSERT INTO t SELECT i, i+1 FROM generate_series(1, 10) i;
|
INSERT INTO t SELECT i, i+1 FROM generate_series(1, 10) i;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
|
|
||||||
SELECT count(*) FROM t;
|
SELECT count(*) FROM t;
|
||||||
|
@ -46,7 +46,7 @@ INSERT INTO t SELECT i, i+1 FROM generate_series(1, 10) i;
|
||||||
COMMIT;
|
COMMIT;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
|
|
||||||
SELECT count(*) FROM t;
|
SELECT count(*) FROM t;
|
||||||
|
|
|
@ -28,13 +28,13 @@ SELECT * FROM columnar_truncate_test;
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('columnar_truncate_test');
|
from columnar_test_helpers.columnar_storage_info('columnar_truncate_test');
|
||||||
|
|
||||||
TRUNCATE TABLE columnar_truncate_test;
|
TRUNCATE TABLE columnar_truncate_test;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('columnar_truncate_test');
|
from columnar_test_helpers.columnar_storage_info('columnar_truncate_test');
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
|
|
@ -18,7 +18,7 @@ SELECT sum(a), sum(b) FROM t;
|
||||||
SELECT count(*) FROM t_stripes;
|
SELECT count(*) FROM t_stripes;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
|
|
||||||
-- vacuum full should merge stripes together
|
-- vacuum full should merge stripes together
|
||||||
|
@ -30,7 +30,7 @@ SELECT sum(a), sum(b) FROM t;
|
||||||
SELECT count(*) FROM t_stripes;
|
SELECT count(*) FROM t_stripes;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
|
|
||||||
-- test the case when all data cannot fit into a single stripe
|
-- test the case when all data cannot fit into a single stripe
|
||||||
|
@ -43,7 +43,7 @@ SELECT count(*) FROM t_stripes;
|
||||||
VACUUM FULL t;
|
VACUUM FULL t;
|
||||||
|
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
@ -108,7 +108,7 @@ COMMIT;
|
||||||
|
|
||||||
VACUUM VERBOSE t;
|
VACUUM VERBOSE t;
|
||||||
select
|
select
|
||||||
version_major, version_minor, reserved_stripe_id, reserved_row_number, reserved_offset
|
version_major, version_minor, reserved_stripe_id, reserved_row_number
|
||||||
from columnar_test_helpers.columnar_storage_info('t');
|
from columnar_test_helpers.columnar_storage_info('t');
|
||||||
|
|
||||||
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
SELECT * FROM columnar_test_helpers.chunk_group_consistency;
|
||||||
|
|
Loading…
Reference in New Issue