This commit is contained in:
54liuyao 2024-03-26 19:11:19 +08:00
parent 93edc9d1ff
commit ed87ac75a7
4 changed files with 146 additions and 72 deletions

View File

@ -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

View File

@ -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

View File

@ -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

View File

@ -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