feat: add sqlness test for bloom filter index (#5240)

* feat: add sqlness test for bloom filter index Signed-off-by: Ruihang Xia <waynestxia@gmail.com> * drop table after finished Signed-off-by: Ruihang Xia <waynestxia@gmail.com> * redact more variables Signed-off-by: Ruihang Xia <waynestxia@gmail.com> --------- Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
GreptimeTeam · Dec 27, 2024 · 11bab0c · 11bab0c
1 parent 588f675
commit 11bab0c
Show file tree

Hide file tree

Showing 4 changed files with 137 additions and 0 deletions.
diff --git a/...mmon/create/create_with_skip_index.result → .../create/create_with_skipping_index.result b/...mmon/create/create_with_skip_index.result → .../create/create_with_skipping_index.result
diff --git a/.../common/create/create_with_skip_index.sql → ...mon/create/create_with_skipping_index.sql b/.../common/create/create_with_skip_index.sql → ...mon/create/create_with_skipping_index.sql
diff --git a/tests/cases/standalone/common/select/skipping_index.result b/tests/cases/standalone/common/select/skipping_index.result
@@ -0,0 +1,99 @@
+create table
+    skipping_table (
+        ts timestamp time index,
+        id string skipping index,
+        `name` string skipping index
+        with
+            (granularity = 8192),
+    );
+
+Affected Rows: 0
+
+INSERT INTO skipping_table VALUES (1664356800000, 'id1', 'name1');
+
+Affected Rows: 1
+
+ADMIN FLUSH_TABLE('skipping_table');
+
++-------------------------------------+
+| ADMIN FLUSH_TABLE('skipping_table') |
++-------------------------------------+
+| 0                                   |
++-------------------------------------+
+
+INSERT INTO skipping_table VALUES (1664356801000, 'id2', 'name2');
+
+Affected Rows: 1
+
+ADMIN FLUSH_TABLE('skipping_table');
+
++-------------------------------------+
+| ADMIN FLUSH_TABLE('skipping_table') |
++-------------------------------------+
+| 0                                   |
++-------------------------------------+
+
+INSERT INTO skipping_table VALUES (1664356802000, 'id3', 'name3');
+
+Affected Rows: 1
+
+ADMIN FLUSH_TABLE('skipping_table');
+
++-------------------------------------+
+| ADMIN FLUSH_TABLE('skipping_table') |
++-------------------------------------+
+| 0                                   |
++-------------------------------------+
+
+-- SQLNESS REPLACE (metrics.*) REDACTED
+-- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
+-- SQLNESS REPLACE (-+) -
+-- SQLNESS REPLACE (\s\s+) _
+-- SQLNESS REPLACE (peers.*) REDACTED
+-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
+EXPLAIN ANALYZE SELECT * FROM skipping_table WHERE id = 'id2' ORDER BY `name`;
+
++-+-+-+
+| stage | node | plan_|
++-+-+-+
+| 0_| 0_|_MergeScanExec: REDACTED
+|_|_|_|
+| 1_| 0_|_SortPreservingMergeExec: [name@2 ASC NULLS LAST] REDACTED
+|_|_|_CoalesceBatchesExec: target_batch_size=8192 REDACTED
+|_|_|_SortExec: expr=[name@2 ASC NULLS LAST], preserve_partitioning=[true] REDACTED
+|_|_|_CoalesceBatchesExec: target_batch_size=8192 REDACTED
+|_|_|_FilterExec: id@1 = id2 REDACTED
+|_|_|_RepartitionExec: partitioning=REDACTED
+|_|_|_SeqScan: region=REDACTED, partition_count=3 (0 memtable ranges, 3 file 3 ranges) REDACTED
+|_|_|_|
+|_|_| Total rows: 1_|
++-+-+-+
+
+-- SQLNESS REPLACE (metrics.*) REDACTED
+-- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
+-- SQLNESS REPLACE (-+) -
+-- SQLNESS REPLACE (\s\s+) _
+-- SQLNESS REPLACE (peers.*) REDACTED
+-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
+EXPLAIN ANALYZE SELECT * FROM skipping_table WHERE id = 'id5' ORDER BY `name`;
+
++-+-+-+
+| stage | node | plan_|
++-+-+-+
+| 0_| 0_|_MergeScanExec: REDACTED
+|_|_|_|
+| 1_| 0_|_SortPreservingMergeExec: [name@2 ASC NULLS LAST] REDACTED
+|_|_|_CoalesceBatchesExec: target_batch_size=8192 REDACTED
+|_|_|_SortExec: expr=[name@2 ASC NULLS LAST], preserve_partitioning=[true] REDACTED
+|_|_|_CoalesceBatchesExec: target_batch_size=8192 REDACTED
+|_|_|_FilterExec: id@1 = id5 REDACTED
+|_|_|_RepartitionExec: partitioning=REDACTED
+|_|_|_SeqScan: region=REDACTED, partition_count=3 (0 memtable ranges, 3 file 3 ranges) REDACTED
+|_|_|_|
+|_|_| Total rows: 0_|
++-+-+-+
+
+DROP TABLE IF EXISTS skipping_table;
+
+Affected Rows: 0
+
diff --git a/tests/cases/standalone/common/select/skipping_index.sql b/tests/cases/standalone/common/select/skipping_index.sql
@@ -0,0 +1,38 @@
+create table
+    skipping_table (
+        ts timestamp time index,
+        id string skipping index,
+        `name` string skipping index
+        with
+            (granularity = 8192),
+    );
+
+INSERT INTO skipping_table VALUES (1664356800000, 'id1', 'name1');
+
+ADMIN FLUSH_TABLE('skipping_table');
+
+INSERT INTO skipping_table VALUES (1664356801000, 'id2', 'name2');
+
+ADMIN FLUSH_TABLE('skipping_table');
+
+INSERT INTO skipping_table VALUES (1664356802000, 'id3', 'name3');
+
+ADMIN FLUSH_TABLE('skipping_table');
+
+-- SQLNESS REPLACE (metrics.*) REDACTED
+-- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
+-- SQLNESS REPLACE (-+) -
+-- SQLNESS REPLACE (\s\s+) _
+-- SQLNESS REPLACE (peers.*) REDACTED
+-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
+EXPLAIN ANALYZE SELECT * FROM skipping_table WHERE id = 'id2' ORDER BY `name`;
+
+-- SQLNESS REPLACE (metrics.*) REDACTED
+-- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
+-- SQLNESS REPLACE (-+) -
+-- SQLNESS REPLACE (\s\s+) _
+-- SQLNESS REPLACE (peers.*) REDACTED
+-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
+EXPLAIN ANALYZE SELECT * FROM skipping_table WHERE id = 'id5' ORDER BY `name`;
+
+DROP TABLE IF EXISTS skipping_table;