From 3cec5d981ef19364de6bbad7ce47dfad68043f4d Mon Sep 17 00:00:00 2001 From: Ping Xiao Date: Mon, 16 May 2022 22:12:29 +0800 Subject: [PATCH] test: add test case for sliding --- tests/pytest/query/sliding.py | 48 +++++++++++++++++++++++++++++++++++ 1 file changed, 48 insertions(+) diff --git a/tests/pytest/query/sliding.py b/tests/pytest/query/sliding.py index f5c59ec1ba..212e51d146 100644 --- a/tests/pytest/query/sliding.py +++ b/tests/pytest/query/sliding.py @@ -62,6 +62,54 @@ class TDTestCase: tdSql.query("select sum(k) from t1 interval(1d) sliding(1h)") tdSql.checkRows(24) + # TD-14690 + tdSql.execute("drop database if exists ceil") + tdSql.execute("create database ceil keep 36500") + tdSql.execute("use ceil") + tdSql.execute("create stable stable_1 (ts timestamp , q_nchar nchar(20) ) tags(loc nchar(100))") + tdSql.execute("create table stable_1_1 using stable_1 tags('stable_1_1')") + tdSql.execute("create table stable_1_2 using stable_1 tags('stable_1_2')") + + self.ts = 1630000000000 + for i in range(10): + if i <= 5: + tdSql.execute("insert into stable_1_1 (ts , q_nchar) values(%d, %d)" % (self.ts + i * 1000, i % 5 + 1)) + tdSql.execute("insert into stable_1_2 (ts , q_nchar) values(%d, %d)" % (self.ts + i * 1000, i % 5 + 1)) + else: + tdSql.execute("insert into stable_1_1 (ts , q_nchar) values(%d, %d)" % (self.ts + 39000 + i * 1000, i % 5)) + tdSql.execute("insert into stable_1_2 (ts , q_nchar) values(%d, %d)" % (self.ts + 10000 + i * 1000, i % 5 + 1)) + + tdSql.execute("insert into stable_1_1 (ts , q_nchar) values(%d, %d)" % (1630000049000, 5)) + tdSql.execute("insert into stable_1_2 (ts , q_nchar) values(%d, %d)" % (1630000020000, 1)) + + tdSql.query("select COUNT(q_nchar) from stable_1 interval(20s) sliding(10s) order by ts") + tdSql.checkRows(6) + tdSql.checkData(0, 1, 12) + tdSql.checkData(1, 1, 16) + tdSql.checkData(2, 1, 5) + tdSql.checkData(3, 1, 1) + tdSql.checkData(4, 1, 5) + tdSql.checkData(5, 1, 5) + + tdSql.query("select COUNT(q_nchar) from (select * from stable_1) interval(20s) sliding(10s) order by ts") + tdSql.checkRows(6) + tdSql.checkData(0, 1, 12) + tdSql.checkData(1, 1, 16) + tdSql.checkData(2, 1, 5) + tdSql.checkData(3, 1, 1) + tdSql.checkData(4, 1, 5) + tdSql.checkData(5, 1, 5) + + tdSql.query("select COUNT(q_nchar) from (select * from stable_1 order by ts) interval(20s) sliding(10s);") + tdSql.checkRows(6) + tdSql.checkData(0, 1, 12) + tdSql.checkData(1, 1, 16) + tdSql.checkData(2, 1, 5) + tdSql.checkData(3, 1, 1) + tdSql.checkData(4, 1, 5) + tdSql.checkData(5, 1, 5) + + def stop(self): tdSql.close() tdLog.success("%s successfully executed" % __file__) -- GitLab