From d7fe41d05f325eaa3d83e4cab27563bba42282e4 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Thu, 28 Mar 2024 16:04:35 +0800
Subject: [PATCH] add ci

---
 .../script/tsim/stream/streamPrimaryKey3.sim  | 104 +++++++++++++++++-
 1 file changed, 98 insertions(+), 6 deletions(-)

diff --git a/tests/script/tsim/stream/streamPrimaryKey3.sim b/tests/script/tsim/stream/streamPrimaryKey3.sim
index 319fa59da6..367060a92d 100644
--- a/tests/script/tsim/stream/streamPrimaryKey3.sim
+++ b/tests/script/tsim/stream/streamPrimaryKey3.sim
@@ -70,10 +70,24 @@ if $data12 != 4 then
   goto loop0
 endi
 
-sql insert into t1 values(1648791210001,3,1,1,2.0);
+print step2=============
+
+sql create database test1  vgroups 4;
+sql use test1;
+sql create table st(ts timestamp, a int primary key, b int , c int, d double) tags(ta varchar(100),tb int,tc int);
+sql create table t1 using st tags("aa", 1, 2);
+
+sql create stream streams2 trigger at_once ignore expired 0 ignore update 0  into streamt2(ts, a primary key, b)  as select _wstart, max(b), count(*) from t1 partition by b interval(10s);
+
+sleep 1000
+
+sql insert into t1 values(1648791210000,1,2,1,1.0);
+sql insert into t1 values(1648791210000,2,4,2,1.0);
+
+sleep 500
+
+sql insert into t1 values(1648791210000,1,3,3,1.0);
 
-print sql delete from t1 where ts = 1648791210000;
-sql delete from t1 where ts = 1648791210000;
 
 $loop_count = 0
 
@@ -86,20 +100,98 @@ if $loop_count == 10 then
   return -1
 endi
 
-print 1 select * from streamt1 order by 1,2
-sql select * from streamt1 order by 1,2;
+print 1 select * from streamt2 order by 1,2
+sql select * from streamt2 order by 1,2;
 
 print $data00 $data01 $data02
 print $data10 $data11 $data12
 print $data20 $data21 $data22
 
-if $rows != 1 then
+if $rows != 2 then
   print =====rows=$rows
   goto loop1
 endi
 
 if $data01 != 3 then
+  print =====data01=$data01
+  goto loop1
+endi
+
+if $data02 != 1 then
+  print =====data02=$data02
+  goto loop1
+endi
+
+if $data11 != 4 then
+  print =====data11=$data11
+  goto loop1
+endi
+
+if $data12 != 1 then
+  print =====data12=$data12
+  goto loop1
+endi
+
+print step3=============
+
+sql create database test2  vgroups 4;
+sql use test2;
+sql create table st(ts timestamp, a int primary key, b int , c int, d double) tags(ta varchar(100),tb int,tc int);
+sql create table t1 using st tags("aa", 1, 2);
+
+sql create stream streams3 trigger at_once ignore expired 0 ignore update 0  into streamt3(ts, a primary key, b)  as select _wstart, max(b), count(*) from t1 partition by b session(ts, 10s);
+
+sleep 1000
+
+sql insert into t1 values(1648791210000,1,2,1,1.0);
+sql insert into t1 values(1648791210000,2,4,2,1.0);
+
+sleep 500
+
+sql insert into t1 values(1648791210000,1,3,3,1.0);
+
+
+$loop_count = 0
+
+loop2:
+
+sleep 200
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
   return -1
 endi
 
+print 1 select * from streamt3 order by 1,2
+sql select * from streamt3 order by 1,2;
+
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+
+if $rows != 2 then
+  print =====rows=$rows
+  goto loop2
+endi
+
+if $data01 != 3 then
+  print =====data01=$data01
+  goto loop2
+endi
+
+if $data02 != 1 then
+  print =====data02=$data02
+  goto loop2
+endi
+
+if $data11 != 4 then
+  print =====data11=$data11
+  goto loop2
+endi
+
+if $data12 != 1 then
+  print =====data12=$data12
+  goto loop2
+endi
+
 system sh/exec.sh -n dnode1 -s stop -x SIGINT
\ No newline at end of file