test: reproduce bugs

Author: guanshengliang

test/cases/13-StreamProcessing/07-SubQuery/test_subquery_sliding_bug8.py

@@ -107,29 +107,43 @@ def createStreams(self):
         self.streams = []
 
         stream = StreamItem(
-            id=5,
-            stream="create stream rdb.s5 interval(5m) sliding(5m) from tdb.triggers partition by tbname into rdb.r5 as select _twstart ts, _twend te, _twduration td, _twrownum tw, %%tbname as tb, count(c1) c1, avg(c2) c2 from %%tbname where ts >= _twstart and ts < _twend",
-            res_query="select ts, te, td, tw, tb, c1, c2, tag_tbname from rdb.r5 where tag_tbname='t1' limit 3;",
-            exp_query="select _wstart, _wend, _wduration, count(c1), 't1', count(c1), avg(c2), 't1' from tdb.t1 where ts >= '2025-01-01 00:00:00' and ts < '2025-01-01 00:15:00' interval(5m) fill(value, 0, 0, null);",
-            check_func=self.check5,
+            id=10,
+            stream="create stream rdb.s10 interval(5m) sliding(5m) from tdb.triggers partition by id, tbname into rdb.r10 as select _twstart ts, _twend te, _twduration td, _twrownum tw, _tgrpid tg, cast(_tlocaltime % 1000000 as timestamp) tl, %%1 t1_data, %%2 t2_data, %%tbname tb_data, count(cint) c1_data, avg(cint) c2_data from qdb.meters where cts >= _twstart and cts < _twend and _twduration is not null and _twrownum is not null and _tgrpid is not null and _tlocaltime is not null and tbname = %%2;",
+            res_query="select ts, t1_data, t2_data, tb_data, c1_data, c2_data, id, tag_tbname from rdb.r10 where id=1;",
+            exp_query="select _wstart, 1, 't1', 't1', count(cint) c1, avg(cint) c2, 1, 't1' from qdb.meters where cts >= '2025-01-01 00:00:00' and cts < '2025-01-01 00:35:00' and tbname='t1' interval(5m);",
+            check_func=self.check10,
         )
         self.streams.append(stream)
 
         tdLog.info(f"create total:{len(self.streams)} streams")
         for stream in self.streams:
             stream.createStream()
 
-    def check5(self):
+    def check10(self):
+        tdSql.checkTableSchema(
+            dbname="rdb",
+            tbname="r10",
+            schema=[
+                ["ts", "TIMESTAMP", 8, ""],
+                ["te", "TIMESTAMP", 8, ""],
+                ["td", "BIGINT", 8, ""],
+                ["tw", "BIGINT", 8, ""],
+                ["tg", "BIGINT", 8, ""],
+                ["tl", "TIMESTAMP", 8, ""],
+                ["t1_data", "INT", 4, ""],
+                ["t2_data", "VARCHAR", 270, ""],
+                ["tb_data", "VARCHAR", 270, ""],
+                ["c1_data", "BIGINT", 8, ""],
+                ["c2_data", "DOUBLE", 8, ""],
+                ["id", "INT", 4, "TAG"],
+                ["tag_tbname", "VARCHAR", 270, "TAG"],
+            ],
+        )
         tdSql.checkResultsByFunc(
-            sql="select * from information_schema.ins_tags where db_name='rdb' and stable_name='r5' and tag_name='tag_tbname';",
+            sql="select * from information_schema.ins_tags where db_name='rdb' and stable_name='r10' and tag_name='tag_tbname';",
             func=lambda: tdSql.getRows() == 2,
         )
         tdSql.checkResultsByFunc(
-            sql="select ts, te, td, c1, tag_tbname from rdb.r5 where tag_tbname='t2'",
-            func=lambda: tdSql.getRows() == 1
-            and tdSql.compareData(0, 0, "2025-01-01 00:10:00.000")
-            and tdSql.compareData(0, 1, "2025-01-01 00:15:00.000")
-            and tdSql.compareData(0, 2, 300000)
-            and tdSql.compareData(0, 3, 2)
-            and tdSql.compareData(0, 4, "t2"),
+            sql="select * from rdb.r10 where tag_tbname='t2'",
+            func=lambda: tdSql.getRows() == 1,
         )