From e3a82cadd465dbe38633dbee2156821f0edd4025 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Mon, 30 Sep 2024 09:05:29 +0800
Subject: [PATCH] add ci

---
 .../stream/streamInterpForceWindowClose1.sim  | 168 +++++++++++++++++-
 1 file changed, 162 insertions(+), 6 deletions(-)

diff --git a/tests/script/tsim/stream/streamInterpForceWindowClose1.sim b/tests/script/tsim/stream/streamInterpForceWindowClose1.sim
index f0147c3f02..1de845f331 100644
--- a/tests/script/tsim/stream/streamInterpForceWindowClose1.sim
+++ b/tests/script/tsim/stream/streamInterpForceWindowClose1.sim
@@ -73,6 +73,23 @@ print $data40 $data41 $data42 $data43 $data44
 print $data50 $data51 $data52 $data53 $data54
 
 
+# row 0
+if $rows < 2 then
+  print ======rows=$rows
+  goto loop0
+endi
+
+print 2 sql select * from streamt where a == 21;
+sql select * from streamt where a == 21;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+
 # row 0
 if $rows < 2 then
   print ======rows=$rows
@@ -89,7 +106,34 @@ if $loop_count == 20 then
   return -1
 endi
 
-print 2 sql select * from streamt where a == 2;
+print 2 sql select * from streamt where a == 31;
+sql select * from streamt where a == 31;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+
+# row 0
+if $rows < 2 then
+  print ======rows=$rows
+  goto loop0
+endi
+
+$loop_count = 0
+loop1:
+
+sleep 2000
+
+$loop_count = $loop_count + 1
+if $loop_count == 20 then
+  return -1
+endi
+
+print  sql select * from streamt where a == 2;
 sql select * from streamt where a == 2;
 
 print $data00 $data01 $data02 $data03 $data04
@@ -105,6 +149,38 @@ if $rows < 2 then
   goto loop1
 endi
 
+print 3 sql select * from streamt where a == 22;
+sql select * from streamt where a == 22;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+# row 0
+if $rows < 2 then
+  print ======rows=$rows
+  goto loop1
+endi
+
+print 3 sql select * from streamt where a == 32;
+sql select * from streamt where a == 32;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+# row 0
+if $rows < 2 then
+  print ======rows=$rows
+  goto loop1
+endi
+
 $loop_count = 0
 loop2:
 
@@ -115,7 +191,7 @@ if $loop_count == 20 then
   return -1
 endi
 
-print 2 sql select * from streamt where a == 3;
+print 4 sql select * from streamt where a == 3;
 sql select * from streamt where a == 3;
 
 print $data00 $data01 $data02 $data03 $data04
@@ -131,6 +207,38 @@ if $rows < 2 then
   goto loop2
 endi
 
+print 4 sql select * from streamt where a == 23;
+sql select * from streamt where a == 23;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+# row 0
+if $rows < 2 then
+  print ======rows=$rows
+  goto loop2
+endi
+
+print 4 sql select * from streamt where a == 33;
+sql select * from streamt where a == 33;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+# row 0
+if $rows < 2 then
+  print ======rows=$rows
+  goto loop2
+endi
+
 sleep 4000
 
 $loop_count = 0
@@ -143,6 +251,54 @@ if $loop_count == 20 then
   return -1
 endi
 
+print 5 sql select * from streamt where a == 3;
+sql select * from streamt where a == 3;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+# row 0
+if $rows < 5 then
+  print ======rows=$rows
+  goto loop3
+endi
+
+print 5 sql select * from streamt where a == 23;
+sql select * from streamt where a == 23;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+# row 0
+if $rows < 5 then
+  print ======rows=$rows
+  goto loop3
+endi
+
+print 5 sql select * from streamt where a == 33;
+sql select * from streamt where a == 33;
+
+print $data00 $data01 $data02 $data03 $data04
+print $data10 $data11 $data12 $data13 $data14
+print $data20 $data21 $data22 $data23 $data24
+print $data30 $data31 $data32 $data33 $data34
+print $data40 $data41 $data42 $data43 $data44
+print $data50 $data51 $data52 $data53 $data54
+
+# row 0
+if $rows < 5 then
+  print ======rows=$rows
+  goto loop3
+endi
+
 print 2 sql select * from streamt where a == 3;
 sql select * from streamt where a == 3;
 
@@ -245,7 +401,7 @@ sql create table t1 using st tags(1,1,1);
 sql create table t2 using st tags(2,2,2);
 sql create table t3 using st tags(2,2,2);
 
-sql create stream streams3 trigger force_window_close IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt as select _irowts, interp(a) as a, _isfilled, tbname, b, c from st partition by tbname, b,c every(2s) fill(value,100,200);
+sql create stream streams3 trigger force_window_close IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt as select _irowts, interp(a) as a, _isfilled, tbname, b, c from st partition by tbname, b,c every(2s) fill(value,100);
 
 run tsim/stream/checkTaskStatus.sim
 
@@ -285,7 +441,7 @@ print $data40 $data41 $data42 $data43 $data44
 print $data50 $data51 $data52 $data53 $data54
 
 $loop_count = 0
-loop4:
+loop5:
 
 sleep 2000
 
@@ -305,9 +461,9 @@ print $data40 $data41 $data42 $data43 $data44
 print $data50 $data51 $data52 $data53 $data54
 
 # row 0
-if $rows < 5 then
+if $rows < 10 then
   print ======rows=$rows
-  goto loop4
+  goto loop5
 endi
 
 print end