vnode-insert.sim 4.1 KB
Newer Older
M
Minghao Li 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67
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 supportVnodes -v 0

system sh/exec.sh -n dnode1 -s start
system sh/exec.sh -n dnode2 -s start
system sh/exec.sh -n dnode3 -s start
system sh/exec.sh -n dnode4 -s start

sql connect
sql create dnode $hostname port 7200
sql create dnode $hostname port 7300
sql create dnode $hostname port 7400

$x = 0
step1:
	$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 step1
endi
if $data(2)[4] != ready then
  goto step1
endi
if $data(3)[4] != ready then
  goto step1
endi
if $data(4)[4] != ready then
  goto step1
endi

$replica = 3
$vgroups = 1

print ============= create database
sql create database db replica $replica vgroups $vgroups

$loop_cnt = 0
check_db_ready:
$loop_cnt = $loop_cnt + 1
sleep 200
if $loop_cnt == 100 then
  print ====> db not ready!
	return -1
endi
sql show databases
print ===> rows: $rows
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4] $data[2][5] $data[2][6] $data[2][7] $data[2][8] $data[2][9] $data[2][6] $data[2][11] $data[2][12]  $data[2][13]  $data[2][14]  $data[2][15]  $data[2][16]  $data[2][17]  $data[2][18]  $data[2][19]
if $rows != 3 then
  return -1
endi
68
if $data[2][15] != ready then
M
Minghao Li 已提交
69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181
  goto check_db_ready
endi

sql use db

$loop_cnt = 0
check_vg_ready:
$loop_cnt = $loop_cnt + 1
sleep 200
if $loop_cnt == 300 then
  print ====> vgroups not ready!
	return -1
endi

sql show vgroups
print ===> rows: $rows
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4] $data[0][5] $data[0][6] $data[0][7] $data[0][8] $data[0][9] $data[0][10] $data[0][11]

if $rows != $vgroups then
  return -1
endi

if $data[0][4] == leader then
   if $data[0][6] == follower then
      if $data[0][8] == follower then
         print ---- vgroup $data[0][0] leader locate on dnode $data[0][3] 
      endi
   endi
elif $data[0][6] == leader then
   if $data[0][4] == follower then
      if $data[0][8] == follower then
         print ---- vgroup $data[0][0] leader locate on dnode $data[0][5] 
      endi
   endi
elif $data[0][8] == leader then
   if $data[0][4] == follower then
      if $data[0][6] == follower then
         print ---- vgroup $data[0][0] leader locate on dnode $data[0][7] 
      endi
   endi
else
   goto check_vg_ready
endi


vg_ready:
print ====>  create stable/child table
sql create table stb (ts timestamp, c1 int, c2 float, c3 double) tags (t1 int)

sql show stables
if $rows != 1 then 
  return -1
endi

sql create table ct1 using stb tags(1000)


print ====> step1 insert 1000 records
$N = 1000
$count = 0
while $count < $N
	$ms = 1591200000000 + $count
    sql insert into ct1 values( $ms , $count , 2.1, 3.1)
    $count = $count + 1
endw

print ====> step2 sleep 20s, checking data
sleep 20000


print ====> step3 sleep 30s, kill leader
sleep 30000

print ====> step4 insert 1000 records
$N = 1000
$count = 0
while $count < $N
	$ms = 1591201000000 + $count
    sql insert into ct1 values( $ms , $count , 2.1, 3.1)
    $count = $count + 1
endw

print ====> step5 sleep 20s, checking data
sleep 20000

print ====> step6 stop all
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

print ====> step7 start all
system sh/exec.sh -n dnode1 -s start
system sh/exec.sh -n dnode2 -s start
system sh/exec.sh -n dnode3 -s start
system sh/exec.sh -n dnode4 -s start

print ====> step8 sleep 20s, checking data
sleep 20000

print ====> step9 insert 1000 records
$N = 1000
$count = 0
while $count < $N
	$ms = 1591202000000 + $count
    sql insert into ct1 values( $ms , $count , 2.1, 3.1)
    $count = $count + 1
endw

print ====> step10 sleep 20s, checking data
sleep 20000