test:Add more

Author: happyguoxy

test/cases/13-StreamProcessing/99-Others/test_trigger_type_4.py

@@ -65,9 +65,10 @@ def test_stream_trigger_type1(self):
         sql7 = "create stream s7 state_window (c1)        from stream_trigger partition by tbname options(fill_history_first(1)) into st7  as select _twstart, avg(cint), count(cint) from meters;"
         sql8 = "create stream s8 state_window (c1)        from stream_trigger partition by tbname into st8                                 as select _twstart ts, count(*) c1, avg(cint) c2, _twstart + 1 as ts2 from meters;"
         sql9 = "create stream s9 PERIOD(10s, 10a)                                                 into st9                                 as select cast(_tlocaltime/1000000 as timestamp) as tl, _tprev_localtime/1000000 tp, _tnext_localtime/1000000 tn, now, max(cint) from meters;"
-        # #new stream with session
-        #sql11 = "create stream s11 session(ts,1a)         from stream_trigger  partition by tbname  into st11                               as select _twstart ts, count(*) c1, avg(cint) c2 from meters where cts >= _twstart and cts < _twend;"
-        #sql12 = "create stream s12 session(ts,1a)         from stream_trigger                       into st12                               as select _twstart ts, count(*) c1, avg(cint) c2 from meters where cts >= _twstart and cts < _twend;"
+        
+        
+        sql11 = "create stream s11 session(ts,1a)         from stream_trigger  partition by tbname  into st11                               as select _twstart ts, count(*) c1, avg(cint) c2 from meters where cts >= _twstart and cts <= _twend;"
+        sql12 = "create stream s12 session(ts,1a)         from stream_trigger                       into st12                               as select _twstart ts, count(*) c1, avg(cint) c2 from meters where cts >= _twstart and cts <= _twend;"
         sql13 = "create stream s13 session(ts,1a)         from stream_trigger                       into st13                               as select _twstart ts, count(*) c1, avg(cint) c2 from meters;"
         sql14 = "create stream s14 session(ts,1a)         from stream_trigger                       into st14                               as select _twstart ts, count(*) c1, avg(c2) c2 from %%trows;"
 
@@ -85,13 +86,13 @@ def test_stream_trigger_type1(self):
             # self.StreamItem(sql6, self.checks6),
             # self.StreamItem(sql7, self.checks7),
             # self.StreamItem(sql8, self.checks8),
-            # self.StreamItem(sql9, self.checks9),
-            # #self.StreamItem(sql11, self.checks11),
-            # # self.StreamItem(sql12, self.checks12), 
+            # self.StreamItem(sql9, self.checks9),#113、114
+            self.StreamItem(sql11, self.checks11),#116
+            # self.StreamItem(sql12, self.checks12), #117
             # self.StreamItem(sql13, self.checks13), 
             # self.StreamItem(sql14, self.checks14), 
             # self.StreamItem(sql21, self.checks21), 
-            self.StreamItem(sql22, self.checks22),
+            #self.StreamItem(sql22, self.checks22), #115
         ]
 
         for stream in streams:
@@ -101,10 +102,30 @@ def test_stream_trigger_type1(self):
         tdLog.info(f"=============== write trigger data")
         sql = "insert into stream_trigger values ('2025-01-01 00:00:00', 0, 0), ('2025-01-01 00:00:01', 1, 1), ('2025-01-01 00:00:02', 2, 2);"
         tdSql.execute(sql)
+        
+        tdLog.info(f"=============== create vtable")
+        sql = """create vtable v1 (
+                ts timestamp,
+                t1_cint int from t1.cint,
+                t1_cuint INT UNSIGNED from t1.cuint,
+                t2_cint int from t2.cint,
+                t2_cuint INT UNSIGNED from t2.cuint,   
+                stream_trigger_c1 int from stream_trigger.c1,
+                stream_trigger_c2 int from stream_trigger.c2);"""
+        tdSql.execute(sql)
 
         tdLog.info(f"=============== check stream result")
         for stream in streams:
             stream.check()
+            
+            
+        # tdLog.info(f"=============== write trigger data again")
+        # sql = "insert into stream_trigger values ('2025-01-01 00:00:00', 0, 0), ('2025-01-01 00:00:01', 1, 0), ('2025-01-01 00:00:02', 2, 2);"
+        # tdSql.execute(sql)
+
+        # tdLog.info(f"=============== check stream result")
+        # for stream in streams:
+        #     stream.check()
 
     def checks1(self):
         result_sql = "select ts, c1, c2 from qdb.st1"
@@ -237,18 +258,14 @@ def checks9(self):
 
 
     def checks11(self):
-        result_sql = "select ts, c1, c2, ts2 from qdb.st11"
+        result_sql = "select ts, c1, c2 from qdb.st11"
         tdSql.checkResultsByFunc(
             sql=result_sql,
             func=lambda: tdSql.getRows() == 2
             and tdSql.compareData(0, 0, "2025-01-01 00:00:00.000")
-            and tdSql.compareData(0, 1, 6)
-            and tdSql.compareData(0, 3, "2025-01-01 00:00:00.001")
-            and tdSql.compareData(0, 2, 1.5)
+            and tdSql.compareData(0, 1, 3)
             and tdSql.compareData(1, 0, "2025-01-01 00:00:01.000")
-            and tdSql.compareData(1, 1, 6)
-            and tdSql.compareData(1, 2, 1.5)
-            and tdSql.compareData(1, 3, "2025-01-01 00:00:01.001"),
+            and tdSql.compareData(1, 1, 3),
         )
 
     def checks12(self):