152 lines
3.8 KiB
Plaintext
152 lines
3.8 KiB
Plaintext
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 numOfMPeers -v 1
|
|
system sh/cfg.sh -n dnode2 -c numOfMPeers -v 1
|
|
system sh/cfg.sh -n dnode3 -c numOfMPeers -v 1
|
|
system sh/cfg.sh -n dnode4 -c numOfMPeers -v 1
|
|
|
|
system sh/cfg.sh -n dnode1 -c mgmtEqualVnodeNum -v 10
|
|
system sh/cfg.sh -n dnode2 -c mgmtEqualVnodeNum -v 10
|
|
system sh/cfg.sh -n dnode3 -c mgmtEqualVnodeNum -v 10
|
|
system sh/cfg.sh -n dnode4 -c mgmtEqualVnodeNum -v 10
|
|
|
|
system sh/cfg.sh -n dnode1 -c maxtablesPerVnode -v 2000
|
|
system sh/cfg.sh -n dnode2 -c maxtablesPerVnode -v 2000
|
|
system sh/cfg.sh -n dnode3 -c maxtablesPerVnode -v 2000
|
|
system sh/cfg.sh -n dnode4 -c maxtablesPerVnode -v 2000
|
|
|
|
system sh/cfg.sh -n dnode1 -c commitlog -v 0
|
|
system sh/cfg.sh -n dnode2 -c commitlog -v 0
|
|
system sh/cfg.sh -n dnode3 -c commitlog -v 0
|
|
system sh/cfg.sh -n dnode4 -c commitlog -v 0
|
|
|
|
print ========= start dnode1
|
|
system sh/exec.sh -n dnode1 -s start
|
|
sleep 3000
|
|
sql connect
|
|
|
|
sql create database ibadb
|
|
sql use ibadb
|
|
sql create table tb(ts timestamp, i int)
|
|
|
|
print ================= step1
|
|
|
|
sql import into tb values(1564641710000, 10000)
|
|
sql select * from tb;
|
|
if $rows != 1 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step2
|
|
sql insert into tb values(1564641708000, 8000)
|
|
sql select * from tb;
|
|
if $rows != 1 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step3
|
|
sql insert into tb values(1564641720000, 20000)
|
|
sql select * from tb;
|
|
if $rows != 2 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step4
|
|
sql import into tb values(1564641708000, 8000)
|
|
sql import into tb values(1564641715000, 15000)
|
|
sql import into tb values(1564641730000, 30000)
|
|
sql select * from tb;
|
|
if $rows != 5 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step5
|
|
sql insert into tb values(1564641708000, 8000)
|
|
sql insert into tb values(1564641714000, 14000)
|
|
sql insert into tb values(1564641725000, 25000)
|
|
sql insert into tb values(1564641740000, 40000)
|
|
sql select * from tb;
|
|
if $rows != 6 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step6
|
|
sql import into tb values(1564641707000, 7000)
|
|
sql import into tb values(1564641712000, 12000)
|
|
sql import into tb values(1564641723000, 23000)
|
|
sql import into tb values(1564641734000, 34000)
|
|
sql import into tb values(1564641750000, 50000)
|
|
sql select * from tb;
|
|
if $rows != 11 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step7
|
|
sql import into tb values(1564641707001, 7001)
|
|
sql import into tb values(1564641712001, 12001)
|
|
sql import into tb values(1564641723001, 23001)
|
|
sql import into tb values(1564641734001, 34001)
|
|
sql import into tb values(1564641750001, 50001)
|
|
sql select * from tb;
|
|
if $rows != 16 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step8
|
|
sql insert into tb values(1564641708002, 8002)
|
|
sql insert into tb values(1564641714002, 14002)
|
|
sql insert into tb values(1564641725002, 25002)
|
|
sql insert into tb values(1564641900000, 200000)
|
|
sql select * from tb;
|
|
if $rows != 17 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step9 only insert last one
|
|
sql import into tb values(1564641705000, 5000)(1564641718000, 18000)(1564642400000, 700000)
|
|
sql select * from tb;
|
|
if $rows != 20 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step10
|
|
sql import into tb values(1564641705000, 5000)(1564641718000, 18000)(1564642400000, 70000)
|
|
sql select * from tb;
|
|
if $rows != 20 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step11
|
|
sql import into tb values(1564642400000, 700000)
|
|
sql select * from tb;
|
|
if $rows != 20 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step12
|
|
sql import into tb values(1564641709527, 9527)(1564641709527, 9528)
|
|
sql select * from tb;
|
|
print rows=> $rows
|
|
if $rows != 21 then
|
|
return -1
|
|
endi
|
|
|
|
print ================= step13
|
|
sql import into tb values(1564641709898, 9898)(1564641709897, 9897)
|
|
sql select * from tb;
|
|
print rows=> $rows
|
|
if $rows != 23 then
|
|
return -1
|
|
endi
|
|
|