[add cluster cases]
This commit is contained in:
parent
a427d5bc28
commit
754eb6be0f
|
@ -55,7 +55,7 @@ sql create dnode $hostname3
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 10000
|
$totalTableNum = 1000
|
||||||
$sleepTimer = 10000
|
$sleepTimer = 10000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
|
@ -133,5 +133,3 @@ if $data00 != $totalRows then
|
||||||
return -1
|
return -1
|
||||||
endi
|
endi
|
||||||
|
|
||||||
print drop dnode $hostname3, return error: not drop dnode for repica is 2, need 2 dnodes.
|
|
||||||
sql_error drop dnode $hostname3
|
|
||||||
|
|
|
@ -59,7 +59,7 @@ $totalTableNum = 100
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
sql create database $db replica 3 maxTables $totalTableNum
|
sql create database $db replica 2 maxTables $totalTableNum
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
|
@ -168,7 +168,7 @@ $dnode4Status = $data4_4
|
||||||
|
|
||||||
if $dnode3Status != ready then
|
if $dnode3Status != ready then
|
||||||
sleep 2000
|
sleep 2000
|
||||||
goto wait_dnode4_reready
|
goto wait_dnode3_reready
|
||||||
endi
|
endi
|
||||||
|
|
||||||
sql select count(*) from $stb
|
sql select count(*) from $stb
|
||||||
|
@ -213,8 +213,8 @@ print show vgroups:
|
||||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1 $data5_1 $data6_1 $data7_1 $data8_1 $data9_1
|
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1 $data5_1 $data6_1 $data7_1 $data8_1 $data9_1
|
||||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2 $data5_2 $data6_2 $data7_2 $data8_2 $data9_2
|
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2 $data5_2 $data6_2 $data7_2 $data8_2 $data9_2
|
||||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $data7_3 $data8_3 $data9_3
|
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $data7_3 $data8_3 $data9_3
|
||||||
$dnode2Vtatus = $data4_2
|
$dnode2Vtatus = $data7_2
|
||||||
$dnode3Vtatus = $data7_2
|
$dnode3Vtatus = $data4_2
|
||||||
|
|
||||||
if $dnode2Vtatus != offline then
|
if $dnode2Vtatus != offline then
|
||||||
sleep 2000
|
sleep 2000
|
||||||
|
|
|
@ -59,7 +59,7 @@ $totalTableNum = 100
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
sql create database $db replica 3 maxTables $totalTableNum
|
sql create database $db replica 2 maxTables $totalTableNum
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
|
@ -141,8 +141,8 @@ print show vgroups:
|
||||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1 $data5_1 $data6_1 $data7_1 $data8_1 $data9_1
|
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1 $data5_1 $data6_1 $data7_1 $data8_1 $data9_1
|
||||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2 $data5_2 $data6_2 $data7_2 $data8_2 $data9_2
|
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2 $data5_2 $data6_2 $data7_2 $data8_2 $data9_2
|
||||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $data7_3 $data8_3 $data9_3
|
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $data7_3 $data8_3 $data9_3
|
||||||
$dnode2Vtatus = $data4_2
|
$dnode2Vtatus = $data7_2
|
||||||
$dnode3Vtatus = $data7_2
|
$dnode3Vtatus = $data4_2
|
||||||
|
|
||||||
if $dnode2Vtatus != offline then
|
if $dnode2Vtatus != offline then
|
||||||
sleep 2000
|
sleep 2000
|
||||||
|
|
|
@ -47,7 +47,7 @@ system sh/exec.sh -n dnode1 -s start
|
||||||
sleep 3000
|
sleep 3000
|
||||||
sql connect
|
sql connect
|
||||||
|
|
||||||
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 3, and create table, insert data
|
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 2, and create table, insert data
|
||||||
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
|
||||||
|
@ -60,13 +60,13 @@ $totalTableNum = 100
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
print create database $db replica 3 maxTables $totalTableNum
|
print create database $db replica 2 maxTables $totalTableNum
|
||||||
sql create database $db replica 3 maxTables $totalTableNum
|
sql create database $db replica 2 maxTables $totalTableNum
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
$stb = stb
|
$stb = stb
|
||||||
sql create table $stb (ts timestamp, c1 int) tags(t1 int)
|
sql create table $stb (ts timestamp, c1 int, c2 int) tags(t1 int)
|
||||||
$rowNum = 500
|
$rowNum = 500
|
||||||
$tblNum = $totalTableNum
|
$tblNum = $totalTableNum
|
||||||
$totalRows = 0
|
$totalRows = 0
|
||||||
|
@ -81,8 +81,8 @@ while $i < $tblNum
|
||||||
$x = 0
|
$x = 0
|
||||||
while $x < $rowNum
|
while $x < $rowNum
|
||||||
$ts = $tsStart + $x
|
$ts = $tsStart + $x
|
||||||
sql insert into $tb values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x ) ( $ts + 10a , $x ) ( $ts + 11a , $x ) ( $ts + 12a , $x ) ( $ts + 13a , $x ) ( $ts + 14a , $x ) ( $ts + 15a , $x ) ( $ts + 16a , $x ) ( $ts + 17a , $x ) ( $ts + 18a , $x ) ( $ts + 19a , $x ) ( $ts + 20a , $x ) ( $ts + 21a , $x ) ( $ts + 22a , $x ) ( $ts + 23a , $x ) ( $ts + 24a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 35a , $x ) ( $ts + 36a , $x ) ( $ts + 37a , $x ) ( $ts + 38a , $x ) ( $ts + 39a , $x ) ( $ts + 40a , $x ) ( $ts + 41a , $x ) ( $ts + 42a , $x ) ( $ts + 43a , $x ) ( $ts + 44a , $x ) ( $ts + 45a , $x ) ( $ts + 46a , $x ) ( $ts + 47a , $x ) ( $ts + 48a , $x ) ( $ts + 49a , $x ) ( $ts + 50a , $x ) ( $ts + 51a , $x ) ( $ts + 52a , $x ) ( $ts + 53a , $x ) ( $ts + 54a , $x ) ( $ts + 55a , $x ) ( $ts + 56a , $x ) ( $ts + 57a , $x ) ( $ts + 58a , $x ) ( $ts + 59a , $x )
|
sql insert into $tb values ( $ts + 0a , $x , $x ) ( $ts + 1a , $x , $x ) ( $ts + 2a , $x , $x ) ( $ts + 3a , $x , $x ) ( $ts + 4a , $x , $x ) ( $ts + 5a , $x , $x ) ( $ts + 6a , $x , $x ) ( $ts + 7a , $x , $x ) ( $ts + 8a , $x , $x ) ( $ts + 9a , $x , $x ) ( $ts + 10a , $x , $x ) ( $ts + 11a , $x , $x ) ( $ts + 12a , $x , $x ) ( $ts + 13a , $x , $x ) ( $ts + 14a , $x , $x ) ( $ts + 15a , $x , $x ) ( $ts + 16a , $x , $x ) ( $ts + 17a , $x , $x ) ( $ts + 18a , $x , $x ) ( $ts + 19a , $x , $x )
|
||||||
$x = $x + 60
|
$x = $x + 20
|
||||||
endw
|
endw
|
||||||
$totalRows = $totalRows + $x
|
$totalRows = $totalRows + $x
|
||||||
print info: inserted $x rows into $tb and totalRows: $totalRows
|
print info: inserted $x rows into $tb and totalRows: $totalRows
|
||||||
|
@ -113,8 +113,8 @@ print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
$dnode2Status = $data4_2
|
$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != offline then
|
if $dnode4Status != offline then
|
||||||
|
@ -151,7 +151,7 @@ sql alter table $stb add column f1 double
|
||||||
$i = 0
|
$i = 0
|
||||||
while $i < $tblNum
|
while $i < $tblNum
|
||||||
$tb = tb . $i
|
$tb = tb . $i
|
||||||
sql inset into $tb values (now, 10001) (now + 1s, 10002) (now + 2s, 10003) (now + 3s, 10004)
|
sql insert into $tb values (now, 10001, 1.0001) (now + 1s, 10002, 1.0002) (now + 2s, 10003, 1.0003) (now + 3s, 10004, 1.0004)
|
||||||
$i = $i + 1
|
$i = $i + 1
|
||||||
endw
|
endw
|
||||||
$addRows = 4 * $tblNum
|
$addRows = 4 * $tblNum
|
||||||
|
@ -174,8 +174,8 @@ print $data0_4 $data1_4 $data2_4 $data3_4 $data4_4
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
#$dnode2Status = $data4_2
|
#$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != ready then
|
if $dnode4Status != ready then
|
||||||
|
|
|
@ -47,7 +47,7 @@ system sh/exec.sh -n dnode1 -s start
|
||||||
sleep 3000
|
sleep 3000
|
||||||
sql connect
|
sql connect
|
||||||
|
|
||||||
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 3, and create table, insert data
|
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 2, and create table, insert data
|
||||||
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
|
||||||
|
@ -59,9 +59,11 @@ sleep 3000
|
||||||
$totalTableNum = 100
|
$totalTableNum = 100
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
|
$maxTables = $totalTableNum * 2
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
print create database $db replica 3 maxTables $totalTableNum
|
print create database $db replica 2 maxTables $maxTables
|
||||||
sql create database $db replica 3 maxTables $totalTableNum
|
sql create database $db replica 2 maxTables $maxTables
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
|
@ -113,8 +115,8 @@ print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
$dnode2Status = $data4_2
|
$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != offline then
|
if $dnode4Status != offline then
|
||||||
|
@ -186,8 +188,8 @@ print $data0_4 $data1_4 $data2_4 $data3_4 $data4_4
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
#$dnode2Status = $data4_2
|
#$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != ready then
|
if $dnode4Status != ready then
|
||||||
|
|
|
@ -113,8 +113,8 @@ print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
$dnode2Status = $data4_2
|
$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != offline then
|
if $dnode4Status != offline then
|
||||||
|
|
|
@ -47,7 +47,7 @@ system sh/exec.sh -n dnode1 -s start
|
||||||
sleep 3000
|
sleep 3000
|
||||||
sql connect
|
sql connect
|
||||||
|
|
||||||
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 3, and create table, insert data
|
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 2, and create table, insert data
|
||||||
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
|
||||||
|
@ -60,8 +60,8 @@ $totalTableNum = 100
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
print create database $db replica 3 maxTables $totalTableNum
|
print create database $db replica 2 maxTables $totalTableNum
|
||||||
sql create database $db replica 3 maxTables $totalTableNum
|
sql create database $db replica 2 maxTables $totalTableNum
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
|
@ -113,8 +113,8 @@ print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
$dnode2Status = $data4_2
|
$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != offline then
|
if $dnode4Status != offline then
|
||||||
|
@ -172,8 +172,8 @@ print $data0_4 $data1_4 $data2_4 $data3_4 $data4_4
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
#$dnode2Status = $data4_2
|
#$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != ready then
|
if $dnode4Status != ready then
|
||||||
|
|
|
@ -66,7 +66,7 @@ sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
$stb = stb
|
$stb = stb
|
||||||
sql create table $stb (ts timestamp, c1 int) tags(t1 int)
|
sql create table $stb (ts timestamp, c1 int, c2 int) tags(t1 int)
|
||||||
$rowNum = 500
|
$rowNum = 500
|
||||||
$tblNum = $totalTableNum
|
$tblNum = $totalTableNum
|
||||||
$totalRows = 0
|
$totalRows = 0
|
||||||
|
@ -81,8 +81,8 @@ while $i < $tblNum
|
||||||
$x = 0
|
$x = 0
|
||||||
while $x < $rowNum
|
while $x < $rowNum
|
||||||
$ts = $tsStart + $x
|
$ts = $tsStart + $x
|
||||||
sql insert into $tb values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x ) ( $ts + 10a , $x ) ( $ts + 11a , $x ) ( $ts + 12a , $x ) ( $ts + 13a , $x ) ( $ts + 14a , $x ) ( $ts + 15a , $x ) ( $ts + 16a , $x ) ( $ts + 17a , $x ) ( $ts + 18a , $x ) ( $ts + 19a , $x ) ( $ts + 20a , $x ) ( $ts + 21a , $x ) ( $ts + 22a , $x ) ( $ts + 23a , $x ) ( $ts + 24a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 35a , $x ) ( $ts + 36a , $x ) ( $ts + 37a , $x ) ( $ts + 38a , $x ) ( $ts + 39a , $x ) ( $ts + 40a , $x ) ( $ts + 41a , $x ) ( $ts + 42a , $x ) ( $ts + 43a , $x ) ( $ts + 44a , $x ) ( $ts + 45a , $x ) ( $ts + 46a , $x ) ( $ts + 47a , $x ) ( $ts + 48a , $x ) ( $ts + 49a , $x ) ( $ts + 50a , $x ) ( $ts + 51a , $x ) ( $ts + 52a , $x ) ( $ts + 53a , $x ) ( $ts + 54a , $x ) ( $ts + 55a , $x ) ( $ts + 56a , $x ) ( $ts + 57a , $x ) ( $ts + 58a , $x ) ( $ts + 59a , $x )
|
sql insert into $tb values ( $ts + 0a , $x , $x ) ( $ts + 1a , $x , $x ) ( $ts + 2a , $x , $x ) ( $ts + 3a , $x , $x ) ( $ts + 4a , $x , $x ) ( $ts + 5a , $x , $x ) ( $ts + 6a , $x , $x ) ( $ts + 7a , $x , $x ) ( $ts + 8a , $x , $x ) ( $ts + 9a , $x , $x ) ( $ts + 10a , $x , $x ) ( $ts + 11a , $x , $x ) ( $ts + 12a , $x , $x ) ( $ts + 13a , $x , $x ) ( $ts + 14a , $x , $x ) ( $ts + 15a , $x , $x ) ( $ts + 16a , $x , $x ) ( $ts + 17a , $x , $x ) ( $ts + 18a , $x , $x ) ( $ts + 19a , $x , $x )
|
||||||
$x = $x + 60
|
$x = $x + 20
|
||||||
endw
|
endw
|
||||||
$totalRows = $totalRows + $x
|
$totalRows = $totalRows + $x
|
||||||
print info: inserted $x rows into $tb and totalRows: $totalRows
|
print info: inserted $x rows into $tb and totalRows: $totalRows
|
||||||
|
@ -151,7 +151,7 @@ sql alter table $stb add column f1 double
|
||||||
$i = 0
|
$i = 0
|
||||||
while $i < $tblNum
|
while $i < $tblNum
|
||||||
$tb = tb . $i
|
$tb = tb . $i
|
||||||
sql inset into $tb values (now, 10001) (now + 1s, 10002) (now + 2s, 10003) (now + 3s, 10004)
|
sql insert into $tb values (now, 10001, 1.0001) (now + 1s, 10002, 1.0002) (now + 2s, 10003, 1.0003) (now + 3s, 10004, 1.0004)
|
||||||
$i = $i + 1
|
$i = $i + 1
|
||||||
endw
|
endw
|
||||||
$addRows = 4 * $tblNum
|
$addRows = 4 * $tblNum
|
||||||
|
|
|
@ -58,10 +58,11 @@ sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 100
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
$maxTables = $totalTableNum * 2
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
print create database $db replica 3 maxTables $totalTableNum
|
print create database $db replica 3 maxTables $maxTables
|
||||||
sql create database $db replica 3 maxTables $totalTableNum
|
sql create database $db replica 3 maxTables $maxTables
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
|
|
|
@ -47,7 +47,7 @@ system sh/exec.sh -n dnode1 -s start
|
||||||
sleep 3000
|
sleep 3000
|
||||||
sql connect
|
sql connect
|
||||||
|
|
||||||
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 3, and create table, insert data
|
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 2, and create table, insert data
|
||||||
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
|
||||||
|
@ -56,12 +56,12 @@ sql create dnode $hostname2
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
print create database $db replica 3 maxTables $totalTableNum
|
print create database $db replica 2 maxTables $totalTableNum
|
||||||
sql create database $db replica 3 maxTables $totalTableNum
|
sql create database $db replica 2 maxTables $totalTableNum
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
|
@ -113,8 +113,8 @@ print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
$dnode2Status = $data4_2
|
$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != offline then
|
if $dnode4Status != offline then
|
||||||
|
@ -162,7 +162,7 @@ while $i < $tblNum
|
||||||
endw
|
endw
|
||||||
|
|
||||||
sql select count(*) from $stb
|
sql select count(*) from $stb
|
||||||
print data00 $data00
|
print data00:$data00 totalRows:$totalRows
|
||||||
if $data00 != $totalRows then
|
if $data00 != $totalRows then
|
||||||
return -1
|
return -1
|
||||||
endi
|
endi
|
||||||
|
@ -172,8 +172,8 @@ system sh/exec.sh -n dnode4 -s start
|
||||||
run_back unique/arbitrator/sync_replica_alterTable_background_add.sim
|
run_back unique/arbitrator/sync_replica_alterTable_background_add.sim
|
||||||
|
|
||||||
print ============== step6: check result
|
print ============== step6: check result
|
||||||
#in background.sim, add one column and insert 200 rows
|
#in background.sim, add one column and insert 36 rows
|
||||||
$totalRows = $totalRows + 200
|
$totalRows = $totalRows + 36
|
||||||
|
|
||||||
$cnt = 0
|
$cnt = 0
|
||||||
wait_table_altered:
|
wait_table_altered:
|
||||||
|
@ -183,7 +183,7 @@ if $cnt == 20 then
|
||||||
endi
|
endi
|
||||||
sql select count(*) from $stb
|
sql select count(*) from $stb
|
||||||
if $data00 != $totalRows then
|
if $data00 != $totalRows then
|
||||||
print data00: $data00
|
print data00:$data00 totalRows:$totalRows
|
||||||
sleep 2000
|
sleep 2000
|
||||||
goto wait_table_altered
|
goto wait_table_altered
|
||||||
endi
|
endi
|
||||||
|
|
|
@ -47,7 +47,7 @@ system sh/exec.sh -n dnode1 -s start
|
||||||
sleep 3000
|
sleep 3000
|
||||||
sql connect
|
sql connect
|
||||||
|
|
||||||
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 3, and create table, insert data
|
print ============== step2: start dnode2/dnode3/dnode4 and add into cluster , then create database with replica 2, and create table, insert data
|
||||||
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
|
||||||
|
@ -56,12 +56,12 @@ sql create dnode $hostname2
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
print create database $db replica 3 maxTables $totalTableNum
|
print create database $db replica 2 maxTables $totalTableNum
|
||||||
sql create database $db replica 3 maxTables $totalTableNum
|
sql create database $db replica 2 maxTables $totalTableNum
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
# create table , insert data
|
# create table , insert data
|
||||||
|
@ -113,8 +113,8 @@ print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
$dnode2Status = $data4_2
|
$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != offline then
|
if $dnode4Status != offline then
|
||||||
|
@ -173,7 +173,7 @@ run_back unique/arbitrator/sync_replica_alterTable_background_drop.sim
|
||||||
|
|
||||||
print ============== step6: check result
|
print ============== step6: check result
|
||||||
#in background.sim, drop one column and add one new column, then insert 200 rows
|
#in background.sim, drop one column and add one new column, then insert 200 rows
|
||||||
$totalRows = $totalRows + 200
|
$totalRows = $totalRows + 36
|
||||||
|
|
||||||
$cnt = 0
|
$cnt = 0
|
||||||
wait_table_altered:
|
wait_table_altered:
|
||||||
|
|
|
@ -56,7 +56,7 @@ sql create dnode $hostname2
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
|
@ -113,8 +113,8 @@ print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||||
#$dnode1Status = $data4_1
|
#$dnode1Status = $data4_1
|
||||||
$dnode2Status = $data4_2
|
$dnode2Status = $data4_2
|
||||||
$dnode3Status = $data4_3
|
#$dnode3Status = $data4_3
|
||||||
$dnode4Status = $data4_4
|
$dnode4Status = $data4_3
|
||||||
#$dnode5Status = $data4_5
|
#$dnode5Status = $data4_5
|
||||||
|
|
||||||
if $dnode4Status != offline then
|
if $dnode4Status != offline then
|
||||||
|
|
|
@ -56,7 +56,7 @@ sql create dnode $hostname2
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
|
@ -162,18 +162,18 @@ while $i < $tblNum
|
||||||
endw
|
endw
|
||||||
|
|
||||||
sql select count(*) from $stb
|
sql select count(*) from $stb
|
||||||
print data00 $data00
|
print data00:$data00 totalRows:$totalRows
|
||||||
if $data00 != $totalRows then
|
if $data00 != $totalRows then
|
||||||
return -1
|
return -1
|
||||||
endi
|
endi
|
||||||
|
|
||||||
print ============== step5: restart dnode4, while drop database in other thead when dnode4 is syncing
|
print ============== step5: restart dnode4, while drop some tables in other thread when dnode4 is syncing
|
||||||
system sh/exec.sh -n dnode4 -s start
|
system sh/exec.sh -n dnode4 -s start
|
||||||
run_back unique/arbitrator/sync_replica_dropTable_background.sim
|
run_back unique/arbitrator/sync_replica_dropTable_background.sim
|
||||||
|
|
||||||
print ============== step6: check result
|
print ============== step6: check result
|
||||||
#in background.sim, drop 10 tables
|
#in background.sim, drop 5 tables
|
||||||
$totalRows = $totalRows - 10800
|
$totalRows = $totalRows - 5400
|
||||||
|
|
||||||
$cnt = 0
|
$cnt = 0
|
||||||
wait_table_dropped:
|
wait_table_dropped:
|
||||||
|
@ -183,15 +183,15 @@ if $cnt == 20 then
|
||||||
endi
|
endi
|
||||||
sql select count(*) from $stb
|
sql select count(*) from $stb
|
||||||
if $data00 != $totalRows then
|
if $data00 != $totalRows then
|
||||||
print data00: $data00
|
print data00:$data00 totalRows:$totalRows
|
||||||
sleep 2000
|
sleep 2000
|
||||||
goto wait_table_dropped
|
goto wait_table_dropped
|
||||||
endi
|
endi
|
||||||
|
|
||||||
$tblNum = $tblNum - 10
|
$tblNum = $tblNum - 5
|
||||||
sql select count(tbname) from $stb
|
sql select count(tbname) from $stb
|
||||||
if $data00 != $tblNum then
|
if $data00 != $tblNum then
|
||||||
print data00: $data00
|
print data00: $data00 tblNum: $tblNum
|
||||||
sleep 2000
|
sleep 2000
|
||||||
goto wait_table_dropped
|
goto wait_table_dropped
|
||||||
endi
|
endi
|
||||||
|
|
|
@ -56,7 +56,7 @@ sql create dnode $hostname3
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
|
@ -173,7 +173,7 @@ run_back unique/arbitrator/sync_replica_alterTable_background_add.sim
|
||||||
|
|
||||||
print ============== step6: check result
|
print ============== step6: check result
|
||||||
#in background.sim, add one column and insert 200 rows
|
#in background.sim, add one column and insert 200 rows
|
||||||
$totalRows = $totalRows + 200
|
$totalRows = $totalRows + 36
|
||||||
|
|
||||||
$cnt = 0
|
$cnt = 0
|
||||||
wait_table_altered:
|
wait_table_altered:
|
||||||
|
|
|
@ -56,7 +56,7 @@ sql create dnode $hostname3
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
|
@ -172,8 +172,8 @@ system sh/exec.sh -n dnode4 -s start
|
||||||
run_back unique/arbitrator/sync_replica_alterTable_background_drop.sim
|
run_back unique/arbitrator/sync_replica_alterTable_background_drop.sim
|
||||||
|
|
||||||
print ============== step6: check result
|
print ============== step6: check result
|
||||||
#in background.sim, drop one column and add one new column, then insert 200 rows
|
#in background.sim, drop one column and add one new column, then insert 36 rows
|
||||||
$totalRows = $totalRows + 200
|
$totalRows = $totalRows + 36
|
||||||
|
|
||||||
$cnt = 0
|
$cnt = 0
|
||||||
wait_table_altered:
|
wait_table_altered:
|
||||||
|
|
|
@ -56,7 +56,7 @@ sql create dnode $hostname3
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
|
|
|
@ -56,7 +56,7 @@ sql create dnode $hostname3
|
||||||
sql create dnode $hostname4
|
sql create dnode $hostname4
|
||||||
sleep 3000
|
sleep 3000
|
||||||
|
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
$sleepTimer = 3000
|
$sleepTimer = 3000
|
||||||
|
|
||||||
$db = db
|
$db = db
|
||||||
|
@ -143,7 +143,7 @@ if $dnode3Vtatus != master then
|
||||||
sleep 2000
|
sleep 2000
|
||||||
goto wait_dnode4_vgroup_offline
|
goto wait_dnode4_vgroup_offline
|
||||||
endi
|
endi
|
||||||
|
sleep 2000
|
||||||
print ============== step4: insert more data rows
|
print ============== step4: insert more data rows
|
||||||
$tsStart = $tsEnd + 1000
|
$tsStart = $tsEnd + 1000
|
||||||
$i = 0
|
$i = 0
|
||||||
|
@ -173,7 +173,7 @@ run_back unique/arbitrator/sync_replica_dropTable_background.sim
|
||||||
|
|
||||||
print ============== step6: check result
|
print ============== step6: check result
|
||||||
#in background.sim, drop 10 tables
|
#in background.sim, drop 10 tables
|
||||||
$totalRows = $totalRows - 10800
|
$totalRows = $totalRows - 5400
|
||||||
|
|
||||||
$cnt = 0
|
$cnt = 0
|
||||||
wait_table_dropped:
|
wait_table_dropped:
|
||||||
|
@ -188,7 +188,7 @@ if $data00 != $totalRows then
|
||||||
goto wait_table_dropped
|
goto wait_table_dropped
|
||||||
endi
|
endi
|
||||||
|
|
||||||
$tblNum = $tblNum - 10
|
$tblNum = $tblNum - 5
|
||||||
sql select count(tbname) from $stb
|
sql select count(tbname) from $stb
|
||||||
if $data00 != $tblNum then
|
if $data00 != $tblNum then
|
||||||
print data00: $data00
|
print data00: $data00
|
||||||
|
|
|
@ -3,7 +3,7 @@ sql connect
|
||||||
$db = db
|
$db = db
|
||||||
$stb = stb
|
$stb = stb
|
||||||
print =============== sync_replica_alterTable_background_add.sim step0: alter table and insert data
|
print =============== sync_replica_alterTable_background_add.sim step0: alter table and insert data
|
||||||
$totalTableNum = 100
|
$totalTableNum = 10
|
||||||
|
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
|
@ -12,7 +12,7 @@ print alter table $stb add column f1 float
|
||||||
sql alter table $stb add column f1 float
|
sql alter table $stb add column f1 float
|
||||||
|
|
||||||
$tblNum = $totalTableNum
|
$tblNum = $totalTableNum
|
||||||
$alterTblNum = 51
|
$alterTblNum = 10
|
||||||
|
|
||||||
$i = 1
|
$i = 1
|
||||||
while $i < $alterTblNum
|
while $i < $alterTblNum
|
||||||
|
|
|
@ -8,11 +8,11 @@ $totalTableNum = 100
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
#sql create table $stb (ts timestamp, c1 int) tags(t1 int)
|
#sql create table $stb (ts timestamp, c1 int) tags(t1 int)
|
||||||
sql alter table $stb drop column c1
|
|
||||||
sql alter table $stb add column f1 double
|
sql alter table $stb add column f1 double
|
||||||
|
sql alter table $stb drop column c1
|
||||||
|
|
||||||
$tblNum = $totalTableNum
|
$tblNum = $totalTableNum
|
||||||
$alterTblNum = 51
|
$alterTblNum = 10
|
||||||
|
|
||||||
$i = 1
|
$i = 1
|
||||||
while $i < $alterTblNum
|
while $i < $alterTblNum
|
||||||
|
|
|
@ -3,12 +3,12 @@ sql connect
|
||||||
$db = db
|
$db = db
|
||||||
$stb = stb
|
$stb = stb
|
||||||
print =============== sync_replica_dropTable_background.sim step0: drop table
|
print =============== sync_replica_dropTable_background.sim step0: drop table
|
||||||
$totalTableNum = 100
|
$totalTableNum = 6
|
||||||
|
|
||||||
sql use $db
|
sql use $db
|
||||||
|
|
||||||
$tblNum = $totalTableNum
|
$tblNum = $totalTableNum
|
||||||
$dropTblNum = 11
|
$dropTblNum = 6
|
||||||
|
|
||||||
$i = 1
|
$i = 1
|
||||||
while $i < $dropTblNum
|
while $i < $dropTblNum
|
||||||
|
|
Loading…
Reference in New Issue