postgres/timescaledb
1
0
Fork 0
mirror of https://github.com/timescale/timescaledb.git synced 2025-05-16 02:23:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add more ordered append tests

Browse Source 
This patch adds tests for hypertables with indexes not on all chunks
and chunks with removed columns to the ordered append tests.
This commit is contained in:
Sven Klemm 2019-05-02 17:23:40 +02:00 committed by Sven Klemm
parent bfabb30be0
commit fac493b83a
5 changed files with 452 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

131
test/expected/plan_ordered_append-10.out
View File

@ -98,6 +98,45 @@ ANALYZE ordered_append;
ANALYZE ordered_append_reverse;
ANALYZE dimension_last;
ANALYZE dimension_only;
-- create hypertable with indexes not on all chunks
CREATE TABLE ht_missing_indexes(time timestamptz NOT NULL, device_id int, value float);
SELECT create_hypertable('ht_missing_indexes','time');
create_hypertable
---------------------------------
(5,public,ht_missing_indexes,t)
(1 row)
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 1, 0.5;
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 2, 1.5;
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 3, 2.5;
-- drop index from 2nd chunk of ht_missing_indexes
SELECT format('%I.%I',i.schemaname,i.indexname) AS "INDEX_NAME"
FROM _timescaledb_catalog.chunk c
INNER JOIN _timescaledb_catalog.hypertable ht ON c.hypertable_id = ht.id
INNER JOIN pg_indexes i ON i.schemaname = c.schema_name AND i.tablename=c.table_name
WHERE ht.table_name = 'ht_missing_indexes'
ORDER BY c.id LIMIT 1 OFFSET 1 \gset
DROP INDEX :INDEX_NAME;
ANALYZE ht_missing_indexes;
-- create hypertable with with dropped columns
CREATE TABLE ht_dropped_columns(c1 int, c2 int, c3 int, c4 int, c5 int, time timestamptz NOT NULL, device_id int, value float);
SELECT create_hypertable('ht_dropped_columns','time');
create_hypertable
---------------------------------
(6,public,ht_dropped_columns,t)
(1 row)
ALTER TABLE ht_dropped_columns DROP COLUMN c1;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-01'::timestamptz,'2000-01-02'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c2;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-08'::timestamptz,'2000-01-09'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c3;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-15'::timestamptz,'2000-01-16'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c4;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-22'::timestamptz,'2000-01-23'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c5;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-29'::timestamptz,'2000-01-30'::timestamptz,'1m'::interval), 1, 0.5;
ANALYZE ht_dropped_columns;
\ir :TEST_QUERY_NAME
-- This file and its contents are licensed under the Apache License 2.0.
-- Please see the included NOTICE for copyright information and
@ -124,13 +163,21 @@ ORDER BY ht.table_name, range_start;
dimension_only | _hyper_4_12_chunk | 946857600000000
dimension_only | _hyper_4_13_chunk | 947030400000000
dimension_only | _hyper_4_14_chunk | 947203200000000
ht_dropped_columns | _hyper_6_18_chunk | 946512000000000
ht_dropped_columns | _hyper_6_19_chunk | 947116800000000
ht_dropped_columns | _hyper_6_20_chunk | 947721600000000
ht_dropped_columns | _hyper_6_21_chunk | 948326400000000
ht_dropped_columns | _hyper_6_22_chunk | 948931200000000
ht_missing_indexes | _hyper_5_15_chunk | 946512000000000
ht_missing_indexes | _hyper_5_16_chunk | 947116800000000
ht_missing_indexes | _hyper_5_17_chunk | 947721600000000
ordered_append | _hyper_1_1_chunk | 946512000000000
ordered_append | _hyper_1_2_chunk | 947116800000000
ordered_append | _hyper_1_3_chunk | 947721600000000
ordered_append_reverse | _hyper_2_6_chunk | 946512000000000
ordered_append_reverse | _hyper_2_5_chunk | 947116800000000
ordered_append_reverse | _hyper_2_4_chunk | 947721600000000
(14 rows)
(22 rows)
-- test ASC for ordered chunks
:PREFIX SELECT
@ -681,5 +728,87 @@ LIMIT 2;
-> Seq Scan on devices (actual rows=1 loops=1)
(10 rows)
-- test hypertable with index missing on one chunk
-- does not yet use ordered append
:PREFIX SELECT
time, device_id, value
FROM ht_missing_indexes
ORDER BY time ASC LIMIT 1;
QUERY PLAN
----------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=1 loops=1)
-> Merge Append (actual rows=1 loops=1)
Sort Key: _hyper_5_15_chunk."time"
-> Index Scan Backward using _hyper_5_15_chunk_ht_missing_indexes_time_idx on _hyper_5_15_chunk (actual rows=1 loops=1)
-> Sort (actual rows=1 loops=1)
Sort Key: _hyper_5_16_chunk."time"
Sort Method: top-N heapsort Memory: 25kB
-> Seq Scan on _hyper_5_16_chunk (actual rows=30240 loops=1)
-> Index Scan Backward using _hyper_5_17_chunk_ht_missing_indexes_time_idx on _hyper_5_17_chunk (actual rows=1 loops=1)
(9 rows)
-- test hypertable with index missing on one chunk
-- does not yet use ordered append
:PREFIX SELECT
time, device_id, value
FROM ht_missing_indexes
WHERE device_id = 2
ORDER BY time DESC LIMIT 1;
QUERY PLAN
-------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=1 loops=1)
-> Merge Append (actual rows=1 loops=1)
Sort Key: _hyper_5_17_chunk."time" DESC
-> Index Scan using _hyper_5_17_chunk_ht_missing_indexes_time_idx on _hyper_5_17_chunk (actual rows=1 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 1
-> Sort (actual rows=1 loops=1)
Sort Key: _hyper_5_16_chunk."time" DESC
Sort Method: top-N heapsort Memory: 25kB
-> Seq Scan on _hyper_5_16_chunk (actual rows=10080 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 20160
-> Index Scan using _hyper_5_15_chunk_ht_missing_indexes_time_idx on _hyper_5_15_chunk (actual rows=1 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 1
(15 rows)
-- test hypertable with dropped columns
:PREFIX SELECT
time, device_id, value
FROM ht_dropped_columns
ORDER BY time ASC LIMIT 1;
QUERY PLAN
----------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=1 loops=1)
-> Append (actual rows=1 loops=1)
-> Index Scan Backward using _hyper_6_18_chunk_ht_dropped_columns_time_idx on _hyper_6_18_chunk (actual rows=1 loops=1)
-> Index Scan Backward using _hyper_6_19_chunk_ht_dropped_columns_time_idx on _hyper_6_19_chunk (never executed)
-> Index Scan Backward using _hyper_6_20_chunk_ht_dropped_columns_time_idx on _hyper_6_20_chunk (never executed)
-> Index Scan Backward using _hyper_6_21_chunk_ht_dropped_columns_time_idx on _hyper_6_21_chunk (never executed)
-> Index Scan Backward using _hyper_6_22_chunk_ht_dropped_columns_time_idx on _hyper_6_22_chunk (never executed)
(7 rows)
-- test hypertable with dropped columns
:PREFIX SELECT
time, device_id, value
FROM ht_dropped_columns
WHERE device_id = 1
ORDER BY time DESC;
QUERY PLAN
----------------------------------------------------------------------------------------------------------------------
Append (actual rows=7205 loops=1)
-> Index Scan using _hyper_6_22_chunk_ht_dropped_columns_time_idx on _hyper_6_22_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
-> Index Scan using _hyper_6_21_chunk_ht_dropped_columns_time_idx on _hyper_6_21_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
-> Index Scan using _hyper_6_20_chunk_ht_dropped_columns_time_idx on _hyper_6_20_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
-> Index Scan using _hyper_6_19_chunk_ht_dropped_columns_time_idx on _hyper_6_19_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
-> Index Scan using _hyper_6_18_chunk_ht_dropped_columns_time_idx on _hyper_6_18_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
(11 rows)
--generate the results into two different files
\set ECHO errors

131
test/expected/plan_ordered_append-11.out
View File

@ -98,6 +98,45 @@ ANALYZE ordered_append;
ANALYZE ordered_append_reverse;
ANALYZE dimension_last;
ANALYZE dimension_only;
-- create hypertable with indexes not on all chunks
CREATE TABLE ht_missing_indexes(time timestamptz NOT NULL, device_id int, value float);
SELECT create_hypertable('ht_missing_indexes','time');
create_hypertable
---------------------------------
(5,public,ht_missing_indexes,t)
(1 row)
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 1, 0.5;
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 2, 1.5;
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 3, 2.5;
-- drop index from 2nd chunk of ht_missing_indexes
SELECT format('%I.%I',i.schemaname,i.indexname) AS "INDEX_NAME"
FROM _timescaledb_catalog.chunk c
INNER JOIN _timescaledb_catalog.hypertable ht ON c.hypertable_id = ht.id
INNER JOIN pg_indexes i ON i.schemaname = c.schema_name AND i.tablename=c.table_name
WHERE ht.table_name = 'ht_missing_indexes'
ORDER BY c.id LIMIT 1 OFFSET 1 \gset
DROP INDEX :INDEX_NAME;
ANALYZE ht_missing_indexes;
-- create hypertable with with dropped columns
CREATE TABLE ht_dropped_columns(c1 int, c2 int, c3 int, c4 int, c5 int, time timestamptz NOT NULL, device_id int, value float);
SELECT create_hypertable('ht_dropped_columns','time');
create_hypertable
---------------------------------
(6,public,ht_dropped_columns,t)
(1 row)
ALTER TABLE ht_dropped_columns DROP COLUMN c1;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-01'::timestamptz,'2000-01-02'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c2;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-08'::timestamptz,'2000-01-09'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c3;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-15'::timestamptz,'2000-01-16'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c4;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-22'::timestamptz,'2000-01-23'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c5;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-29'::timestamptz,'2000-01-30'::timestamptz,'1m'::interval), 1, 0.5;
ANALYZE ht_dropped_columns;
\ir :TEST_QUERY_NAME
-- This file and its contents are licensed under the Apache License 2.0.
-- Please see the included NOTICE for copyright information and
@ -124,13 +163,21 @@ ORDER BY ht.table_name, range_start;
dimension_only | _hyper_4_12_chunk | 946857600000000
dimension_only | _hyper_4_13_chunk | 947030400000000
dimension_only | _hyper_4_14_chunk | 947203200000000
ht_dropped_columns | _hyper_6_18_chunk | 946512000000000
ht_dropped_columns | _hyper_6_19_chunk | 947116800000000
ht_dropped_columns | _hyper_6_20_chunk | 947721600000000
ht_dropped_columns | _hyper_6_21_chunk | 948326400000000
ht_dropped_columns | _hyper_6_22_chunk | 948931200000000
ht_missing_indexes | _hyper_5_15_chunk | 946512000000000
ht_missing_indexes | _hyper_5_16_chunk | 947116800000000
ht_missing_indexes | _hyper_5_17_chunk | 947721600000000
ordered_append | _hyper_1_1_chunk | 946512000000000
ordered_append | _hyper_1_2_chunk | 947116800000000
ordered_append | _hyper_1_3_chunk | 947721600000000
ordered_append_reverse | _hyper_2_6_chunk | 946512000000000
ordered_append_reverse | _hyper_2_5_chunk | 947116800000000
ordered_append_reverse | _hyper_2_4_chunk | 947721600000000
(14 rows)
(22 rows)
-- test ASC for ordered chunks
:PREFIX SELECT
@ -679,5 +726,87 @@ LIMIT 2;
-> Seq Scan on devices (actual rows=1 loops=1)
(10 rows)
-- test hypertable with index missing on one chunk
-- does not yet use ordered append
:PREFIX SELECT
time, device_id, value
FROM ht_missing_indexes
ORDER BY time ASC LIMIT 1;
QUERY PLAN
----------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=1 loops=1)
-> Merge Append (actual rows=1 loops=1)
Sort Key: _hyper_5_15_chunk."time"
-> Index Scan Backward using _hyper_5_15_chunk_ht_missing_indexes_time_idx on _hyper_5_15_chunk (actual rows=1 loops=1)
-> Sort (actual rows=1 loops=1)
Sort Key: _hyper_5_16_chunk."time"
Sort Method: top-N heapsort Memory: 25kB
-> Seq Scan on _hyper_5_16_chunk (actual rows=30240 loops=1)
-> Index Scan Backward using _hyper_5_17_chunk_ht_missing_indexes_time_idx on _hyper_5_17_chunk (actual rows=1 loops=1)
(9 rows)
-- test hypertable with index missing on one chunk
-- does not yet use ordered append
:PREFIX SELECT
time, device_id, value
FROM ht_missing_indexes
WHERE device_id = 2
ORDER BY time DESC LIMIT 1;
QUERY PLAN
-------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=1 loops=1)
-> Merge Append (actual rows=1 loops=1)
Sort Key: _hyper_5_17_chunk."time" DESC
-> Index Scan using _hyper_5_17_chunk_ht_missing_indexes_time_idx on _hyper_5_17_chunk (actual rows=1 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 1
-> Sort (actual rows=1 loops=1)
Sort Key: _hyper_5_16_chunk."time" DESC
Sort Method: top-N heapsort Memory: 25kB
-> Seq Scan on _hyper_5_16_chunk (actual rows=10080 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 20160
-> Index Scan using _hyper_5_15_chunk_ht_missing_indexes_time_idx on _hyper_5_15_chunk (actual rows=1 loops=1)
Filter: (device_id = 2)
Rows Removed by Filter: 1
(15 rows)
-- test hypertable with dropped columns
:PREFIX SELECT
time, device_id, value
FROM ht_dropped_columns
ORDER BY time ASC LIMIT 1;
QUERY PLAN
----------------------------------------------------------------------------------------------------------------------------------
Limit (actual rows=1 loops=1)
-> Append (actual rows=1 loops=1)
-> Index Scan Backward using _hyper_6_18_chunk_ht_dropped_columns_time_idx on _hyper_6_18_chunk (actual rows=1 loops=1)
-> Index Scan Backward using _hyper_6_19_chunk_ht_dropped_columns_time_idx on _hyper_6_19_chunk (never executed)
-> Index Scan Backward using _hyper_6_20_chunk_ht_dropped_columns_time_idx on _hyper_6_20_chunk (never executed)
-> Index Scan Backward using _hyper_6_21_chunk_ht_dropped_columns_time_idx on _hyper_6_21_chunk (never executed)
-> Index Scan Backward using _hyper_6_22_chunk_ht_dropped_columns_time_idx on _hyper_6_22_chunk (never executed)
(7 rows)
-- test hypertable with dropped columns
:PREFIX SELECT
time, device_id, value
FROM ht_dropped_columns
WHERE device_id = 1
ORDER BY time DESC;
QUERY PLAN
----------------------------------------------------------------------------------------------------------------------
Append (actual rows=7205 loops=1)
-> Index Scan using _hyper_6_22_chunk_ht_dropped_columns_time_idx on _hyper_6_22_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
-> Index Scan using _hyper_6_21_chunk_ht_dropped_columns_time_idx on _hyper_6_21_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
-> Index Scan using _hyper_6_20_chunk_ht_dropped_columns_time_idx on _hyper_6_20_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
-> Index Scan using _hyper_6_19_chunk_ht_dropped_columns_time_idx on _hyper_6_19_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
-> Index Scan using _hyper_6_18_chunk_ht_dropped_columns_time_idx on _hyper_6_18_chunk (actual rows=1441 loops=1)
Filter: (device_id = 1)
(11 rows)
--generate the results into two different files
\set ECHO errors

126
test/expected/plan_ordered_append-9.6.out
View File

@ -98,6 +98,45 @@ ANALYZE ordered_append;
ANALYZE ordered_append_reverse;
ANALYZE dimension_last;
ANALYZE dimension_only;
-- create hypertable with indexes not on all chunks
CREATE TABLE ht_missing_indexes(time timestamptz NOT NULL, device_id int, value float);
SELECT create_hypertable('ht_missing_indexes','time');
create_hypertable
---------------------------------
(5,public,ht_missing_indexes,t)
(1 row)
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 1, 0.5;
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 2, 1.5;
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 3, 2.5;
-- drop index from 2nd chunk of ht_missing_indexes
SELECT format('%I.%I',i.schemaname,i.indexname) AS "INDEX_NAME"
FROM _timescaledb_catalog.chunk c
INNER JOIN _timescaledb_catalog.hypertable ht ON c.hypertable_id = ht.id
INNER JOIN pg_indexes i ON i.schemaname = c.schema_name AND i.tablename=c.table_name
WHERE ht.table_name = 'ht_missing_indexes'
ORDER BY c.id LIMIT 1 OFFSET 1 \gset
DROP INDEX :INDEX_NAME;
ANALYZE ht_missing_indexes;
-- create hypertable with with dropped columns
CREATE TABLE ht_dropped_columns(c1 int, c2 int, c3 int, c4 int, c5 int, time timestamptz NOT NULL, device_id int, value float);
SELECT create_hypertable('ht_dropped_columns','time');
create_hypertable
---------------------------------
(6,public,ht_dropped_columns,t)
(1 row)
ALTER TABLE ht_dropped_columns DROP COLUMN c1;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-01'::timestamptz,'2000-01-02'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c2;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-08'::timestamptz,'2000-01-09'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c3;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-15'::timestamptz,'2000-01-16'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c4;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-22'::timestamptz,'2000-01-23'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c5;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-29'::timestamptz,'2000-01-30'::timestamptz,'1m'::interval), 1, 0.5;
ANALYZE ht_dropped_columns;
\ir :TEST_QUERY_NAME
-- This file and its contents are licensed under the Apache License 2.0.
-- Please see the included NOTICE for copyright information and
@ -124,13 +163,21 @@ ORDER BY ht.table_name, range_start;
dimension_only | _hyper_4_12_chunk | 946857600000000
dimension_only | _hyper_4_13_chunk | 947030400000000
dimension_only | _hyper_4_14_chunk | 947203200000000
ht_dropped_columns | _hyper_6_18_chunk | 946512000000000
ht_dropped_columns | _hyper_6_19_chunk | 947116800000000
ht_dropped_columns | _hyper_6_20_chunk | 947721600000000
ht_dropped_columns | _hyper_6_21_chunk | 948326400000000
ht_dropped_columns | _hyper_6_22_chunk | 948931200000000
ht_missing_indexes | _hyper_5_15_chunk | 946512000000000
ht_missing_indexes | _hyper_5_16_chunk | 947116800000000
ht_missing_indexes | _hyper_5_17_chunk | 947721600000000
ordered_append | _hyper_1_1_chunk | 946512000000000
ordered_append | _hyper_1_2_chunk | 947116800000000
ordered_append | _hyper_1_3_chunk | 947721600000000
ordered_append_reverse | _hyper_2_6_chunk | 946512000000000
ordered_append_reverse | _hyper_2_5_chunk | 947116800000000
ordered_append_reverse | _hyper_2_4_chunk | 947721600000000
(14 rows)
(22 rows)
-- test ASC for ordered chunks
:PREFIX SELECT
@ -664,5 +711,82 @@ LIMIT 2;
-> Seq Scan on devices
(10 rows)
-- test hypertable with index missing on one chunk
-- does not yet use ordered append
:PREFIX SELECT
time, device_id, value
FROM ht_missing_indexes
ORDER BY time ASC LIMIT 1;
QUERY PLAN
----------------------------------------------------------------------------------------------------------
Limit
-> Merge Append
Sort Key: _hyper_5_15_chunk."time"
-> Index Scan Backward using _hyper_5_15_chunk_ht_missing_indexes_time_idx on _hyper_5_15_chunk
-> Sort
Sort Key: _hyper_5_16_chunk."time"
-> Seq Scan on _hyper_5_16_chunk
-> Index Scan Backward using _hyper_5_17_chunk_ht_missing_indexes_time_idx on _hyper_5_17_chunk
(8 rows)
-- test hypertable with index missing on one chunk
-- does not yet use ordered append
:PREFIX SELECT
time, device_id, value
FROM ht_missing_indexes
WHERE device_id = 2
ORDER BY time DESC LIMIT 1;
QUERY PLAN
-------------------------------------------------------------------------------------------------
Limit
-> Merge Append
Sort Key: _hyper_5_17_chunk."time" DESC
-> Index Scan using _hyper_5_17_chunk_ht_missing_indexes_time_idx on _hyper_5_17_chunk
Filter: (device_id = 2)
-> Sort
Sort Key: _hyper_5_16_chunk."time" DESC
-> Seq Scan on _hyper_5_16_chunk
Filter: (device_id = 2)
-> Index Scan using _hyper_5_15_chunk_ht_missing_indexes_time_idx on _hyper_5_15_chunk
Filter: (device_id = 2)
(11 rows)
-- test hypertable with dropped columns
:PREFIX SELECT
time, device_id, value
FROM ht_dropped_columns
ORDER BY time ASC LIMIT 1;
QUERY PLAN
----------------------------------------------------------------------------------------------------------
Limit
-> Append
-> Index Scan Backward using _hyper_6_18_chunk_ht_dropped_columns_time_idx on _hyper_6_18_chunk
-> Index Scan Backward using _hyper_6_19_chunk_ht_dropped_columns_time_idx on _hyper_6_19_chunk
-> Index Scan Backward using _hyper_6_20_chunk_ht_dropped_columns_time_idx on _hyper_6_20_chunk
-> Index Scan Backward using _hyper_6_21_chunk_ht_dropped_columns_time_idx on _hyper_6_21_chunk
-> Index Scan Backward using _hyper_6_22_chunk_ht_dropped_columns_time_idx on _hyper_6_22_chunk
(7 rows)
-- test hypertable with dropped columns
:PREFIX SELECT
time, device_id, value
FROM ht_dropped_columns
WHERE device_id = 1
ORDER BY time DESC;
QUERY PLAN
-------------------------------------------------------------------------------------------
Append
-> Index Scan using _hyper_6_22_chunk_ht_dropped_columns_time_idx on _hyper_6_22_chunk
Filter: (device_id = 1)
-> Index Scan using _hyper_6_21_chunk_ht_dropped_columns_time_idx on _hyper_6_21_chunk
Filter: (device_id = 1)
-> Index Scan using _hyper_6_20_chunk_ht_dropped_columns_time_idx on _hyper_6_20_chunk
Filter: (device_id = 1)
-> Index Scan using _hyper_6_19_chunk_ht_dropped_columns_time_idx on _hyper_6_19_chunk
Filter: (device_id = 1)
-> Index Scan using _hyper_6_18_chunk_ht_dropped_columns_time_idx on _hyper_6_18_chunk
Filter: (device_id = 1)
(11 rows)
--generate the results into two different files
\set ECHO errors

39
test/sql/include/plan_ordered_append_load.sql
View File

@ -65,3 +65,42 @@ ANALYZE ordered_append_reverse;
ANALYZE dimension_last;
ANALYZE dimension_only;
-- create hypertable with indexes not on all chunks
CREATE TABLE ht_missing_indexes(time timestamptz NOT NULL, device_id int, value float);
SELECT create_hypertable('ht_missing_indexes','time');
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 1, 0.5;
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 2, 1.5;
INSERT INTO ht_missing_indexes SELECT generate_series('2000-01-01'::timestamptz,'2000-01-18'::timestamptz,'1m'::interval), 3, 2.5;
-- drop index from 2nd chunk of ht_missing_indexes
SELECT format('%I.%I',i.schemaname,i.indexname) AS "INDEX_NAME"
FROM _timescaledb_catalog.chunk c
INNER JOIN _timescaledb_catalog.hypertable ht ON c.hypertable_id = ht.id
INNER JOIN pg_indexes i ON i.schemaname = c.schema_name AND i.tablename=c.table_name
WHERE ht.table_name = 'ht_missing_indexes'
ORDER BY c.id LIMIT 1 OFFSET 1 \gset
DROP INDEX :INDEX_NAME;
ANALYZE ht_missing_indexes;
-- create hypertable with with dropped columns
CREATE TABLE ht_dropped_columns(c1 int, c2 int, c3 int, c4 int, c5 int, time timestamptz NOT NULL, device_id int, value float);
SELECT create_hypertable('ht_dropped_columns','time');
ALTER TABLE ht_dropped_columns DROP COLUMN c1;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-01'::timestamptz,'2000-01-02'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c2;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-08'::timestamptz,'2000-01-09'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c3;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-15'::timestamptz,'2000-01-16'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c4;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-22'::timestamptz,'2000-01-23'::timestamptz,'1m'::interval), 1, 0.5;
ALTER TABLE ht_dropped_columns DROP COLUMN c5;
INSERT INTO ht_dropped_columns(time,device_id,value) SELECT generate_series('2000-01-29'::timestamptz,'2000-01-30'::timestamptz,'1m'::interval), 1, 0.5;
ANALYZE ht_dropped_columns;

28
test/sql/include/plan_ordered_append_query.sql
View File

@ -188,3 +188,31 @@ INNER JOIN devices USING(device_id)
ORDER BY dimension_last.time DESC
LIMIT 2;
-- test hypertable with index missing on one chunk
-- does not yet use ordered append
:PREFIX SELECT
time, device_id, value
FROM ht_missing_indexes
ORDER BY time ASC LIMIT 1;
-- test hypertable with index missing on one chunk
-- does not yet use ordered append
:PREFIX SELECT
time, device_id, value
FROM ht_missing_indexes
WHERE device_id = 2
ORDER BY time DESC LIMIT 1;
-- test hypertable with dropped columns
:PREFIX SELECT
time, device_id, value
FROM ht_dropped_columns
ORDER BY time ASC LIMIT 1;
-- test hypertable with dropped columns
:PREFIX SELECT
time, device_id, value
FROM ht_dropped_columns
WHERE device_id = 1
ORDER BY time DESC;