test: case for replica3
This commit is contained in:
Shengliang Guan
parent
fe14f49cf2
commit
f98d4f33be
|
|
@ -162,6 +162,12 @@
|
||||||
# --- valgrind
|
# --- valgrind
|
||||||
./test.sh -f tsim/valgrind/checkError.sim -v
|
./test.sh -f tsim/valgrind/checkError.sim -v
|
||||||
|
|
||||||
|
# --- vnode
|
||||||
|
#./test.sh -f tsim/vnode/replica3_basic.sim
|
||||||
|
#./test.sh -f tsim/vnode/replica3_repeat.sim
|
||||||
|
#./test.sh -f tsim/vnode/replica3_vgroup.sim
|
||||||
|
./test.sh -f tsim/vnode/replica3_many.sim
|
||||||
|
|
||||||
# --- sync
|
# --- sync
|
||||||
./test.sh -f tsim/sync/3Replica1VgElect.sim
|
./test.sh -f tsim/sync/3Replica1VgElect.sim
|
||||||
./test.sh -f tsim/sync/3Replica5VgElect.sim
|
./test.sh -f tsim/sync/3Replica5VgElect.sim
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,368 @@
|
||||||
|
system sh/stop_dnodes.sh
|
||||||
|
system sh/deploy.sh -n dnode1 -i 1
|
||||||
|
system sh/deploy.sh -n dnode2 -i 2
|
||||||
|
system sh/deploy.sh -n dnode3 -i 3
|
||||||
|
|
||||||
|
print ========== step0
|
||||||
|
system sh/exec.sh -n dnode1 -s start
|
||||||
|
sql connect
|
||||||
|
|
||||||
|
sql create dnode $hostname port 7200
|
||||||
|
sql create dnode $hostname port 7300
|
||||||
|
system sh/exec.sh -n dnode2 -s start
|
||||||
|
system sh/exec.sh -n dnode3 -s start
|
||||||
|
|
||||||
|
$x = 0
|
||||||
|
step01:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 10 then
|
||||||
|
print ====> dnode not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show dnodes
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05
|
||||||
|
print ===> $data10 $data11 $data12 $data13 $data14 $data15
|
||||||
|
print ===> $data20 $data21 $data22 $data23 $data24 $data25
|
||||||
|
if $rows != 3 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(1)[4] != ready then
|
||||||
|
goto step01
|
||||||
|
endi
|
||||||
|
if $data(2)[4] != ready then
|
||||||
|
goto step01
|
||||||
|
endi
|
||||||
|
if $data(3)[4] != ready then
|
||||||
|
goto step01
|
||||||
|
endi
|
||||||
|
|
||||||
|
sql create mnode on dnode 2
|
||||||
|
sql create mnode on dnode 3
|
||||||
|
|
||||||
|
$x = 0
|
||||||
|
step02:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 20 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show mnodes
|
||||||
|
print $data(1)[0] $data(1)[1] $data(1)[2]
|
||||||
|
print $data(2)[0] $data(2)[1] $data(2)[2]
|
||||||
|
print $data(3)[0] $data(3)[1] $data(3)[2]
|
||||||
|
|
||||||
|
if $rows != 3 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(1)[0] != 1 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(1)[2] != leader then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(2)[0] != 2 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(2)[2] != follower then
|
||||||
|
goto step02
|
||||||
|
endi
|
||||||
|
if $data(3)[0] != 3 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(3)[2] != follower then
|
||||||
|
goto step02
|
||||||
|
endi
|
||||||
|
|
||||||
|
$N = 10
|
||||||
|
$table = table_r3
|
||||||
|
$db = db1
|
||||||
|
|
||||||
|
print =================== step 1
|
||||||
|
sql create database $db replica 3 vgroups 1
|
||||||
|
sql use $db
|
||||||
|
|
||||||
|
$x = 0
|
||||||
|
step1:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show vgroups -x step1
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step1
|
||||||
|
endi
|
||||||
|
|
||||||
|
sql use $db
|
||||||
|
sql create table $table (ts timestamp, speed int)
|
||||||
|
|
||||||
|
print =================== step2
|
||||||
|
$x = 1
|
||||||
|
$y = $x + $N
|
||||||
|
$expect = $N
|
||||||
|
while $x < $y
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now + $ms , $x )
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
sql select * from $table
|
||||||
|
print sql select * from $table -> $rows points
|
||||||
|
if $rows != $expect then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
|
||||||
|
print =================== step3
|
||||||
|
system sh/exec.sh -n dnode2 -s stop
|
||||||
|
$x = 0
|
||||||
|
step3:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show vgroups -x step3
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step3
|
||||||
|
endi
|
||||||
|
|
||||||
|
$y = $x + $N
|
||||||
|
$expect = $N * 2
|
||||||
|
while $x < $y
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now + $ms , $x )
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
print sql select * from $table -> $rows points
|
||||||
|
#if $rows != $expect then
|
||||||
|
# return -1
|
||||||
|
#endi
|
||||||
|
|
||||||
|
print =================== step4
|
||||||
|
system sh/exec.sh -n dnode2 -s start
|
||||||
|
$x = 0
|
||||||
|
step4:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show vgroups -x step4
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step4
|
||||||
|
endi
|
||||||
|
|
||||||
|
$y = $x + $N
|
||||||
|
$expect = $N * 3
|
||||||
|
while $x < $y
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now + $ms , $x )
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
sql select * from $table
|
||||||
|
print sql select * from $table -> $rows points
|
||||||
|
#if $rows != $expect then
|
||||||
|
# return -1
|
||||||
|
#endi
|
||||||
|
|
||||||
|
print =================== step5
|
||||||
|
system sh/exec.sh -n dnode3 -s stop
|
||||||
|
$x = 0
|
||||||
|
step5:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show vgroups -x step5
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step5
|
||||||
|
endi
|
||||||
|
|
||||||
|
$y = $x + $N
|
||||||
|
$expect = $N * 4
|
||||||
|
while $x < $y
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now + $ms , 10)
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
sql select * from $table
|
||||||
|
print sql select * from $table -> $rows points
|
||||||
|
#if $rows != $expect then
|
||||||
|
# return -1
|
||||||
|
#endi
|
||||||
|
|
||||||
|
print =================== step6
|
||||||
|
system sh/exec.sh -n dnode3 -s start
|
||||||
|
$x = 0
|
||||||
|
step6:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show vgroups -x step6
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step6
|
||||||
|
endi
|
||||||
|
|
||||||
|
$y = $x + $N
|
||||||
|
$expect = $N * 5
|
||||||
|
while $x < $y
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now + $ms , $x )
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
sql select * from $table
|
||||||
|
print sql select * from $table -> $rows points
|
||||||
|
#if $rows != $expect then
|
||||||
|
# return -1
|
||||||
|
#endi
|
||||||
|
|
||||||
|
print =================== step7
|
||||||
|
system sh/exec.sh -n dnode1 -s stop
|
||||||
|
$x = 0
|
||||||
|
step7:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show vgroups -x step7
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step7
|
||||||
|
endi
|
||||||
|
|
||||||
|
$y = $x + $N
|
||||||
|
$expect = $N * 6
|
||||||
|
while $x < $y
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now + $ms , 10)
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
sql select * from $table
|
||||||
|
print sql select * from $table -> $rows points
|
||||||
|
#if $rows != $expect then
|
||||||
|
# return -1
|
||||||
|
#endi
|
||||||
|
|
||||||
|
print =================== step 8
|
||||||
|
system sh/exec.sh -n dnode1 -s start
|
||||||
|
$x = 0
|
||||||
|
step8:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show vgroups -x step8
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step8
|
||||||
|
endi
|
||||||
|
|
||||||
|
$y = $x + $N
|
||||||
|
$expect = $N * 7
|
||||||
|
while $x < $y
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now + $ms , 10)
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
print sql select * from $table -> $rows points
|
||||||
|
#if $rows != $expect then
|
||||||
|
# return -1
|
||||||
|
#endi
|
||||||
|
|
||||||
|
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
||||||
|
|
@ -0,0 +1,262 @@
|
||||||
|
system sh/stop_dnodes.sh
|
||||||
|
system sh/deploy.sh -n dnode1 -i 1
|
||||||
|
system sh/deploy.sh -n dnode2 -i 2
|
||||||
|
system sh/deploy.sh -n dnode3 -i 3
|
||||||
|
system sh/deploy.sh -n dnode4 -i 4
|
||||||
|
|
||||||
|
print ========== step0
|
||||||
|
system sh/exec.sh -n dnode1 -s start
|
||||||
|
sql connect
|
||||||
|
|
||||||
|
sql create dnode $hostname port 7200
|
||||||
|
sql create dnode $hostname port 7300
|
||||||
|
sql create dnode $hostname port 7400
|
||||||
|
system sh/exec.sh -n dnode2 -s start
|
||||||
|
system sh/exec.sh -n dnode3 -s start
|
||||||
|
system sh/exec.sh -n dnode4 -s start
|
||||||
|
|
||||||
|
$x = 0
|
||||||
|
step0:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 10 then
|
||||||
|
print ====> dnode not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show dnodes
|
||||||
|
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
|
||||||
|
if $rows != 4 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(1)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(2)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(3)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(4)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
|
||||||
|
print ========= step1
|
||||||
|
sql create database db1 replica 3 vgroups 1
|
||||||
|
sql create database db2 replica 3 vgroups 1
|
||||||
|
sql create database db3 replica 3 vgroups 1
|
||||||
|
sql create database db4 replica 3 vgroups 1
|
||||||
|
|
||||||
|
print =============== step12 wait vgroup2
|
||||||
|
$x = 0
|
||||||
|
step12:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show d1.vgroups
|
||||||
|
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
|
||||||
|
print ===> $data30 $data31 $data32 $data33 $data34 $data35 $data36 $data37 $data38 $data39
|
||||||
|
if $rows != 4 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step12
|
||||||
|
endi
|
||||||
|
|
||||||
|
print =============== step13 wait vgroup3
|
||||||
|
$x = 0
|
||||||
|
step13:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show d1.vgroups
|
||||||
|
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
|
||||||
|
print ===> $data30 $data31 $data32 $data33 $data34 $data35 $data36 $data37 $data38 $data39
|
||||||
|
if $rows != 4 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(3)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(3)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(3)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step13
|
||||||
|
endi
|
||||||
|
|
||||||
|
print =============== step14 wait vgroup4
|
||||||
|
$x = 0
|
||||||
|
step14:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show d1.vgroups
|
||||||
|
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
|
||||||
|
print ===> $data30 $data31 $data32 $data33 $data34 $data35 $data36 $data37 $data38 $data39
|
||||||
|
if $rows != 4 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(4)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(4)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(4)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step14
|
||||||
|
endi
|
||||||
|
|
||||||
|
print =============== step15 wait vgroup5
|
||||||
|
$x = 0
|
||||||
|
step15:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show d1.vgroups
|
||||||
|
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
|
||||||
|
print ===> $data30 $data31 $data32 $data33 $data34 $data35 $data36 $data37 $data38 $data39
|
||||||
|
if $rows != 4 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(4)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(4)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(4)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step15
|
||||||
|
endi
|
||||||
|
|
||||||
|
print =============== step16: create table
|
||||||
|
sql create table db1.tb1 (ts timestamp, i int)
|
||||||
|
sql create table db2.tb2 (ts timestamp, i int)
|
||||||
|
sql create table db3.tb3 (ts timestamp, i int)
|
||||||
|
sql create table db4.tb4 (ts timestamp, i int)
|
||||||
|
sql insert into db1.tb1 values(now, 1)
|
||||||
|
sql insert into db2.tb2 values(now, 1)
|
||||||
|
sql insert into db3.tb3 values(now, 1)
|
||||||
|
sql insert into db4.tb4 values(now, 1)
|
||||||
|
|
||||||
|
sql select count(*) from db1.tb1
|
||||||
|
$lastRows1 = $rows
|
||||||
|
sql select count(*) from db2.tb2
|
||||||
|
$lastRows2 = $rows
|
||||||
|
sql select count(*) from db3.tb3
|
||||||
|
$lastRows3 = $rows
|
||||||
|
sql select count(*) from db4.tb4
|
||||||
|
$lastRows4 = $rows
|
||||||
|
|
||||||
|
print ======== step2
|
||||||
|
run_back tsim/vnode/back_insert_many.sim
|
||||||
|
sleep 3000
|
||||||
|
|
||||||
|
$x = 0
|
||||||
|
loop:
|
||||||
|
|
||||||
|
print ======== step3
|
||||||
|
system sh/exec.sh -n dnode2 -s stop
|
||||||
|
sleep 3000
|
||||||
|
system sh/exec.sh -n dnode2 -s start
|
||||||
|
sleep 3000
|
||||||
|
|
||||||
|
print ======== step4
|
||||||
|
system sh/exec.sh -n dnode3 -s stop
|
||||||
|
sleep 3000
|
||||||
|
system sh/exec.sh -n dnode3 -s start
|
||||||
|
sleep 3000
|
||||||
|
|
||||||
|
print ======== step5
|
||||||
|
system sh/exec.sh -n dnode2 -s stop
|
||||||
|
sleep 3000
|
||||||
|
system sh/exec.sh -n dnode2 -s start
|
||||||
|
sleep 3000
|
||||||
|
|
||||||
|
print ======== step6
|
||||||
|
sql select count(*) from db1.tb1
|
||||||
|
print select count(*) from db1.tb1 ==> $data00 $lastRows1
|
||||||
|
if $data00 <= $lastRows1 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
$lastRows1 = $data00
|
||||||
|
|
||||||
|
sql select count(*) from db2.tb2
|
||||||
|
print select count(*) from db2.tb2 ==> $data00 $lastRows2
|
||||||
|
if $data00 <= $lastRows2 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
$lastRows2 = $data00
|
||||||
|
|
||||||
|
sql select count(*) from db3.tb3
|
||||||
|
print select count(*) from db3.tb3 ==> $data00 $lastRows3
|
||||||
|
if $data00 <= $lastRows3 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
$lastRows3 = $data00
|
||||||
|
|
||||||
|
sql select count(*) from db4.tb4
|
||||||
|
print select count(*) from db4.tb4 ==> $data00 $lastRows4
|
||||||
|
if $data00 <= $lastRows4 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
$lastRows4 = $data00
|
||||||
|
|
||||||
|
print ======== step7
|
||||||
|
|
||||||
|
print ======== loop Times $x
|
||||||
|
|
||||||
|
if $x < 2 then
|
||||||
|
$x = $x + 1
|
||||||
|
goto loop
|
||||||
|
endi
|
||||||
|
|
||||||
|
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode4 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode5 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode6 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode7 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode8 -s stop -x SIGINT
|
||||||
|
|
@ -1,77 +1,84 @@
|
||||||
system sh/stop_dnodes.sh
|
system sh/stop_dnodes.sh
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
system sh/deploy.sh -n dnode1 -i 1
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
system sh/deploy.sh -n dnode2 -i 2
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
system sh/deploy.sh -n dnode3 -i 3
|
||||||
system sh/deploy.sh -n dnode4 -i 4
|
system sh/deploy.sh -n dnode4 -i 4
|
||||||
system sh/cfg.sh -n dnode1 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode2 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode3 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode4 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode1 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode2 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode3 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode4 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode1 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode2 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode3 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode4 -c mnodeEqualVnodeNum -v 4
|
|
||||||
|
|
||||||
|
print ========== step0
|
||||||
system sh/exec.sh -n dnode1 -s start
|
system sh/exec.sh -n dnode1 -s start
|
||||||
|
|
||||||
sql connect
|
sql connect
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
sql create dnode $hostname port 7200
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname port 7300
|
||||||
|
sql create dnode $hostname port 7400
|
||||||
system sh/exec.sh -n dnode2 -s start
|
system sh/exec.sh -n dnode2 -s start
|
||||||
system sh/exec.sh -n dnode3 -s start
|
system sh/exec.sh -n dnode3 -s start
|
||||||
system sh/exec.sh -n dnode4 -s start
|
system sh/exec.sh -n dnode4 -s start
|
||||||
|
|
||||||
|
$x = 0
|
||||||
|
step0:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 10 then
|
||||||
|
print ====> dnode not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show dnodes
|
||||||
|
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
|
||||||
|
if $rows != 4 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(1)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(2)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(3)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(4)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
|
||||||
|
print ========= step1
|
||||||
|
sql create database db replica 3 vgroups 1
|
||||||
$x = 0
|
$x = 0
|
||||||
step1:
|
step1:
|
||||||
$x = $x + 1
|
$x = $x + 1
|
||||||
sleep 1000
|
sleep 1000
|
||||||
if $x == 10 then
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
return -1
|
return -1
|
||||||
endi
|
endi
|
||||||
|
sql show db.vgroups
|
||||||
sql show dnodes
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
print dnode1 $data4_1
|
if $rows != 4 then
|
||||||
print dnode2 $data4_2
|
return -1
|
||||||
print dnode3 $data4_3
|
|
||||||
print dnode4 $data4_4
|
|
||||||
|
|
||||||
if $data4_1 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
endi
|
||||||
if $data4_2 != ready then
|
if $data(2)[4] == leader then
|
||||||
goto step1
|
$leaderExist = 1
|
||||||
endi
|
endi
|
||||||
if $data4_3 != ready then
|
if $data(2)[6] == leader then
|
||||||
goto step1
|
$leaderExist = 1
|
||||||
endi
|
endi
|
||||||
if $data4_4 != ready then
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
goto step1
|
goto step1
|
||||||
endi
|
endi
|
||||||
|
|
||||||
sql show mnodes
|
|
||||||
print mnode1 $data2_1
|
|
||||||
print mnode1 $data2_2
|
|
||||||
print mnode1 $data2_3
|
|
||||||
if $data2_1 != master then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print ========= step1
|
|
||||||
sql create database db replica 3
|
|
||||||
sql create table db.tb (ts timestamp, i int)
|
sql create table db.tb (ts timestamp, i int)
|
||||||
sql insert into db.tb values(now, 1)
|
sql insert into db.tb values(now, 1)
|
||||||
sql select count(*) from db.tb
|
sql select count(*) from db.tb
|
||||||
$lastRows = $rows
|
$lastRows = $rows
|
||||||
|
|
||||||
print ======== step2
|
print ======== step2
|
||||||
run_back unique/vnode/back_insert.sim
|
run_back tsim/vnode/back_insert.sim
|
||||||
sleep 2000
|
sleep 2000
|
||||||
|
|
||||||
print ======== step3
|
print ======== step3
|
||||||
|
|
@ -0,0 +1,129 @@
|
||||||
|
system sh/stop_dnodes.sh
|
||||||
|
system sh/deploy.sh -n dnode1 -i 1
|
||||||
|
system sh/deploy.sh -n dnode2 -i 2
|
||||||
|
system sh/deploy.sh -n dnode3 -i 3
|
||||||
|
system sh/deploy.sh -n dnode4 -i 4
|
||||||
|
|
||||||
|
print ========== step0
|
||||||
|
system sh/exec.sh -n dnode1 -s start
|
||||||
|
sql connect
|
||||||
|
|
||||||
|
sql create dnode $hostname port 7200
|
||||||
|
sql create dnode $hostname port 7300
|
||||||
|
sql create dnode $hostname port 7400
|
||||||
|
system sh/exec.sh -n dnode2 -s start
|
||||||
|
system sh/exec.sh -n dnode3 -s start
|
||||||
|
system sh/exec.sh -n dnode4 -s start
|
||||||
|
|
||||||
|
$x = 0
|
||||||
|
step0:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 10 then
|
||||||
|
print ====> dnode not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show dnodes
|
||||||
|
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
|
||||||
|
if $rows != 4 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
if $data(1)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(2)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(3)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
if $data(4)[4] != ready then
|
||||||
|
goto step0
|
||||||
|
endi
|
||||||
|
|
||||||
|
$N = 10
|
||||||
|
$table = table_r3
|
||||||
|
$db = db1
|
||||||
|
|
||||||
|
print =================== step 1
|
||||||
|
sql create database $db replica 3 vgroups 2
|
||||||
|
sql use $db
|
||||||
|
|
||||||
|
$x = 0
|
||||||
|
step1:
|
||||||
|
$x = $x + 1
|
||||||
|
sleep 1000
|
||||||
|
if $x == 60 then
|
||||||
|
print ====> db not ready!
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
sql show vgroups
|
||||||
|
print ===> $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
|
||||||
|
print ===> $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
|
||||||
|
if $rows != 2 then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(2)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(2)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step1
|
||||||
|
endi
|
||||||
|
$leaderExist = 0
|
||||||
|
if $data(3)[4] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(3)[6] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $data(3)[8] == leader then
|
||||||
|
$leaderExist = 1
|
||||||
|
endi
|
||||||
|
if $leaderExist != 1 then
|
||||||
|
goto step1
|
||||||
|
endi
|
||||||
|
|
||||||
|
sql create table st (ts timestamp, speed int) tags (t1 int)
|
||||||
|
|
||||||
|
$tbPre = m
|
||||||
|
$N = 300
|
||||||
|
$x = 0
|
||||||
|
$y = $x + $N
|
||||||
|
while $x < $y
|
||||||
|
$table = $tbPre . $x
|
||||||
|
sql create table $table using st tags ( $x )
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now + $ms , $x )
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
#print =================== step2
|
||||||
|
$x = -500
|
||||||
|
$y = $x + $N
|
||||||
|
while $x < $y
|
||||||
|
$ms = $x . m
|
||||||
|
sql insert into $table values (now $ms , $x )
|
||||||
|
$x = $x + 1
|
||||||
|
endw
|
||||||
|
|
||||||
|
$expect = $N + 1
|
||||||
|
sql select * from $table
|
||||||
|
print sql select * from $table -> $rows points expect $expect
|
||||||
|
if $rows != $expect then
|
||||||
|
return -1
|
||||||
|
endi
|
||||||
|
|
||||||
|
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
||||||
|
system sh/exec.sh -n dnode4 -s stop -x SIGINT
|
||||||
|
|
@ -1,220 +0,0 @@
|
||||||
system sh/stop_dnodes.sh
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
|
||||||
system sh/deploy.sh -n dnode4 -i 4
|
|
||||||
|
|
||||||
system sh/cfg.sh -n dnode1 -c walLevel -v 1
|
|
||||||
system sh/cfg.sh -n dnode2 -c walLevel -v 1
|
|
||||||
system sh/cfg.sh -n dnode3 -c walLevel -v 1
|
|
||||||
system sh/cfg.sh -n dnode4 -c walLevel -v 1
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
$x = 0
|
|
||||||
connectTbase:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 20 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
sql connect -x connectTbase
|
|
||||||
|
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
|
||||||
sql create dnode $hostname4
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
system sh/exec.sh -n dnode4 -s start
|
|
||||||
sleep 3001
|
|
||||||
|
|
||||||
$N = 10
|
|
||||||
$table = table_r4
|
|
||||||
$db = db1
|
|
||||||
|
|
||||||
print =================== step 1
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
created:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 20 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
sql create database $db replica 4 -x created
|
|
||||||
sql use $db
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
create1:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 20 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
sql create table $table (ts timestamp, speed int) -x create1
|
|
||||||
sleep 3001
|
|
||||||
|
|
||||||
print =================== step 2
|
|
||||||
$x = 1
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 3
|
|
||||||
system sh/exec.sh -n dnode2 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 2
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 4
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 3
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 5
|
|
||||||
system sh/exec.sh -n dnode3 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 4
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 6
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 5
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
|
|
||||||
print =================== step 7
|
|
||||||
system sh/exec.sh -n dnode4 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 6
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 8
|
|
||||||
system sh/exec.sh -n dnode4 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 7
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 9
|
|
||||||
system sh/exec.sh -n dnode1 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 8
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 10
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 9
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s stop
|
|
||||||
system sh/exec.sh -n dnode2 -s stop
|
|
||||||
system sh/exec.sh -n dnode3 -s stop
|
|
||||||
system sh/exec.sh -n dnode4 -s stop
|
|
||||||
|
|
||||||
|
|
@ -1,263 +0,0 @@
|
||||||
system sh/stop_dnodes.sh
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
|
||||||
system sh/deploy.sh -n dnode4 -i 4
|
|
||||||
system sh/deploy.sh -n dnode5 -i 5
|
|
||||||
|
|
||||||
system sh/cfg.sh -n dnode1 -c walLevel -v 1
|
|
||||||
system sh/cfg.sh -n dnode2 -c walLevel -v 1
|
|
||||||
system sh/cfg.sh -n dnode3 -c walLevel -v 1
|
|
||||||
system sh/cfg.sh -n dnode4 -c walLevel -v 1
|
|
||||||
system sh/cfg.sh -n dnode5 -c walLevel -v 1
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
connectTbase:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 20 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
sql connect -x connectTbase
|
|
||||||
|
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
|
||||||
sql create dnode $hostname4
|
|
||||||
sql create dnode $hostname5
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
system sh/exec.sh -n dnode4 -s start
|
|
||||||
system sh/exec.sh -n dnode5 -s start
|
|
||||||
sleep 3001
|
|
||||||
|
|
||||||
$N = 10
|
|
||||||
$table = table_r5
|
|
||||||
$db = db1
|
|
||||||
|
|
||||||
print =================== step 1
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
created:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 20 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
sql create database $db replica 5 -x created
|
|
||||||
sql use $db
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
create1:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 20 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
sql create table $table (ts timestamp, speed int) -x create1
|
|
||||||
|
|
||||||
sleep 3001
|
|
||||||
|
|
||||||
print =================== step 2
|
|
||||||
$x = 1
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 3
|
|
||||||
system sh/exec.sh -n dnode2 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 2
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 4
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 3
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 5
|
|
||||||
system sh/exec.sh -n dnode3 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 4
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 6
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 5
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
|
|
||||||
print =================== step 7
|
|
||||||
system sh/exec.sh -n dnode4 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 6
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 8
|
|
||||||
system sh/exec.sh -n dnode4 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 7
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
|
|
||||||
print =================== step 9
|
|
||||||
system sh/exec.sh -n dnode5 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 8
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 10
|
|
||||||
system sh/exec.sh -n dnode5 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 9
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 11
|
|
||||||
system sh/exec.sh -n dnode1 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 10
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 12
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 11
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s stop
|
|
||||||
system sh/exec.sh -n dnode2 -s stop
|
|
||||||
system sh/exec.sh -n dnode3 -s stop
|
|
||||||
system sh/exec.sh -n dnode4 -s stop
|
|
||||||
system sh/exec.sh -n dnode5 -s stop
|
|
||||||
|
|
||||||
|
|
@ -1,147 +0,0 @@
|
||||||
system sh/stop_dnodes.sh
|
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
|
||||||
system sh/deploy.sh -n dnode4 -i 4
|
|
||||||
system sh/cfg.sh -n dnode1 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode2 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode3 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode4 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode1 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode2 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode3 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode4 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode1 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode2 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode3 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode4 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
|
|
||||||
sql connect
|
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
$x = 0
|
|
||||||
step1:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 10 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show dnodes
|
|
||||||
print dnode1 $data4_1
|
|
||||||
print dnode2 $data4_2
|
|
||||||
print dnode3 $data4_3
|
|
||||||
print dnode4 $data4_4
|
|
||||||
|
|
||||||
if $data4_1 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
if $data4_2 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
if $data4_3 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show mnodes
|
|
||||||
print mnode1 $data2_1
|
|
||||||
print mnode1 $data2_2
|
|
||||||
print mnode1 $data2_3
|
|
||||||
if $data2_1 != master then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print ========= step1
|
|
||||||
sql create database db1 replica 2
|
|
||||||
sql create database db2 replica 2
|
|
||||||
sql create database db3 replica 2
|
|
||||||
sql create database db4 replica 2
|
|
||||||
sql create table db1.tb1 (ts timestamp, i int)
|
|
||||||
sql create table db2.tb2 (ts timestamp, i int)
|
|
||||||
sql create table db3.tb3 (ts timestamp, i int)
|
|
||||||
sql create table db4.tb4 (ts timestamp, i int)
|
|
||||||
sql insert into db1.tb1 values(now, 1)
|
|
||||||
sql insert into db2.tb2 values(now, 1)
|
|
||||||
sql insert into db3.tb3 values(now, 1)
|
|
||||||
sql insert into db4.tb4 values(now, 1)
|
|
||||||
|
|
||||||
sql select count(*) from db1.tb1
|
|
||||||
$lastRows1 = $rows
|
|
||||||
sql select count(*) from db2.tb2
|
|
||||||
$lastRows2 = $rows
|
|
||||||
sql select count(*) from db3.tb3
|
|
||||||
$lastRows3 = $rows
|
|
||||||
sql select count(*) from db4.tb4
|
|
||||||
$lastRows4 = $rows
|
|
||||||
|
|
||||||
print ======== step2
|
|
||||||
run_back unique/vnode/back_insert_many.sim
|
|
||||||
sleep 3000
|
|
||||||
|
|
||||||
print ======== step3
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
loop:
|
|
||||||
|
|
||||||
print ======== step4
|
|
||||||
system sh/exec.sh -n dnode3 -s stop
|
|
||||||
sleep 3000
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
sleep 3000
|
|
||||||
|
|
||||||
print ======== step5
|
|
||||||
system sh/exec.sh -n dnode2 -s stop
|
|
||||||
sleep 3000
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
sleep 3000
|
|
||||||
|
|
||||||
print ======== step6
|
|
||||||
sql select count(*) from db1.tb1
|
|
||||||
print select count(*) from db1.tb1 ==> $data00 $lastRows1
|
|
||||||
if $data00 <= $lastRows1 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
$lastRows1 = $data00
|
|
||||||
|
|
||||||
sql select count(*) from db2.tb2
|
|
||||||
print select count(*) from db2.tb2 ==> $data00 $lastRows2
|
|
||||||
if $data00 <= $lastRows2 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
$lastRows2 = $data00
|
|
||||||
|
|
||||||
sql select count(*) from db3.tb3
|
|
||||||
print select count(*) from db3.tb3 ==> $data00 $lastRows3
|
|
||||||
if $data00 <= $lastRows3 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
$lastRows3 = $data00
|
|
||||||
|
|
||||||
sql select count(*) from db4.tb4
|
|
||||||
print select count(*) from db4.tb4 ==> $data00 $lastRows4
|
|
||||||
if $data00 <= $lastRows4 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
$lastRows4 = $data00
|
|
||||||
|
|
||||||
print ======== step7
|
|
||||||
|
|
||||||
print ======== loop Times $x
|
|
||||||
|
|
||||||
if $x < 2 then
|
|
||||||
$x = $x + 1
|
|
||||||
goto loop
|
|
||||||
endi
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode4 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode5 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode6 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode7 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode8 -s stop -x SIGINT
|
|
||||||
|
|
@ -1,103 +0,0 @@
|
||||||
system sh/stop_dnodes.sh
|
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
|
||||||
system sh/deploy.sh -n dnode4 -i 4
|
|
||||||
system sh/cfg.sh -n dnode1 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode2 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode3 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode4 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode1 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode2 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode3 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode4 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode1 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode2 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode3 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode4 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode1 -c debugFlag -v 131
|
|
||||||
system sh/cfg.sh -n dnode2 -c debugFlag -v 131
|
|
||||||
system sh/cfg.sh -n dnode3 -c debugFlag -v 131
|
|
||||||
system sh/cfg.sh -n dnode4 -c debugFlag -v 131
|
|
||||||
system sh/cfg.sh -n dnode1 -c arbitrator -v $arbitrator
|
|
||||||
system sh/cfg.sh -n dnode2 -c arbitrator -v $arbitrator
|
|
||||||
system sh/cfg.sh -n dnode3 -c arbitrator -v $arbitrator
|
|
||||||
system sh/cfg.sh -n dnode4 -c arbitrator -v $arbitrator
|
|
||||||
|
|
||||||
print ============== step0: start tarbitrator
|
|
||||||
system sh/exec_tarbitrator.sh -s start
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
sleep 2000
|
|
||||||
sql connect
|
|
||||||
|
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
|
||||||
system sh/exec.sh -n dnode2 -s start -t
|
|
||||||
system sh/exec.sh -n dnode3 -s start -t
|
|
||||||
sleep 2000
|
|
||||||
|
|
||||||
print ========= step1
|
|
||||||
sql create database db replica 2
|
|
||||||
#sql create table db.tb1 (ts timestamp, i int)
|
|
||||||
#sql create table db.tb2 (ts timestamp, i int)
|
|
||||||
#sql create table db.tb3 (ts timestamp, i int)
|
|
||||||
#sql create table db.tb4 (ts timestamp, i int)
|
|
||||||
#sql insert into db.tb1 values(now, 1)
|
|
||||||
#sql select count(*) from db.tb1
|
|
||||||
|
|
||||||
sql create database db replica 2
|
|
||||||
sql create table db.tb (ts timestamp, i int)
|
|
||||||
sql insert into db.tb values(now, 1)
|
|
||||||
sql select count(*) from db.tb
|
|
||||||
$lastRows = $rows
|
|
||||||
|
|
||||||
print ======== step2
|
|
||||||
#run_back unique/vnode/back_insert_many.sim
|
|
||||||
run_back unique/vnode/back_insert.sim
|
|
||||||
sleep 2000
|
|
||||||
|
|
||||||
print ======== step3
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
loop:
|
|
||||||
|
|
||||||
print ======== step4
|
|
||||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
|
||||||
sleep 10000
|
|
||||||
system sh/exec.sh -n dnode2 -s start -t
|
|
||||||
sleep 10000
|
|
||||||
|
|
||||||
print ======== step5
|
|
||||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
|
||||||
sleep 10000
|
|
||||||
system sh/exec.sh -n dnode3 -s start -t
|
|
||||||
sleep 10000
|
|
||||||
|
|
||||||
print ======== step6
|
|
||||||
#sql select count(*) from db.tb1
|
|
||||||
#print select count(*) from db.tb1 ==> $data00 $lastRows
|
|
||||||
sql select count(*) from db.tb
|
|
||||||
print select count(*) from db.tb ==> $data00 $lastRows
|
|
||||||
if $data00 <= $lastRows then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print ======== step7
|
|
||||||
$lastRows = $data00
|
|
||||||
print ======== loop Times $x
|
|
||||||
|
|
||||||
if $x < 10 then
|
|
||||||
$x = $x + 1
|
|
||||||
goto loop
|
|
||||||
endi
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode4 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode5 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode6 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode7 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode8 -s stop -x SIGINT
|
|
||||||
|
|
@ -1,223 +0,0 @@
|
||||||
system sh/stop_dnodes.sh
|
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
|
||||||
system sh/deploy.sh -n dnode4 -i 4
|
|
||||||
|
|
||||||
system sh/cfg.sh -n dnode1 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode2 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode3 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode4 -c wallevel -v 2
|
|
||||||
|
|
||||||
system sh/cfg.sh -n dnode1 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode2 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode3 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode4 -c numOfMnodes -v 1
|
|
||||||
|
|
||||||
system sh/cfg.sh -n dnode1 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode2 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode3 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode4 -c mnodeEqualVnodeNum -v 4
|
|
||||||
|
|
||||||
print ========= start dnodes
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
sleep 2000
|
|
||||||
sql connect
|
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
sleep 2000
|
|
||||||
|
|
||||||
sql reset query cache
|
|
||||||
|
|
||||||
print ========= step1
|
|
||||||
sql create database d1 replica 2
|
|
||||||
sql create database d2 replica 2
|
|
||||||
sql create database d3 replica 2
|
|
||||||
sql create database d4 replica 2
|
|
||||||
|
|
||||||
sql create table d1.t1 (ts timestamp, i int)
|
|
||||||
sql create table d2.t2 (ts timestamp, i int)
|
|
||||||
sql create table d3.t3 (ts timestamp, i int)
|
|
||||||
sql create table d4.t4 (ts timestamp, i int)
|
|
||||||
|
|
||||||
sql insert into d1.t1 values(now, 1)
|
|
||||||
sql insert into d2.t2 values(now, 1)
|
|
||||||
sql insert into d3.t3 values(now, 1)
|
|
||||||
sql insert into d4.t4 values(now, 1)
|
|
||||||
|
|
||||||
sql select * from d1.t1
|
|
||||||
if $rows != 1 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d2.t2
|
|
||||||
if $rows != 1 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d3.t3
|
|
||||||
if $rows != 1 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d4.t4
|
|
||||||
if $rows != 1 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show dnodes
|
|
||||||
print dnode1 ==> openVnodes: $data2_1
|
|
||||||
print dnode2 ==> openVnodes: $data2_2
|
|
||||||
print dnode3 ==> openVnodes: $data2_3
|
|
||||||
|
|
||||||
if $data2_1 != 0 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
if $data2_2 != 4 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
if $data2_3 != 4 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
if $data4_1 != ready then
|
|
||||||
print dnode1 status should ready but is $data4_1
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
if $data4_2 != ready then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
if $data4_3 != ready then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print ========= step2
|
|
||||||
sql insert into d1.t1 values(now, 2)
|
|
||||||
sql insert into d2.t2 values(now, 2)
|
|
||||||
sql insert into d3.t3 values(now, 2)
|
|
||||||
sql insert into d4.t4 values(now, 2)
|
|
||||||
|
|
||||||
sql select * from d1.t1
|
|
||||||
if $rows != 2 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d2.t2
|
|
||||||
if $rows != 2 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d3.t3
|
|
||||||
if $rows != 2 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d4.t4
|
|
||||||
if $rows != 2 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print ========= step3
|
|
||||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
|
||||||
sleep 3000
|
|
||||||
|
|
||||||
#sql insert into d1.t1 values(now, 3)
|
|
||||||
#sql insert into d2.t2 values(now, 3)
|
|
||||||
#sql insert into d3.t3 values(now, 3)
|
|
||||||
#sql insert into d4.t4 values(now, 3)
|
|
||||||
|
|
||||||
#sql select * from d1.t1
|
|
||||||
#if $rows != 2 then
|
|
||||||
# return -1
|
|
||||||
#endi
|
|
||||||
|
|
||||||
#sql select * from d2.t2
|
|
||||||
#if $rows != 2 then
|
|
||||||
# return -1
|
|
||||||
#endi
|
|
||||||
|
|
||||||
#sql select * from d3.t3
|
|
||||||
#if $rows != 2 then
|
|
||||||
# return -1
|
|
||||||
#endi
|
|
||||||
|
|
||||||
#sql select * from d4.t4
|
|
||||||
#if $rows != 2 then
|
|
||||||
# return -1
|
|
||||||
#endi
|
|
||||||
|
|
||||||
print ========= step4
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
sleep 3000
|
|
||||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
|
||||||
sleep 3000
|
|
||||||
|
|
||||||
#sql insert into d1.t1 values(now, 4)
|
|
||||||
#sql insert into d2.t2 values(now, 4)
|
|
||||||
#sql insert into d3.t3 values(now, 4)
|
|
||||||
#sql insert into d4.t4 values(now, 4)
|
|
||||||
|
|
||||||
#sql select * from d1.t1
|
|
||||||
#if $rows != 2 then
|
|
||||||
# return -1
|
|
||||||
#endi
|
|
||||||
|
|
||||||
#sql select * from d2.t2
|
|
||||||
#if $rows != 2 then
|
|
||||||
# return -1
|
|
||||||
#endi
|
|
||||||
|
|
||||||
#sql select * from d3.t3
|
|
||||||
#if $rows != 2 then
|
|
||||||
# return -1
|
|
||||||
#endi
|
|
||||||
|
|
||||||
#sql select * from d4.t4
|
|
||||||
#if $rows != 2 then
|
|
||||||
# return -1
|
|
||||||
#endi
|
|
||||||
|
|
||||||
print ========= step5
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
sleep 3000
|
|
||||||
|
|
||||||
sql insert into d1.t1 values(now, 5)
|
|
||||||
sql insert into d2.t2 values(now, 5)
|
|
||||||
sql insert into d3.t3 values(now, 5)
|
|
||||||
sql insert into d4.t4 values(now, 5)
|
|
||||||
|
|
||||||
sql select * from d1.t1
|
|
||||||
if $rows != 3 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d2.t2
|
|
||||||
if $rows != 3 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d3.t3
|
|
||||||
if $rows != 3 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql select * from d4.t4
|
|
||||||
if $rows != 3 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode4 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode5 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode6 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode7 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode8 -s stop -x SIGINT
|
|
||||||
|
|
@ -1,110 +0,0 @@
|
||||||
system sh/stop_dnodes.sh
|
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
|
||||||
system sh/deploy.sh -n dnode4 -i 4
|
|
||||||
system sh/cfg.sh -n dnode1 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode2 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode3 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode4 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode1 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode2 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode3 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode4 -c numOfMnodes -v 1
|
|
||||||
system sh/cfg.sh -n dnode1 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode2 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode3 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/cfg.sh -n dnode4 -c mnodeEqualVnodeNum -v 4
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
|
|
||||||
sql connect
|
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
step1:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 10 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show dnodes
|
|
||||||
print dnode1 $data4_1
|
|
||||||
print dnode2 $data4_2
|
|
||||||
print dnode3 $data4_3
|
|
||||||
print dnode4 $data4_4
|
|
||||||
|
|
||||||
if $data4_1 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
if $data4_2 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
if $data4_3 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show mnodes
|
|
||||||
print mnode1 $data2_1
|
|
||||||
print mnode1 $data2_2
|
|
||||||
print mnode1 $data2_3
|
|
||||||
if $data2_1 != master then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print ========= step1
|
|
||||||
sql create database db replica 2
|
|
||||||
sql create table db.tb (ts timestamp, i int)
|
|
||||||
sql insert into db.tb values(now, 1)
|
|
||||||
sql select count(*) from db.tb
|
|
||||||
$lastRows = $rows
|
|
||||||
|
|
||||||
print ======== step2
|
|
||||||
run_back unique/vnode/back_insert.sim
|
|
||||||
sleep 2000
|
|
||||||
|
|
||||||
print ======== step3
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
loop:
|
|
||||||
|
|
||||||
print ======== step4
|
|
||||||
system sh/exec.sh -n dnode2 -s stop
|
|
||||||
sleep 3000
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
sleep 3000
|
|
||||||
|
|
||||||
print ======== step5
|
|
||||||
system sh/exec.sh -n dnode3 -s stop
|
|
||||||
sleep 3000
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
sleep 3000
|
|
||||||
|
|
||||||
print ======== step6
|
|
||||||
sql select count(*) from db.tb
|
|
||||||
print select count(*) from db.tb ==> $data00 $lastRows
|
|
||||||
if $data00 <= $lastRows then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print ======== step7
|
|
||||||
$lastRows = $data00
|
|
||||||
print ======== loop Times $x
|
|
||||||
|
|
||||||
if $x < 2 then
|
|
||||||
$x = $x + 1
|
|
||||||
goto loop
|
|
||||||
endi
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode4 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode5 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode6 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode7 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode8 -s stop -x SIGINT
|
|
||||||
|
|
@ -1,233 +0,0 @@
|
||||||
system sh/stop_dnodes.sh
|
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
|
||||||
system sh/cfg.sh -n dnode1 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode2 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode3 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode1 -c numOfMnodes -v 3
|
|
||||||
system sh/cfg.sh -n dnode2 -c numOfMnodes -v 3
|
|
||||||
system sh/cfg.sh -n dnode3 -c numOfMnodes -v 3
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
sql connect
|
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
step1:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 10 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show dnodes
|
|
||||||
print dnode1 $data4_1
|
|
||||||
print dnode2 $data4_2
|
|
||||||
print dnode3 $data4_3
|
|
||||||
|
|
||||||
if $data4_1 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
if $data4_2 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
if $data4_3 != ready then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show mnodes
|
|
||||||
print mnode1 $data2_1
|
|
||||||
print mnode1 $data2_2
|
|
||||||
print mnode1 $data2_3
|
|
||||||
if $data2_1 != master then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
if $data2_2 != slave then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
if $data2_3 != slave then
|
|
||||||
goto step1
|
|
||||||
endi
|
|
||||||
|
|
||||||
$N = 10
|
|
||||||
$table = table_r3
|
|
||||||
$db = db1
|
|
||||||
|
|
||||||
print =================== step 1
|
|
||||||
|
|
||||||
sql create database $db replica 3
|
|
||||||
sql use $db
|
|
||||||
sql create table $table (ts timestamp, speed int)
|
|
||||||
sleep 3001
|
|
||||||
|
|
||||||
print =================== step 2
|
|
||||||
$x = 1
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 3
|
|
||||||
system sh/exec.sh -n dnode2 -s stop
|
|
||||||
sleep 2000
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 2
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 4
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
step4:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 40 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show db1.vgroups
|
|
||||||
print online vnodes $data03
|
|
||||||
if $data03 != 3 then
|
|
||||||
goto step4
|
|
||||||
endi
|
|
||||||
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 3
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 5
|
|
||||||
system sh/exec.sh -n dnode3 -s stop
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 4
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 6
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
step6:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 40 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show db1.vgroups
|
|
||||||
print online vnodes $data03
|
|
||||||
if $data03 != 3 then
|
|
||||||
goto step6
|
|
||||||
endi
|
|
||||||
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 5
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 7
|
|
||||||
system sh/exec.sh -n dnode1 -s stop
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 6
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
print =================== step 8
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
|
|
||||||
$x = 0
|
|
||||||
step8:
|
|
||||||
$x = $x + 1
|
|
||||||
sleep 1000
|
|
||||||
if $x == 40 then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
sql show db1.vgroups
|
|
||||||
print online vnodes $data03
|
|
||||||
if $data03 != 3 then
|
|
||||||
goto step8
|
|
||||||
endi
|
|
||||||
|
|
||||||
$y = $x + $N
|
|
||||||
$expect = $N * 7
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , 10)
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode4 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode5 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode6 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode7 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode8 -s stop -x SIGINT
|
|
||||||
|
|
@ -1,71 +0,0 @@
|
||||||
system sh/stop_dnodes.sh
|
|
||||||
|
|
||||||
system sh/deploy.sh -n dnode1 -i 1
|
|
||||||
system sh/deploy.sh -n dnode2 -i 2
|
|
||||||
system sh/deploy.sh -n dnode3 -i 3
|
|
||||||
system sh/cfg.sh -n dnode1 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode2 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode3 -c wallevel -v 2
|
|
||||||
system sh/cfg.sh -n dnode1 -c numOfMnodes -v 3
|
|
||||||
system sh/cfg.sh -n dnode2 -c numOfMnodes -v 3
|
|
||||||
system sh/cfg.sh -n dnode3 -c numOfMnodes -v 3
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s start
|
|
||||||
sql connect
|
|
||||||
sql create dnode $hostname2
|
|
||||||
sql create dnode $hostname3
|
|
||||||
system sh/exec.sh -n dnode2 -s start
|
|
||||||
system sh/exec.sh -n dnode3 -s start
|
|
||||||
sleep 2000
|
|
||||||
|
|
||||||
$N = 10
|
|
||||||
$table = table_r3
|
|
||||||
$db = db1
|
|
||||||
|
|
||||||
sleep 2000
|
|
||||||
|
|
||||||
print =================== step 1
|
|
||||||
|
|
||||||
sql create database $db replica 3
|
|
||||||
sql use $db
|
|
||||||
sql create table st (ts timestamp, speed int) tags (t1 int)
|
|
||||||
sleep 3001
|
|
||||||
|
|
||||||
|
|
||||||
$tbPre = m
|
|
||||||
$N = 300
|
|
||||||
$x = 0
|
|
||||||
$y = $x + $N
|
|
||||||
while $x < $y
|
|
||||||
$table = $tbPre . $x
|
|
||||||
sql create table $table using st tags ( $x )
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now + $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
|
|
||||||
#print =================== step 2
|
|
||||||
$x = -500
|
|
||||||
$y = $x + $N
|
|
||||||
while $x < $y
|
|
||||||
$ms = $x . m
|
|
||||||
sql insert into $table values (now $ms , $x )
|
|
||||||
$x = $x + 1
|
|
||||||
endw
|
|
||||||
|
|
||||||
$expect = $N + 1
|
|
||||||
sql select * from $table
|
|
||||||
print sql select * from $table -> $rows points expect $expect
|
|
||||||
if $rows != $expect then
|
|
||||||
return -1
|
|
||||||
endi
|
|
||||||
|
|
||||||
system sh/exec.sh -n dnode1 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode4 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode5 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode6 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode7 -s stop -x SIGINT
|
|
||||||
system sh/exec.sh -n dnode8 -s stop -x SIGINT
|
|
||||||
|
|
@ -1,6 +0,0 @@
|
||||||
run unique/vnode/many.sim
|
|
||||||
run unique/vnode/replica2_basic2.sim
|
|
||||||
run unique/vnode/replica2_repeat.sim
|
|
||||||
run unique/vnode/replica3_basic.sim
|
|
||||||
run unique/vnode/replica3_repeat.sim
|
|
||||||
run unique/vnode/replica3_vgroup.sim
|
|
||||||
Loading…
Reference in New Issue