xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

ci:add some test for stream

This commit is contained in:
54liuyao 2022-12-13 09:30:34 +08:00
parent 998b45efeb
commit 9f3fabc7f5
1 changed files with 42 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
tests/script/tsim/stream/basic1.sim
View File

@ -792,4 +792,46 @@ if $rows != 1 then
goto loop17
endi
#for TS-2242
sql create database test5 vgroups 1;
sql use test5;
sql create stable st(ts timestamp, a int, b int , c int) tags(ta int,tb int,tc int);
sql create table ts1 using st tags(1,1,1);
sql create stream streams5 trigger at_once into streamt5 as select count(*), _wstart, _wend, max(a) from ts1 interval(10s) ;
sql create stream streams6 trigger at_once into streamt6 as select count(*), _wstart, _wend, max(a), _wstart as ts from ts1 interval(10s) ;
sql_error create stream streams7 trigger at_once into streamt7 as select _wstart, count(*), _wstart, _wend, max(a) from ts1 interval(10s) ;
sql_error create stream streams8 trigger at_once into streamt8 as select count(*), _wstart, _wstart, _wend, max(a) from ts1 interval(10s) ;
sql_error create stream streams9 trigger at_once into streamt9 as select _wstart as ts, count(*), _wstart as ts, _wend, max(a) from ts1 interval(10s) ;
sql insert into ts1 values(1648791211000,1,2,3);
print ====== test _wstart
$loop_count = 0
loop17:
sleep 200
sql select * from streamt5;
$loop_count = $loop_count + 1
if $loop_count == 10 then
return -1
endi
if $rows != 1 then
print =====rows=$rows
goto loop17
endi
sql select * from streamt6;
if $rows != 1 then
print =====rows=$rows
goto loop17
endi
print ====== test _wstart end
system sh/exec.sh -n dnode1 -s stop -x SIGINT