提交 3cec5d98 编写于 作者: P Ping Xiao

test: add test case for sliding

上级 09c2189f
...@@ -62,6 +62,54 @@ class TDTestCase: ...@@ -62,6 +62,54 @@ class TDTestCase:
tdSql.query("select sum(k) from t1 interval(1d) sliding(1h)") tdSql.query("select sum(k) from t1 interval(1d) sliding(1h)")
tdSql.checkRows(24) 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): def stop(self):
tdSql.close() tdSql.close()
tdLog.success("%s successfully executed" % __file__) tdLog.success("%s successfully executed" % __file__)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册