template

Author: svenklemm

tsl/test/sql/compress_bloom_sparse.sql.in

@@ -31,10 +31,11 @@ select count(compress_chunk(x)) from show_chunks('bloom') x;
 select * from settings;
 vacuum full analyze bloom;
 
-select schema_name || '.' || table_name chunk from _timescaledb_catalog.chunk
-    where id = (select compressed_chunk_id from _timescaledb_catalog.chunk
-        where hypertable_id = (select id from _timescaledb_catalog.hypertable
-            where table_name = 'bloom') limit 1)
+select cs.compress_relid::regclass chunk from _timescaledb_catalog.chunk ch
+    join _timescaledb_catalog.compression_settings cs
+        on cs.relid = format('%I.%I', ch.schema_name, ch.table_name)::regclass
+    where ch.hypertable_id = (select id from _timescaledb_catalog.hypertable
+        where table_name = 'bloom') limit 1
 \gset
 
 select * from test.show_columns_ext(:'chunk'::regclass);
@@ -288,10 +289,11 @@ select count(compress_chunk(x)) from show_chunks('badtable') x;
 
 vacuum full analyze badtable;
 
-select schema_name || '.' || table_name chunk from _timescaledb_catalog.chunk
-    where id = (select compressed_chunk_id from _timescaledb_catalog.chunk
-        where hypertable_id = (select id from _timescaledb_catalog.hypertable
-            where table_name = 'badtable') limit 1)
+select cs.compress_relid::regclass chunk from _timescaledb_catalog.chunk ch
+    join _timescaledb_catalog.compression_settings cs
+        on cs.relid = format('%I.%I', ch.schema_name, ch.table_name)::regclass
+    where ch.hypertable_id = (select id from _timescaledb_catalog.hypertable
+        where table_name = 'badtable') limit 1
 \gset
 
 select * from test.show_columns_ext(:'chunk'::regclass);
@@ -324,10 +326,11 @@ select * from settings;
 vacuum full analyze badtable;
 
 -- Verify that we actually got the bloom filter index.
-select schema_name || '.' || table_name chunk from _timescaledb_catalog.chunk
-    where id = (select compressed_chunk_id from _timescaledb_catalog.chunk
-        where hypertable_id = (select id from _timescaledb_catalog.hypertable
-            where table_name = 'badtable') limit 1)
+select cs.compress_relid::regclass chunk from _timescaledb_catalog.chunk ch
+    join _timescaledb_catalog.compression_settings cs
+        on cs.relid = format('%I.%I', ch.schema_name, ch.table_name)::regclass
+    where ch.hypertable_id = (select id from _timescaledb_catalog.hypertable
+        where table_name = 'badtable') limit 1
 \gset
 
 select * from test.show_columns_ext(:'chunk'::regclass);

tsl/test/sql/compression_update_delete.sql.in

@@ -16,8 +16,10 @@ SELECT
 FROM
    _timescaledb_catalog.hypertable h JOIN
   _timescaledb_catalog.chunk c ON h.id = c.hypertable_id
+   LEFT JOIN _timescaledb_catalog.compression_settings cs
+ON cs.relid = format('%I.%I', c.schema_name, c.table_name)::regclass
    LEFT JOIN _timescaledb_catalog.chunk comp
-ON comp.id = c.compressed_chunk_id
+ON cs.compress_relid = format('%I.%I', comp.schema_name, comp.table_name)::regclass
 ;
 
 CREATE TABLE sample_table (
@@ -1158,10 +1160,11 @@ AND ch1.table_name LIKE '_hyper%'
 ORDER BY ch1.id LIMIT 1 \gset
 
 SELECT ch2.schema_name|| '.' || ch2.table_name AS "COMP_CHUNK_1"
-FROM _timescaledb_catalog.chunk ch1, _timescaledb_catalog.chunk ch2, _timescaledb_catalog.hypertable ht
+FROM _timescaledb_catalog.chunk ch1, _timescaledb_catalog.chunk ch2, _timescaledb_catalog.hypertable ht, _timescaledb_catalog.compression_settings cs
 WHERE ht.table_name = 'index_scan_test'
 AND ch1.hypertable_id = ht.id
-AND ch1.compressed_chunk_id  = ch2.id
+AND cs.relid = format('%I.%I', ch1.schema_name, ch1.table_name)::regclass
+AND cs.compress_relid = format('%I.%I', ch2.schema_name, ch2.table_name)::regclass
 ORDER BY ch2.id LIMIT 1 \gset
 
 INSERT INTO index_scan_test(time,device_id,value) SELECT time, device_id, device_id + 0.5 FROM generate_series('2000-01-01 0:00:00+0'::timestamptz,'2000-01-05 23:55:00+0','1m') gtime(time), generate_series(1,5,1) gdevice(device_id);