[add cases]
This commit is contained in:
plum-lihui
parent
6ce2556391
commit
4cb1e013cf
|
|
@ -0,0 +1,140 @@
|
|||
#### abs, log, pow, sqrt, sin, cos, tan, asin, acos, atan, ceil, floor, round
|
||||
|
||||
system sh/stop_dnodes.sh
|
||||
system sh/deploy.sh -n dnode1 -i 1
|
||||
system sh/cfg.sh -n dnode1
|
||||
system sh/exec.sh -n dnode1 -s start
|
||||
|
||||
$loop_cnt = 0
|
||||
check_dnode_ready:
|
||||
$loop_cnt = $loop_cnt + 1
|
||||
sleep 200
|
||||
if $loop_cnt == 10 then
|
||||
print ====> dnode not ready!
|
||||
return -1
|
||||
endi
|
||||
sql show dnodes
|
||||
print ===> $rows $data00 $data01 $data02 $data03 $data04 $data05
|
||||
if $data00 != 1 then
|
||||
return -1
|
||||
endi
|
||||
if $data04 != ready then
|
||||
goto check_dnode_ready
|
||||
endi
|
||||
|
||||
sql connect
|
||||
|
||||
$vgroups = 4
|
||||
$dbNamme = d0
|
||||
|
||||
print =============== create database $dbNamme vgroups $vgroups
|
||||
sql create database $dbNamme vgroups $vgroups
|
||||
sql show databases
|
||||
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
|
||||
#print $data20 $data21 $data22 $data23 $data24 $data25 $data26 $data27 $data28 $data29
|
||||
|
||||
sql use $dbNamme
|
||||
|
||||
print =============== create super table
|
||||
sql create table if not exists stb (ts timestamp, c1 int, c2 float, c3 double) tags (t1 int)
|
||||
|
||||
print =============== create child table
|
||||
$tbPrefix = ct
|
||||
$tbNum = 2
|
||||
|
||||
$i = 0
|
||||
while $i < $tbNum
|
||||
$tb = $tbPrefix . $i
|
||||
sql create table $tb using stb tags( $i )
|
||||
$i = $i + 1
|
||||
endw
|
||||
|
||||
print =============== create normal table
|
||||
sql create table ntb (ts timestamp, c1 int, c2 float, c3 double)
|
||||
|
||||
sql show tables
|
||||
if $rows != 3 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
print =============== insert data
|
||||
$rowNum = 20
|
||||
$tstart = 1640966400000 # 2022-01-01 00:00:00.000
|
||||
|
||||
$i = 0
|
||||
while $i < $tbNum
|
||||
$tb = $tbPrefix . $i
|
||||
|
||||
$x = 0
|
||||
$c1 = 0
|
||||
while $x < $rowNum
|
||||
$c2 = 0 - $c1
|
||||
$c3 = $c1 + 100
|
||||
|
||||
sql insert into $tb values ($tstart , $c1 , $c2 , $c3 )
|
||||
sql insert into ntb values ($tstart , $c1 , $c2 , $c3 )
|
||||
$tstart = $tstart + 1
|
||||
$c1 = $c1 + 5
|
||||
$x = $x + 1
|
||||
endw
|
||||
|
||||
$i = $i + 1
|
||||
$tstart = 1640966400000
|
||||
endw
|
||||
|
||||
print ====> abs
|
||||
sql select c1, abs(c1), c2, abs(c2), c3, abs(c3) from ct1
|
||||
print ====> select c1, abs(c1), c2, abs(c2), c3, abs(c3) from ct1
|
||||
print ====> rows: $rows
|
||||
print ====> $data00 $data01 $data02 $data03 $data04 $data05
|
||||
print ====> $data10 $data11 $data12 $data13 $data14 $data15
|
||||
print ====> $data20 $data21 $data22 $data23 $data24 $data25
|
||||
print ====> $data30 $data31 $data32 $data33 $data34 $data35
|
||||
print ====> $data40 $data41 $data42 $data43 $data44 $data45
|
||||
print ====> $data50 $data51 $data52 $data53 $data54 $data55
|
||||
print ====> $data60 $data61 $data62 $data63 $data64 $data65
|
||||
print ====> $data70 $data71 $data72 $data73 $data74 $data75
|
||||
print ====> $data80 $data81 $data82 $data83 $data84 $data85
|
||||
print ====> $data90 $data91 $data92 $data93 $data94 $data95
|
||||
if $rows != 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
print ====> sin
|
||||
sql select c1, sin(c1), c2, sin(c2), c3, sin(c3) from ct1
|
||||
print ====> select c1, sin(c1), c2, sin(c2), c3, sin(c3) from ct1
|
||||
print ====> rows: $rows
|
||||
print ====> $data00 $data01 $data02 $data03 $data04 $data05
|
||||
print ====> $data10 $data11 $data12 $data13 $data14 $data15
|
||||
print ====> $data20 $data21 $data22 $data23 $data24 $data25
|
||||
print ====> $data30 $data31 $data32 $data33 $data34 $data35
|
||||
print ====> $data40 $data41 $data42 $data43 $data44 $data45
|
||||
print ====> $data50 $data51 $data52 $data53 $data54 $data55
|
||||
print ====> $data60 $data61 $data62 $data63 $data64 $data65
|
||||
print ====> $data70 $data71 $data72 $data73 $data74 $data75
|
||||
print ====> $data80 $data81 $data82 $data83 $data84 $data85
|
||||
print ====> $data90 $data91 $data92 $data93 $data94 $data95
|
||||
if $rows != 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
print ====> cos
|
||||
sql select c1, cos(c1), c2, cos(c2), c3, cos(c3) from ct1
|
||||
print ====> select c1, cos(c1), c2, cos(c2), c3, cos(c3) from ct1
|
||||
print ====> rows: $rows
|
||||
print ====> $data00 $data01 $data02 $data03 $data04 $data05
|
||||
print ====> $data10 $data11 $data12 $data13 $data14 $data15
|
||||
print ====> $data20 $data21 $data22 $data23 $data24 $data25
|
||||
print ====> $data30 $data31 $data32 $data33 $data34 $data35
|
||||
print ====> $data40 $data41 $data42 $data43 $data44 $data45
|
||||
print ====> $data50 $data51 $data52 $data53 $data54 $data55
|
||||
print ====> $data60 $data61 $data62 $data63 $data64 $data65
|
||||
print ====> $data70 $data71 $data72 $data73 $data74 $data75
|
||||
print ====> $data80 $data81 $data82 $data83 $data84 $data85
|
||||
print ====> $data90 $data91 $data92 $data93 $data94 $data95
|
||||
if $rows != 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
#system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
||||
|
|
@ -226,7 +226,7 @@ void loop_consume(tmq_t* tmq) {
|
|||
int32_t totalRows = 0;
|
||||
int32_t skipLogNum = 0;
|
||||
while (running) {
|
||||
tmq_message_t* tmqMsg = tmq_consumer_poll(tmq, 3000);
|
||||
tmq_message_t* tmqMsg = tmq_consumer_poll(tmq, 6000);
|
||||
if (tmqMsg) {
|
||||
totalMsgs++;
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue