From 7eef4f971296aa40b1f9482b01e6399551f88d78 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Mon, 9 Sep 2024 16:58:29 +0800
Subject: [PATCH] add test

---
 .../script/tsim/stream/streamInterpScalar.sim | 417 ++++++++++++++++++
 1 file changed, 417 insertions(+)
 create mode 100644 tests/script/tsim/stream/streamInterpScalar.sim

diff --git a/tests/script/tsim/stream/streamInterpScalar.sim b/tests/script/tsim/stream/streamInterpScalar.sim
new file mode 100644
index 0000000000..e4e280138b
--- /dev/null
+++ b/tests/script/tsim/stream/streamInterpScalar.sim
@@ -0,0 +1,417 @@
+system sh/stop_dnodes.sh
+system sh/deploy.sh -n dnode1 -i 1
+system sh/exec.sh -n dnode1 -s start
+sleep 50
+sql connect
+
+print step1
+print =============== create database
+sql create database test vgroups 1;
+sql use test;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams1 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt as select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a every(1s) fill(prev);
+
+run tsim/stream/checkTaskStatus.sim
+
+
+sql insert into t1 values(1648791217001,1,1,1,1.1);
+
+sleep 2000
+
+sql insert into t1 values(1648791212009,1,3,3,3.3) (1648791214001,1,4,4,4.4) (1648791219001,1,5,5,5.5) (1648791220001,1,6,6,6.6);
+
+print sql select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a range(1648791213000, 1648791220001) every(1s) fill(prev);
+sql select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a range(1648791213000, 1648791220001) every(1s) fill(prev);
+
+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
+
+
+$loop_count = 0
+loop0:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+print 2 sql select * from streamt order by 1;
+sql select * from streamt order by 1;
+
+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 != 8 then
+  print ======rows=$rows
+  goto loop0
+endi
+
+# row 0
+if $data02 != 3.000000000 then
+  print ======data02=$data02
+  goto loop0
+endi
+
+if $data03 != 3.000000000 then
+  print ======data03=$data03
+  goto loop0
+endi
+
+if $data12 != 3.000000000 then
+  print ======data12=$data12
+  goto loop0
+endi
+
+if $data13 != 3.000000000 then
+  print ======data13=$data13
+  goto loop0
+endi
+
+if $data22 != 4.000000000 then
+  print ======data22=$data22
+  goto loop0
+endi
+
+if $data23 != 4.000000000 then
+  print ======data23=$data23
+  goto loop0
+endi
+
+if $data32 != 4.000000000 then
+  print ======data32=$data32
+  goto loop0
+endi
+
+if $data33 != 4.000000000 then
+  print ======data33=$data33
+  goto loop0
+endi
+
+if $data42 != 4.000000000 then
+  print ======data42=$data42
+  goto loop0
+endi
+
+if $data43 != 4.000000000 then
+  print ======data43=$data43
+  goto loop0
+endi
+
+if $data52 != 1.000000000 then
+  print ======data52=$data52
+  goto loop0
+endi
+
+if $data53 != 1.000000000 then
+  print ======data53=$data53
+  goto loop0
+endi
+
+if $data62 != 1.000000000 then
+  print ======data62=$data62
+  goto loop0
+endi
+
+if $data63 != 1.000000000 then
+  print ======data63=$data63
+  goto loop0
+endi
+
+if $data72 != 5.000000000 then
+  print ======data72=$data72
+  goto loop0
+endi
+
+if $data73 != 5.000000000 then
+  print ======data73=$data73
+  goto loop0
+endi
+
+print step2
+print =============== create database
+sql create database test2 vgroups 1;
+sql use test2;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams2 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt as select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a every(1s) fill(next);
+
+run tsim/stream/checkTaskStatus.sim
+
+
+sql insert into t1 values(1648791217001,1,1,1,1.1);
+
+sleep 2000
+
+sql insert into t1 values(1648791212009,1,3,3,3.3) (1648791214001,1,4,4,4.4) (1648791219001,1,5,5,5.5) (1648791220001,1,6,6,6.6);
+
+print sql select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a range(1648791213000, 1648791220001) every(1s) fill(next);
+sql select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a range(1648791213000, 1648791220001) every(1s) fill(next);
+
+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
+
+
+$loop_count = 0
+loop1:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+print 2 sql select * from streamt order by 1;
+sql select * from streamt order by 1;
+
+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 != 8 then
+  print ======rows=$rows
+  goto loop1
+endi
+
+# row 0
+if $data02 != 4.000000000 then
+  print ======data02=$data02
+  goto loop1
+endi
+
+if $data03 != 4.000000000 then
+  print ======data03=$data03
+  goto loop1
+endi
+
+if $data12 != 4.000000000 then
+  print ======data12=$data12
+  goto loop1
+endi
+
+if $data13 != 4.000000000 then
+  print ======data13=$data13
+  goto loop1
+endi
+
+if $data22 != 1.000000000 then
+  print ======data22=$data22
+  goto loop1
+endi
+
+if $data23 != 1.000000000 then
+  print ======data23=$data23
+  goto loop1
+endi
+
+if $data32 != 1.000000000 then
+  print ======data32=$data32
+  goto loop1
+endi
+
+if $data33 != 1.000000000 then
+  print ======data33=$data33
+  goto loop1
+endi
+
+if $data42 != 1.000000000 then
+  print ======data42=$data42
+  goto loop1
+endi
+
+if $data43 != 1.000000000 then
+  print ======data43=$data43
+  goto loop1
+endi
+
+if $data52 != 5.000000000 then
+  print ======data52=$data52
+  goto loop1
+endi
+
+if $data53 != 5.000000000 then
+  print ======data53=$data53
+  goto loop1
+endi
+
+if $data62 != 5.000000000 then
+  print ======data62=$data62
+  goto loop1
+endi
+
+if $data63 != 5.000000000 then
+  print ======data63=$data63
+  goto loop1
+endi
+
+if $data72 != 6.000000000 then
+  print ======data72=$data72
+  goto loop1
+endi
+
+if $data73 != 6.000000000 then
+  print ======data73=$data73
+  goto loop1
+endi
+
+print step3
+print =============== create database
+sql create database test3 vgroups 1;
+sql use test3;
+
+sql create table t1(ts timestamp, a int, b int , c int, d double);
+sql create stream streams3 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into  streamt as select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a every(1s) fill(value, 100, 200);
+
+run tsim/stream/checkTaskStatus.sim
+
+
+sql insert into t1 values(1648791217001,1,1,1,1.1);
+
+sleep 2000
+
+sql insert into t1 values(1648791212009,1,3,3,3.3) (1648791214001,1,4,4,4.4) (1648791219001,1,5,5,5.5) (1648791220001,1,6,6,6.6);
+
+print sql select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a range(1648791213000, 1648791220001) every(1s) fill(value, 100, 200);
+sql select _irowts, now, floor(interp(d)), interp(floor(d)), a  from t1 partition by tbname, a range(1648791213000, 1648791220001) every(1s) fill(value, 100, 200);
+
+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
+
+
+$loop_count = 0
+loop2:
+
+sleep 300
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+print 2 sql select * from streamt order by 1;
+sql select * from streamt order by 1;
+
+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 != 8 then
+  print ======rows=$rows
+  goto loop2
+endi
+
+# row 0
+if $data02 != 100.000000000 then
+  print ======data02=$data02
+  goto loop2
+endi
+
+if $data03 != 200.000000000 then
+  print ======data03=$data03
+  goto loop2
+endi
+
+if $data12 != 100.000000000 then
+  print ======data12=$data12
+  goto loop2
+endi
+
+if $data13 != 200.000000000 then
+  print ======data13=$data13
+  goto loop2
+endi
+
+if $data22 != 100.000000000 then
+  print ======data22=$data22
+  goto loop2
+endi
+
+if $data23 != 200.000000000 then
+  print ======data23=$data23
+  goto loop2
+endi
+
+if $data32 != 100.000000000 then
+  print ======data32=$data32
+  goto loop2
+endi
+
+if $data33 != 200.000000000 then
+  print ======data33=$data33
+  goto loop2
+endi
+
+if $data42 != 100.000000000 then
+  print ======data42=$data42
+  goto loop2
+endi
+
+if $data43 != 200.000000000 then
+  print ======data43=$data43
+  goto loop2
+endi
+
+if $data52 != 100.000000000 then
+  print ======data52=$data52
+  goto loop2
+endi
+
+if $data53 != 200.000000000 then
+  print ======data53=$data53
+  goto loop2
+endi
+
+if $data62 != 100.000000000 then
+  print ======data62=$data62
+  goto loop2
+endi
+
+if $data63 != 200.000000000 then
+  print ======data63=$data63
+  goto loop2
+endi
+
+if $data72 != 100.000000000 then
+  print ======data72=$data72
+  goto loop2
+endi
+
+if $data73 != 200.000000000 then
+  print ======data73=$data73
+  goto loop2
+endi
+
+print end
+
+system sh/exec.sh -n dnode1 -s stop -x SIGINT