postgres/timescaledb
1
0
Fork 0
mirror of https://github.com/timescale/timescaledb.git synced 2025-05-28 01:30:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix chunk_utils_internal test

Browse Source 
Change chunk_utils_internal test to not use oid but instead use the
role name. Using the oid can lead to failing tests when oid assignment
is different especially when run with regresschecklocal-t.
This commit is contained in:
Sven Klemm 2022-08-15 10:28:19 +02:00 committed by Sven Klemm
parent 131773a902
commit a6cda9c9f0
2 changed files with 46 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
tsl/test/expected/chunk_utils_internal.out
View File

@ -22,7 +22,7 @@ NOTICE: adding not-null constraint to column "time"
INSERT INTO test1.hyper1 VALUES (10, 0.5); INSERT INTO test1.hyper1 VALUES (10, 0.5);
INSERT INTO test1.hyper1 VALUES (30, 0.5); INSERT INTO test1.hyper1 VALUES (30, 0.5);
SELECT chunk_schema as "CHSCHEMA", chunk_name as "CHNAME", SELECT chunk_schema as "CHSCHEMA", chunk_name as "CHNAME",
range_start_integer, range_end_integer range_start_integer, range_end_integer
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'hyper1' and hypertable_schema = 'test1' WHERE hypertable_name = 'hyper1' and hypertable_schema = 'test1'
@ -91,7 +91,7 @@ SELECT * from test1.hyper1 ORDER BY 1;
(3 rows) (3 rows)
-- TEST unfreeze frozen chunk and then drop -- TEST unfreeze frozen chunk and then drop
SELECT table_name, status SELECT table_name, status
FROM _timescaledb_catalog.chunk WHERE table_name = :'CHUNK_NAME'; FROM _timescaledb_catalog.chunk WHERE table_name = :'CHUNK_NAME';
table_name | status table_name | status
------------------+-------- ------------------+--------
@ -105,7 +105,7 @@ SELECT _timescaledb_internal.unfreeze_chunk( :'CHNAME');
(1 row) (1 row)
--verify status in catalog --verify status in catalog
SELECT table_name, status SELECT table_name, status
FROM _timescaledb_catalog.chunk WHERE table_name = :'CHUNK_NAME'; FROM _timescaledb_catalog.chunk WHERE table_name = :'CHUNK_NAME';
table_name | status table_name | status
------------------+-------- ------------------+--------
@ -178,10 +178,10 @@ ERROR: decompress_chunk not permitted on frozen chunk "_hyper_2_3_chunk"
INSERT INTO public.table_to_compress VALUES ('2020-01-01 10:00', 12, 77); INSERT INTO public.table_to_compress VALUES ('2020-01-01 10:00', 12, 77);
ERROR: Insert not permitted on frozen chunk "_hyper_2_3_chunk" ERROR: Insert not permitted on frozen chunk "_hyper_2_3_chunk"
--touches all chunks --touches all chunks
UPDATE public.table_to_compress SET value = 3; UPDATE public.table_to_compress SET value = 3;
ERROR: Update not permitted on frozen chunk "_hyper_2_3_chunk" ERROR: Update not permitted on frozen chunk "_hyper_2_3_chunk"
--touches only frozen chunk --touches only frozen chunk
DELETE FROM public.table_to_compress WHERE time < '2020-01-02'; DELETE FROM public.table_to_compress WHERE time < '2020-01-02';
ERROR: Delete not permitted on frozen chunk "_hyper_2_3_chunk" ERROR: Delete not permitted on frozen chunk "_hyper_2_3_chunk"
\set ON_ERROR_STOP 1 \set ON_ERROR_STOP 1
--try to refreeze --try to refreeze
@ -191,7 +191,7 @@ SELECT _timescaledb_internal.freeze_chunk( :'CHNAME');
t t
(1 row) (1 row)
--touches non-frozen chunk --touches non-frozen chunk
SELECT * from public.table_to_compress ORDER BY 1, 3; SELECT * from public.table_to_compress ORDER BY 1, 3;
time | acq_id | value time | acq_id | value
------------+---------+-------- ------------+---------+--------
@ -200,7 +200,7 @@ SELECT * from public.table_to_compress ORDER BY 1, 3;
02-10-2020 | 1234 | 5678 02-10-2020 | 1234 | 5678
(3 rows) (3 rows)
DELETE FROM public.table_to_compress WHERE time > '2020-01-02'; DELETE FROM public.table_to_compress WHERE time > '2020-01-02';
SELECT * from public.table_to_compress ORDER BY 1, 3; SELECT * from public.table_to_compress ORDER BY 1, 3;
time | acq_id | value time | acq_id | value
------------+---------+-------- ------------+---------+--------
@ -343,10 +343,10 @@ INSERT INTO fdw_table VALUES( '2020-01-01 01:00', 100, 1000);
\c :TEST_DBNAME :ROLE_SUPERUSER \c :TEST_DBNAME :ROLE_SUPERUSER
SELECT current_setting('port') as "PORTNO" \gset SELECT current_setting('port') as "PORTNO" \gset
CREATE EXTENSION postgres_fdw; CREATE EXTENSION postgres_fdw;
CREATE SERVER s3_server FOREIGN DATA WRAPPER postgres_fdw CREATE SERVER s3_server FOREIGN DATA WRAPPER postgres_fdw
OPTIONS ( host 'localhost', dbname 'postgres_fdw_db', port :'PORTNO'); OPTIONS ( host 'localhost', dbname 'postgres_fdw_db', port :'PORTNO');
GRANT USAGE ON FOREIGN SERVER s3_server TO :ROLE_4; GRANT USAGE ON FOREIGN SERVER s3_server TO :ROLE_4;
CREATE USER MAPPING FOR :ROLE_4 SERVER s3_server CREATE USER MAPPING FOR :ROLE_4 SERVER s3_server
OPTIONS ( user :'ROLE_4' , password :'ROLE_4_PASS'); OPTIONS ( user :'ROLE_4' , password :'ROLE_4_PASS');
ALTER USER MAPPING FOR :ROLE_4 SERVER s3_server ALTER USER MAPPING FOR :ROLE_4 SERVER s3_server
OPTIONS (ADD password_required 'false'); OPTIONS (ADD password_required 'false');
@ -377,7 +377,7 @@ SELECT _timescaledb_internal.attach_osm_table_chunk('ht_try', 'child_fdw_table')
(1 row) (1 row)
SELECT chunk_name, range_start, range_end SELECT chunk_name, range_start, range_end
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'ht_try' ORDER BY 1; WHERE hypertable_name = 'ht_try' ORDER BY 1;
chunk_name | range_start | range_end chunk_name | range_start | range_end
------------------+---------------------------------+--------------------------------- ------------------+---------------------------------+---------------------------------
@ -392,13 +392,13 @@ SELECT * FROM ht_try ORDER BY 1;
Tue May 05 01:00:00 2020 PDT | 222 | 222 Tue May 05 01:00:00 2020 PDT | 222 | 222
(2 rows) (2 rows)
SELECT relname, relowner FROM pg_class SELECT relname, relowner::regrole FROM pg_class
WHERE relname in ( select chunk_name FROM timescaledb_information.chunks WHERE relname in ( select chunk_name FROM timescaledb_information.chunks
WHERE hypertable_name = 'ht_try' ); WHERE hypertable_name = 'ht_try' );
relname | relowner relname | relowner
------------------+---------- ------------------+-------------
child_fdw_table | 16392 child_fdw_table | test_role_4
_hyper_5_9_chunk | 16392 _hyper_5_9_chunk | test_role_4
(2 rows) (2 rows)
SELECT inhrelid::regclass SELECT inhrelid::regclass
@ -423,13 +423,13 @@ ERROR: "non_ht" is not a hypertable
-- TEST drop the hypertable and make sure foreign chunks are dropped as well -- -- TEST drop the hypertable and make sure foreign chunks are dropped as well --
\c :TEST_DBNAME :ROLE_4; \c :TEST_DBNAME :ROLE_4;
DROP TABLE ht_try; DROP TABLE ht_try;
SELECT relname FROM pg_class WHERE relname = 'child_fdw_table'; SELECT relname FROM pg_class WHERE relname = 'child_fdw_table';
relname relname
--------- ---------
(0 rows) (0 rows)
SELECT chunk_name, range_start, range_end SELECT chunk_name, range_start, range_end
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'ht_try' ORDER BY 1; WHERE hypertable_name = 'ht_try' ORDER BY 1;
chunk_name | range_start | range_end chunk_name | range_start | range_end
------------+-------------+----------- ------------+-------------+-----------
@ -464,7 +464,7 @@ INSERT into disthyper VALUES ('2020-01-01', 10);
--freeze one of the chunks --freeze one of the chunks
SELECT chunk_schema || '.' || chunk_name as "CHNAME3" SELECT chunk_schema || '.' || chunk_name as "CHNAME3"
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'disthyper' WHERE hypertable_name = 'disthyper'
ORDER BY chunk_name LIMIT 1 ORDER BY chunk_name LIMIT 1
\gset \gset
\set ON_ERROR_STOP 0 \set ON_ERROR_STOP 0
@ -477,10 +477,10 @@ ERROR: operation not supported on distributed chunk or foreign table "_dist_hyp
\c :TEST_DBNAME :ROLE_4 \c :TEST_DBNAME :ROLE_4
CREATE TABLE measure( id integer PRIMARY KEY, mname varchar(10)); CREATE TABLE measure( id integer PRIMARY KEY, mname varchar(10));
INSERT INTO measure VALUES( 1, 'temp'); INSERT INTO measure VALUES( 1, 'temp');
CREATE TABLE hyper_constr ( id integer, time bigint, temp float, mid integer CREATE TABLE hyper_constr ( id integer, time bigint, temp float, mid integer
,PRIMARY KEY (id, time) ,PRIMARY KEY (id, time)
,FOREIGN KEY ( mid) REFERENCES measure(id) ,FOREIGN KEY ( mid) REFERENCES measure(id)
,CHECK ( temp > 10) ,CHECK ( temp > 10)
); );
SELECT create_hypertable('hyper_constr', 'time', chunk_time_interval => 10); SELECT create_hypertable('hyper_constr', 'time', chunk_time_interval => 10);
create_hypertable create_hypertable
@ -505,7 +505,7 @@ SELECT _timescaledb_internal.attach_osm_table_chunk('hyper_constr', 'child_hyper
(1 row) (1 row)
SELECT chunk_name, range_start, range_end SELECT chunk_name, range_start, range_end
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'hyper_constr' ORDER BY 1; WHERE hypertable_name = 'hyper_constr' ORDER BY 1;
chunk_name | range_start | range_end chunk_name | range_start | range_end
--------------------+-------------+----------- --------------------+-------------+-----------
@ -521,7 +521,7 @@ SELECT * FROM hyper_constr order by time;
(2 rows) (2 rows)
--verify the check constraint exists on the OSM chunk --verify the check constraint exists on the OSM chunk
SELECT conname FROM pg_constraint SELECT conname FROM pg_constraint
where conrelid = 'child_hyper_constr'::regclass ORDER BY 1; where conrelid = 'child_hyper_constr'::regclass ORDER BY 1;
conname conname
------------------------- -------------------------

42
tsl/test/sql/chunk_utils_internal.sql
View File

@ -22,7 +22,7 @@ SELECT create_hypertable('test1.hyper1', 'time', chunk_time_interval => 10);
INSERT INTO test1.hyper1 VALUES (10, 0.5); INSERT INTO test1.hyper1 VALUES (10, 0.5);
INSERT INTO test1.hyper1 VALUES (30, 0.5); INSERT INTO test1.hyper1 VALUES (30, 0.5);
SELECT chunk_schema as "CHSCHEMA", chunk_name as "CHNAME", SELECT chunk_schema as "CHSCHEMA", chunk_name as "CHNAME",
range_start_integer, range_end_integer range_start_integer, range_end_integer
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'hyper1' and hypertable_schema = 'test1' WHERE hypertable_name = 'hyper1' and hypertable_schema = 'test1'
@ -60,13 +60,13 @@ INSERT INTO test1.hyper1 VALUES ( 31, 31);
SELECT * from test1.hyper1 ORDER BY 1; SELECT * from test1.hyper1 ORDER BY 1;
-- TEST unfreeze frozen chunk and then drop -- TEST unfreeze frozen chunk and then drop
SELECT table_name, status SELECT table_name, status
FROM _timescaledb_catalog.chunk WHERE table_name = :'CHUNK_NAME'; FROM _timescaledb_catalog.chunk WHERE table_name = :'CHUNK_NAME';
SELECT _timescaledb_internal.unfreeze_chunk( :'CHNAME'); SELECT _timescaledb_internal.unfreeze_chunk( :'CHNAME');
--verify status in catalog --verify status in catalog
SELECT table_name, status SELECT table_name, status
FROM _timescaledb_catalog.chunk WHERE table_name = :'CHUNK_NAME'; FROM _timescaledb_catalog.chunk WHERE table_name = :'CHUNK_NAME';
--unfreezing again works --unfreezing again works
SELECT _timescaledb_internal.unfreeze_chunk( :'CHNAME'); SELECT _timescaledb_internal.unfreeze_chunk( :'CHNAME');
@ -102,16 +102,16 @@ SELECT decompress_chunk( :'CHNAME');
--insert into frozen chunk, should fail --insert into frozen chunk, should fail
INSERT INTO public.table_to_compress VALUES ('2020-01-01 10:00', 12, 77); INSERT INTO public.table_to_compress VALUES ('2020-01-01 10:00', 12, 77);
--touches all chunks --touches all chunks
UPDATE public.table_to_compress SET value = 3; UPDATE public.table_to_compress SET value = 3;
--touches only frozen chunk --touches only frozen chunk
DELETE FROM public.table_to_compress WHERE time < '2020-01-02'; DELETE FROM public.table_to_compress WHERE time < '2020-01-02';
\set ON_ERROR_STOP 1 \set ON_ERROR_STOP 1
--try to refreeze --try to refreeze
SELECT _timescaledb_internal.freeze_chunk( :'CHNAME'); SELECT _timescaledb_internal.freeze_chunk( :'CHNAME');
--touches non-frozen chunk --touches non-frozen chunk
SELECT * from public.table_to_compress ORDER BY 1, 3; SELECT * from public.table_to_compress ORDER BY 1, 3;
DELETE FROM public.table_to_compress WHERE time > '2020-01-02'; DELETE FROM public.table_to_compress WHERE time > '2020-01-02';
SELECT * from public.table_to_compress ORDER BY 1, 3; SELECT * from public.table_to_compress ORDER BY 1, 3;
@ -205,11 +205,11 @@ INSERT INTO fdw_table VALUES( '2020-01-01 01:00', 100, 1000);
SELECT current_setting('port') as "PORTNO" \gset SELECT current_setting('port') as "PORTNO" \gset
CREATE EXTENSION postgres_fdw; CREATE EXTENSION postgres_fdw;
CREATE SERVER s3_server FOREIGN DATA WRAPPER postgres_fdw CREATE SERVER s3_server FOREIGN DATA WRAPPER postgres_fdw
OPTIONS ( host 'localhost', dbname 'postgres_fdw_db', port :'PORTNO'); OPTIONS ( host 'localhost', dbname 'postgres_fdw_db', port :'PORTNO');
GRANT USAGE ON FOREIGN SERVER s3_server TO :ROLE_4; GRANT USAGE ON FOREIGN SERVER s3_server TO :ROLE_4;
CREATE USER MAPPING FOR :ROLE_4 SERVER s3_server CREATE USER MAPPING FOR :ROLE_4 SERVER s3_server
OPTIONS ( user :'ROLE_4' , password :'ROLE_4_PASS'); OPTIONS ( user :'ROLE_4' , password :'ROLE_4_PASS');
ALTER USER MAPPING FOR :ROLE_4 SERVER s3_server ALTER USER MAPPING FOR :ROLE_4 SERVER s3_server
@ -231,14 +231,14 @@ SELECT * FROM child_fdw_table;
SELECT _timescaledb_internal.attach_osm_table_chunk('ht_try', 'child_fdw_table'); SELECT _timescaledb_internal.attach_osm_table_chunk('ht_try', 'child_fdw_table');
SELECT chunk_name, range_start, range_end SELECT chunk_name, range_start, range_end
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'ht_try' ORDER BY 1; WHERE hypertable_name = 'ht_try' ORDER BY 1;
SELECT * FROM ht_try ORDER BY 1; SELECT * FROM ht_try ORDER BY 1;
SELECT relname, relowner FROM pg_class SELECT relname, relowner::regrole FROM pg_class
WHERE relname in ( select chunk_name FROM timescaledb_information.chunks WHERE relname in ( select chunk_name FROM timescaledb_information.chunks
WHERE hypertable_name = 'ht_try' ); WHERE hypertable_name = 'ht_try' );
SELECT inhrelid::regclass SELECT inhrelid::regclass
FROM pg_inherits WHERE inhparent = 'ht_try'::regclass ORDER BY 1; FROM pg_inherits WHERE inhparent = 'ht_try'::regclass ORDER BY 1;
@ -258,10 +258,10 @@ SELECT _timescaledb_internal.attach_osm_table_chunk('non_ht', 'child_fdw_table')
\c :TEST_DBNAME :ROLE_4; \c :TEST_DBNAME :ROLE_4;
DROP TABLE ht_try; DROP TABLE ht_try;
SELECT relname FROM pg_class WHERE relname = 'child_fdw_table'; SELECT relname FROM pg_class WHERE relname = 'child_fdw_table';
SELECT chunk_name, range_start, range_end SELECT chunk_name, range_start, range_end
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'ht_try' ORDER BY 1; WHERE hypertable_name = 'ht_try' ORDER BY 1;
@ -279,7 +279,7 @@ INSERT into disthyper VALUES ('2020-01-01', 10);
--freeze one of the chunks --freeze one of the chunks
SELECT chunk_schema || '.' || chunk_name as "CHNAME3" SELECT chunk_schema || '.' || chunk_name as "CHNAME3"
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'disthyper' WHERE hypertable_name = 'disthyper'
ORDER BY chunk_name LIMIT 1 ORDER BY chunk_name LIMIT 1
\gset \gset
@ -293,10 +293,10 @@ SELECT _timescaledb_internal.unfreeze_chunk( :'CHNAME3');
CREATE TABLE measure( id integer PRIMARY KEY, mname varchar(10)); CREATE TABLE measure( id integer PRIMARY KEY, mname varchar(10));
INSERT INTO measure VALUES( 1, 'temp'); INSERT INTO measure VALUES( 1, 'temp');
CREATE TABLE hyper_constr ( id integer, time bigint, temp float, mid integer CREATE TABLE hyper_constr ( id integer, time bigint, temp float, mid integer
,PRIMARY KEY (id, time) ,PRIMARY KEY (id, time)
,FOREIGN KEY ( mid) REFERENCES measure(id) ,FOREIGN KEY ( mid) REFERENCES measure(id)
,CHECK ( temp > 10) ,CHECK ( temp > 10)
); );
SELECT create_hypertable('hyper_constr', 'time', chunk_time_interval => 10); SELECT create_hypertable('hyper_constr', 'time', chunk_time_interval => 10);
@ -316,11 +316,11 @@ CREATE FOREIGN TABLE child_hyper_constr
SELECT _timescaledb_internal.attach_osm_table_chunk('hyper_constr', 'child_hyper_constr'); SELECT _timescaledb_internal.attach_osm_table_chunk('hyper_constr', 'child_hyper_constr');
SELECT chunk_name, range_start, range_end SELECT chunk_name, range_start, range_end
FROM timescaledb_information.chunks FROM timescaledb_information.chunks
WHERE hypertable_name = 'hyper_constr' ORDER BY 1; WHERE hypertable_name = 'hyper_constr' ORDER BY 1;
SELECT * FROM hyper_constr order by time; SELECT * FROM hyper_constr order by time;
--verify the check constraint exists on the OSM chunk --verify the check constraint exists on the OSM chunk
SELECT conname FROM pg_constraint SELECT conname FROM pg_constraint
where conrelid = 'child_hyper_constr'::regclass ORDER BY 1; where conrelid = 'child_hyper_constr'::regclass ORDER BY 1;