rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-25 01:10:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: adds sqlness test for TTL (#5063)

Browse Source 
* test: adds sqlness test for TTL

* chore: restart cluster

* fix: typo

* test: adds database TTL with metric engine tables
This commit is contained in:
dennis zhuang
2024-12-03 19:32:40 +08:00
committed by GitHub
parent a51853846a
commit ff4c153d4b
10 changed files with 660 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

108
tests/cases/standalone/common/ttl/alter_table_ttl.result Normal file
View File

@@ -0,0 +1,108 @@
CREATE TABLE test_ttl(ts TIMESTAMP TIME INDEX, val INT, PRIMARY KEY(val)) WITH (ttl = '1 day');
Affected Rows: 0
INSERT INTO test_ttl VALUES
(now(), 1),
(now(), 2),
(now(), 3);
Affected Rows: 3
SELECT val from test_ttl;
+-----+
| val |
+-----+
| 1 |
| 2 |
| 3 |
+-----+
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
+-------------------------------+
| ADMIN flush_table('test_ttl') |
+-------------------------------+
| 0 |
+-------------------------------+
ADMIN compact_table('test_ttl');
+---------------------------------+
| ADMIN compact_table('test_ttl') |
+---------------------------------+
| 0 |
+---------------------------------+
SELECT val from test_ttl;
+-----+
| val |
+-----+
| 1 |
| 2 |
| 3 |
+-----+
ALTER TABLE test_ttl SET ttl = '1 second';
Affected Rows: 0
-- SQLNESS SLEEP 2s
ADMIN compact_table('test_ttl');
+---------------------------------+
| ADMIN compact_table('test_ttl') |
+---------------------------------+
| 0 |
+---------------------------------+
SELECT val from test_ttl;
++
++
ALTER TABLE test_ttl SET ttl = '1 minute';
Affected Rows: 0
INSERT INTO test_ttl VALUES
(now(), 1),
(now(), 2),
(now(), 3);
Affected Rows: 3
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
+-------------------------------+
| ADMIN flush_table('test_ttl') |
+-------------------------------+
| 0 |
+-------------------------------+
ADMIN compact_table('test_ttl');
+---------------------------------+
| ADMIN compact_table('test_ttl') |
+---------------------------------+
| 0 |
+---------------------------------+
SELECT val from test_ttl;
+-----+
| val |
+-----+
| 1 |
| 2 |
| 3 |
+-----+
DROP TABLE test_ttl;
Affected Rows: 0

40
tests/cases/standalone/common/ttl/alter_table_ttl.sql Normal file
View File

@@ -0,0 +1,40 @@
CREATE TABLE test_ttl(ts TIMESTAMP TIME INDEX, val INT, PRIMARY KEY(val)) WITH (ttl = '1 day');
INSERT INTO test_ttl VALUES
(now(), 1),
(now(), 2),
(now(), 3);
SELECT val from test_ttl;
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
ADMIN compact_table('test_ttl');
SELECT val from test_ttl;
ALTER TABLE test_ttl SET ttl = '1 second';
-- SQLNESS SLEEP 2s
ADMIN compact_table('test_ttl');
SELECT val from test_ttl;
ALTER TABLE test_ttl SET ttl = '1 minute';
INSERT INTO test_ttl VALUES
(now(), 1),
(now(), 2),
(now(), 3);
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
ADMIN compact_table('test_ttl');
SELECT val from test_ttl;
DROP TABLE test_ttl;

43
tests/cases/standalone/common/ttl/basic.result Normal file
View File

@@ -0,0 +1,43 @@
CREATE TABLE test_ttl(ts TIMESTAMP TIME INDEX, val INT) WITH (ttl = '1 second');
Affected Rows: 0
INSERT INTO test_ttl VALUES
(now(), 1);
Affected Rows: 1
SELECT val from test_ttl;
+-----+
| val |
+-----+
| 1 |
+-----+
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
+-------------------------------+
| ADMIN flush_table('test_ttl') |
+-------------------------------+
| 0 |
+-------------------------------+
ADMIN compact_table('test_ttl');
+---------------------------------+
| ADMIN compact_table('test_ttl') |
+---------------------------------+
| 0 |
+---------------------------------+
SELECT val from test_ttl;
++
++
DROP TABLE test_ttl;
Affected Rows: 0

15
tests/cases/standalone/common/ttl/basic.sql Normal file
View File

@@ -0,0 +1,15 @@
CREATE TABLE test_ttl(ts TIMESTAMP TIME INDEX, val INT) WITH (ttl = '1 second');
INSERT INTO test_ttl VALUES
(now(), 1);
SELECT val from test_ttl;
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
ADMIN compact_table('test_ttl');
SELECT val from test_ttl;
DROP TABLE test_ttl;

96
tests/cases/standalone/common/ttl/database_ttl.result Normal file
View File

@@ -0,0 +1,96 @@
CREATE DATABASE test_ttl_db WITH (ttl = '1 second');
Affected Rows: 1
USE test_ttl_db;
Affected Rows: 0
-- It will use the database TTL setting --
CREATE TABLE test_ttl(ts TIMESTAMP TIME INDEX, val INT);
Affected Rows: 0
INSERT INTO test_ttl VALUES
(now(), 1);
Affected Rows: 1
SELECT val from test_ttl;
+-----+
| val |
+-----+
| 1 |
+-----+
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
+-------------------------------+
| ADMIN flush_table('test_ttl') |
+-------------------------------+
| 0 |
+-------------------------------+
ADMIN compact_table('test_ttl');
+---------------------------------+
| ADMIN compact_table('test_ttl') |
+---------------------------------+
| 0 |
+---------------------------------+
-- Must be expired --
SELECT val from test_ttl;
++
++
ALTER DATABASE test_ttl_db SET ttl = '1 day';
Affected Rows: 0
INSERT INTO test_ttl VALUES
(now(), 1);
Affected Rows: 1
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
+-------------------------------+
| ADMIN flush_table('test_ttl') |
+-------------------------------+
| 0 |
+-------------------------------+
ADMIN compact_table('test_ttl');
+---------------------------------+
| ADMIN compact_table('test_ttl') |
+---------------------------------+
| 0 |
+---------------------------------+
-- Must not be expired --
SELECT val from test_ttl;
+-----+
| val |
+-----+
| 1 |
+-----+
DROP TABLE test_ttl;
Affected Rows: 0
USE public;
Affected Rows: 0
DROP DATABASE test_ttl_db;
Affected Rows: 0

39
tests/cases/standalone/common/ttl/database_ttl.sql Normal file
View File

@@ -0,0 +1,39 @@
CREATE DATABASE test_ttl_db WITH (ttl = '1 second');
USE test_ttl_db;
-- It will use the database TTL setting --
CREATE TABLE test_ttl(ts TIMESTAMP TIME INDEX, val INT);
INSERT INTO test_ttl VALUES
(now(), 1);
SELECT val from test_ttl;
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
ADMIN compact_table('test_ttl');
-- Must be expired --
SELECT val from test_ttl;
ALTER DATABASE test_ttl_db SET ttl = '1 day';
INSERT INTO test_ttl VALUES
(now(), 1);
-- SQLNESS SLEEP 2s
ADMIN flush_table('test_ttl');
ADMIN compact_table('test_ttl');
-- Must not be expired --
SELECT val from test_ttl;
DROP TABLE test_ttl;
USE public;
DROP DATABASE test_ttl_db;

123
tests/cases/standalone/common/ttl/database_ttl_with_metric_engine.result Normal file
View File

@@ -0,0 +1,123 @@
CREATE DATABASE test_ttl_db WITH (ttl = '1 second');
Affected Rows: 1
USE test_ttl_db;
Affected Rows: 0
CREATE TABLE phy (ts timestamp time index, val double) engine=metric with ("physical_metric_table" = "");
Affected Rows: 0
-- It will use the database TTL setting --
CREATE TABLE test_ttl (ts timestamp time index, val double, host string primary key) engine = metric with ("on_physical_table" = "phy");
Affected Rows: 0
INSERT INTO test_ttl(ts, val, host) VALUES
(now(), 1, 'host1'),
(now(), 2, 'host2'),
(now(), 3, 'host3');
Affected Rows: 3
SELECT val, host FROM test_ttl;
+-----+-------+
| val | host |
+-----+-------+
| 2.0 | host2 |
| 3.0 | host3 |
| 1.0 | host1 |
+-----+-------+
-- SQLNESS SLEEP 2s
ADMIN flush_table('phy');
+--------------------------+
| ADMIN flush_table('phy') |
+--------------------------+
| 0 |
+--------------------------+
ADMIN compact_table('phy');
+----------------------------+
| ADMIN compact_table('phy') |
+----------------------------+
| 0 |
+----------------------------+
--- should be expired --
SELECT val, host FROM test_ttl;
++
++
ALTER DATABASE test_ttl_db SET ttl = '1 day';
Affected Rows: 0
INSERT INTO test_ttl(ts, val, host) VALUES
(now(), 1, 'host1'),
(now(), 2, 'host2'),
(now(), 3, 'host3');
Affected Rows: 3
ADMIN flush_table('phy');
+--------------------------+
| ADMIN flush_table('phy') |
+--------------------------+
| 0 |
+--------------------------+
ADMIN compact_table('phy');
+----------------------------+
| ADMIN compact_table('phy') |
+----------------------------+
| 0 |
+----------------------------+
--- should not be expired --
SELECT val, host FROM test_ttl;
+-----+-------+
| val | host |
+-----+-------+
| 2.0 | host2 |
| 3.0 | host3 |
| 1.0 | host1 |
+-----+-------+
-- restart the db, ensure everything is ok
-- SQLNESS ARG restart=true
SELECT val, host FROM test_ttl;
+-----+-------+
| val | host |
+-----+-------+
| 2.0 | host2 |
| 3.0 | host3 |
| 1.0 | host1 |
+-----+-------+
DROP TABLE test_ttl;
Affected Rows: 0
DROP TABLE phy;
Affected Rows: 0
USE public;
Affected Rows: 0
DROP DATABASE test_ttl_db;
Affected Rows: 0

50
tests/cases/standalone/common/ttl/database_ttl_with_metric_engine.sql Normal file
View File

@@ -0,0 +1,50 @@
CREATE DATABASE test_ttl_db WITH (ttl = '1 second');
USE test_ttl_db;
CREATE TABLE phy (ts timestamp time index, val double) engine=metric with ("physical_metric_table" = "");
-- It will use the database TTL setting --
CREATE TABLE test_ttl (ts timestamp time index, val double, host string primary key) engine = metric with ("on_physical_table" = "phy");
INSERT INTO test_ttl(ts, val, host) VALUES
(now(), 1, 'host1'),
(now(), 2, 'host2'),
(now(), 3, 'host3');
SELECT val, host FROM test_ttl;
-- SQLNESS SLEEP 2s
ADMIN flush_table('phy');
ADMIN compact_table('phy');
--- should be expired --
SELECT val, host FROM test_ttl;
ALTER DATABASE test_ttl_db SET ttl = '1 day';
INSERT INTO test_ttl(ts, val, host) VALUES
(now(), 1, 'host1'),
(now(), 2, 'host2'),
(now(), 3, 'host3');
ADMIN flush_table('phy');
ADMIN compact_table('phy');
--- should not be expired --
SELECT val, host FROM test_ttl;
-- restart the db, ensure everything is ok
-- SQLNESS ARG restart=true
SELECT val, host FROM test_ttl;
DROP TABLE test_ttl;
DROP TABLE phy;
USE public;
DROP DATABASE test_ttl_db;

106
tests/cases/standalone/common/ttl/metric_engine_ttl.result Normal file
View File

@@ -0,0 +1,106 @@
CREATE TABLE phy (ts timestamp time index, val double) engine=metric with ("physical_metric_table" = "", ttl = '1 second');
Affected Rows: 0
CREATE TABLE test_ttl (ts timestamp time index, val double, host string primary key) engine = metric with ("on_physical_table" = "phy");
Affected Rows: 0
INSERT INTO test_ttl(ts, val, host) VALUES
(now(), 1, 'host1'),
(now(), 2, 'host2'),
(now(), 3, 'host3');
Affected Rows: 3
SELECT val, host FROM test_ttl;
+-----+-------+
| val | host |
+-----+-------+
| 2.0 | host2 |
| 3.0 | host3 |
| 1.0 | host1 |
+-----+-------+
-- SQLNESS SLEEP 2s
ADMIN flush_table('phy');
+--------------------------+
| ADMIN flush_table('phy') |
+--------------------------+
| 0 |
+--------------------------+
ADMIN compact_table('phy');
+----------------------------+
| ADMIN compact_table('phy') |
+----------------------------+
| 0 |
+----------------------------+
--- should be expired --
SELECT val, host FROM test_ttl;
++
++
ALTER TABLE phy SET ttl = '1 day';
Affected Rows: 0
INSERT INTO test_ttl(ts, val, host) VALUES
(now(), 1, 'host1'),
(now(), 2, 'host2'),
(now(), 3, 'host3');
Affected Rows: 3
ADMIN flush_table('phy');
+--------------------------+
| ADMIN flush_table('phy') |
+--------------------------+
| 0 |
+--------------------------+
ADMIN compact_table('phy');
+----------------------------+
| ADMIN compact_table('phy') |
+----------------------------+
| 0 |
+----------------------------+
--- should not be expired --
SELECT val, host FROM test_ttl;
+-----+-------+
| val | host |
+-----+-------+
| 2.0 | host2 |
| 3.0 | host3 |
| 1.0 | host1 |
+-----+-------+
-- restart the db, ensure everything is ok
-- SQLNESS ARG restart=true
SELECT val, host FROM test_ttl;
+-----+-------+
| val | host |
+-----+-------+
| 2.0 | host2 |
| 3.0 | host3 |
| 1.0 | host1 |
+-----+-------+
DROP TABLE test_ttl;
Affected Rows: 0
DROP TABLE phy;
Affected Rows: 0

40
tests/cases/standalone/common/ttl/metric_engine_ttl.sql Normal file
View File

@@ -0,0 +1,40 @@
CREATE TABLE phy (ts timestamp time index, val double) engine=metric with ("physical_metric_table" = "", ttl = '1 second');
CREATE TABLE test_ttl (ts timestamp time index, val double, host string primary key) engine = metric with ("on_physical_table" = "phy");
INSERT INTO test_ttl(ts, val, host) VALUES
(now(), 1, 'host1'),
(now(), 2, 'host2'),
(now(), 3, 'host3');
SELECT val, host FROM test_ttl;
-- SQLNESS SLEEP 2s
ADMIN flush_table('phy');
ADMIN compact_table('phy');
--- should be expired --
SELECT val, host FROM test_ttl;
ALTER TABLE phy SET ttl = '1 day';
INSERT INTO test_ttl(ts, val, host) VALUES
(now(), 1, 'host1'),
(now(), 2, 'host2'),
(now(), 3, 'host3');
ADMIN flush_table('phy');
ADMIN compact_table('phy');
--- should not be expired --
SELECT val, host FROM test_ttl;
-- restart the db, ensure everything is ok
-- SQLNESS ARG restart=true
SELECT val, host FROM test_ttl;
DROP TABLE test_ttl;
DROP TABLE phy;