From ed87ac75a7f510dece0b71ee8b0500d7d8f69836 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Tue, 26 Mar 2024 19:11:19 +0800
Subject: [PATCH] add ci

---
 .../script/tsim/stream/streamPrimaryKey0.sim  | 80 +++++++++----------
 .../script/tsim/stream/streamPrimaryKey1.sim  | 32 ++++----
 .../script/tsim/stream/streamPrimaryKey2.sim  | 32 ++++----
 .../script/tsim/stream/streamPrimaryKey3.sim  | 74 +++++++++++++++++
 4 files changed, 146 insertions(+), 72 deletions(-)
 create mode 100644 tests/script/tsim/stream/streamPrimaryKey3.sim

diff --git a/tests/script/tsim/stream/streamPrimaryKey0.sim b/tests/script/tsim/stream/streamPrimaryKey0.sim
index 258154f8aa..8905078a3e 100644
--- a/tests/script/tsim/stream/streamPrimaryKey0.sim
+++ b/tests/script/tsim/stream/streamPrimaryKey0.sim
@@ -46,14 +46,14 @@ endi
 print 1 select * from streamt0
 sql select * from streamt0;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
@@ -79,14 +79,14 @@ endi
 print 1 select * from streamt2
 sql select * from streamt2;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
@@ -136,14 +136,14 @@ endi
 print 1 select * from streamt3
 sql select * from streamt3;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
@@ -169,14 +169,14 @@ endi
 print 1 select * from streamt5
 sql select * from streamt5;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
@@ -223,14 +223,14 @@ endi
 print 1 select * from streamt6
 sql select * from streamt6;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
diff --git a/tests/script/tsim/stream/streamPrimaryKey1.sim b/tests/script/tsim/stream/streamPrimaryKey1.sim
index 2496ce0124..71971166d6 100644
--- a/tests/script/tsim/stream/streamPrimaryKey1.sim
+++ b/tests/script/tsim/stream/streamPrimaryKey1.sim
@@ -45,14 +45,14 @@ endi
 print 1 select * from streamt1
 sql select * from streamt1;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
@@ -101,14 +101,14 @@ endi
 print 1 select * from streamt3
 sql select * from streamt3;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
diff --git a/tests/script/tsim/stream/streamPrimaryKey2.sim b/tests/script/tsim/stream/streamPrimaryKey2.sim
index 590f7a562f..c47dc2bb4b 100644
--- a/tests/script/tsim/stream/streamPrimaryKey2.sim
+++ b/tests/script/tsim/stream/streamPrimaryKey2.sim
@@ -54,14 +54,14 @@ endi
 print 1 select * from streamt1
 sql select * from streamt1;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
@@ -119,14 +119,14 @@ endi
 print 1 select * from streamt3
 sql select * from streamt3;
 
-print $data00 $data01 $data01
-print $data10 $data11 $data11
-print $data20 $data21 $data21
-print $data30 $data31 $data31
-print $data40 $data41 $data41
-print $data50 $data51 $data51
-print $data60 $data61 $data61
-print $data70 $data71 $data71
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+print $data40 $data41 $data42
+print $data50 $data51 $data52
+print $data60 $data61 $data62
+print $data70 $data71 $data72
 
 if $rows != 5 then
   print =====rows=$rows
diff --git a/tests/script/tsim/stream/streamPrimaryKey3.sim b/tests/script/tsim/stream/streamPrimaryKey3.sim
new file mode 100644
index 0000000000..39d55bda6c
--- /dev/null
+++ b/tests/script/tsim/stream/streamPrimaryKey3.sim
@@ -0,0 +1,74 @@
+system sh/stop_dnodes.sh
+system sh/deploy.sh -n dnode1 -i 1
+system sh/cfg.sh -n dnode1 -c debugflag -v 135
+system sh/cfg.sh -n dnode1 -c streamBufferSize -v 10
+system sh/exec.sh -n dnode1 -s start
+
+sleep 500
+
+sql connect
+
+print step1=============
+
+sql create database test  vgroups 4;
+sql use test;
+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 streams1 trigger at_once ignore expired 0 ignore update 0  into streamt1(ts, a primary key, b)  as select  ts, a, b from t1 partition by b;
+
+sleep 1000
+
+sql insert into t1 values(1648791210000,1,2,3,1.0);
+sql insert into t1 values(1648791210000,2,4,3,1.0);
+
+sleep 500
+
+sql insert into t1 values(1648791210000,1,3,3,1.0);
+
+
+$loop_count = 0
+
+loop0:
+
+sleep 200
+
+$loop_count = $loop_count + 1
+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 $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+
+if $rows != 2 then
+  print =====rows=$rows
+  goto loop0
+endi
+
+if $data01 != 1 then
+  print =====data01=$data01
+  goto loop0
+endi
+
+if $data02 != 3 then
+  print =====data02=$data02
+  goto loop0
+endi
+
+if $data11 != 2 then
+  print =====data11=$data11
+  goto loop0
+endi
+
+if $data12 != 4 then
+  print =====data12=$data12
+  goto loop0
+endi
+
+
+system sh/exec.sh -n dnode1 -s stop -x SIGINT
\ No newline at end of file