Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
d9d892bf
T
TDengine
项目概览
taosdata
/
TDengine
大约 2 年 前同步成功
通知
1193
Star
22018
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
d9d892bf
编写于
8月 11, 2022
作者:
X
Xiaoyu Wang
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
enh: show command optimize
上级
44df51f9
变更
58
隐藏空白更改
内联
并排
Showing
58 changed file
with
178 addition
and
178 deletion
+178
-178
tests/pytest/client/client.py
tests/pytest/client/client.py
+1
-1
tests/script/tsim/backup/arbitrator/dn3_mn2_killDnode.sim
tests/script/tsim/backup/arbitrator/dn3_mn2_killDnode.sim
+1
-1
tests/script/tsim/backup/arbitrator/replica_changeWithArbitrator.sim
...t/tsim/backup/arbitrator/replica_changeWithArbitrator.sim
+1
-1
tests/script/tsim/backup/cluster/cluster_main.sim
tests/script/tsim/backup/cluster/cluster_main.sim
+14
-14
tests/script/tsim/backup/cluster/cluster_main0.sim
tests/script/tsim/backup/cluster/cluster_main0.sim
+12
-12
tests/script/tsim/backup/cluster/cluster_main1.sim
tests/script/tsim/backup/cluster/cluster_main1.sim
+12
-12
tests/script/tsim/backup/cluster/cluster_main2.sim
tests/script/tsim/backup/cluster/cluster_main2.sim
+12
-12
tests/script/tsim/backup/clusterSimCase/cluster_main.sim
tests/script/tsim/backup/clusterSimCase/cluster_main.sim
+1
-1
tests/script/tsim/bnode/basic1.sim
tests/script/tsim/bnode/basic1.sim
+2
-2
tests/script/tsim/dnode/create_dnode.sim
tests/script/tsim/dnode/create_dnode.sim
+2
-2
tests/script/tsim/dnode/drop_dnode_has_mnode.sim
tests/script/tsim/dnode/drop_dnode_has_mnode.sim
+3
-3
tests/script/tsim/dnode/use_dropped_dnode.sim
tests/script/tsim/dnode/use_dropped_dnode.sim
+1
-1
tests/script/tsim/mnode/basic1.sim
tests/script/tsim/mnode/basic1.sim
+6
-6
tests/script/tsim/mnode/basic2.sim
tests/script/tsim/mnode/basic2.sim
+3
-3
tests/script/tsim/mnode/basic3.sim
tests/script/tsim/mnode/basic3.sim
+4
-4
tests/script/tsim/mnode/basic4.sim
tests/script/tsim/mnode/basic4.sim
+5
-5
tests/script/tsim/mnode/basic5.sim
tests/script/tsim/mnode/basic5.sim
+5
-5
tests/script/tsim/qnode/basic1.sim
tests/script/tsim/qnode/basic1.sim
+1
-1
tests/script/tsim/show/basic.sim
tests/script/tsim/show/basic.sim
+2
-2
tests/script/tsim/snode/basic1.sim
tests/script/tsim/snode/basic1.sim
+1
-1
tests/script/tsim/sync/3Replica5VgElect3mnode.sim
tests/script/tsim/sync/3Replica5VgElect3mnode.sim
+3
-3
tests/script/tsim/sync/3Replica5VgElect3mnodedrop.sim
tests/script/tsim/sync/3Replica5VgElect3mnodedrop.sim
+3
-3
tests/script/tsim/sync/mnodeLeaderTransfer.sim
tests/script/tsim/sync/mnodeLeaderTransfer.sim
+1
-1
tests/script/tsim/user/password.sim
tests/script/tsim/user/password.sim
+4
-4
tests/script/tsim/user/privilege_sysinfo.sim
tests/script/tsim/user/privilege_sysinfo.sim
+1
-1
tests/script/tsim/valgrind/checkError1.sim
tests/script/tsim/valgrind/checkError1.sim
+1
-1
tests/script/tsim/vnode/replica3_basic.sim
tests/script/tsim/vnode/replica3_basic.sim
+1
-1
tests/system-test/0-others/user_control.py
tests/system-test/0-others/user_control.py
+1
-1
tests/system-test/6-cluster/5dnode1mnode.py
tests/system-test/6-cluster/5dnode1mnode.py
+1
-1
tests/system-test/6-cluster/5dnode2mnode.py
tests/system-test/6-cluster/5dnode2mnode.py
+2
-2
tests/system-test/6-cluster/5dnode3mnodeDrop.py
tests/system-test/6-cluster/5dnode3mnodeDrop.py
+12
-12
tests/system-test/6-cluster/5dnode3mnodeDropInsert.py
tests/system-test/6-cluster/5dnode3mnodeDropInsert.py
+12
-12
tests/system-test/6-cluster/5dnode3mnodeSeperate1VnodeStopInsert.py
...em-test/6-cluster/5dnode3mnodeSeperate1VnodeStopInsert.py
+9
-9
tests/system-test/6-cluster/5dnode3mnodeStopInsert.py
tests/system-test/6-cluster/5dnode3mnodeStopInsert.py
+9
-9
tests/system-test/6-cluster/clusterCommonCheck.py
tests/system-test/6-cluster/clusterCommonCheck.py
+3
-3
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_createDb_replica1.py
...t/6-cluster/vnode/4dnode1mnode_basic_createDb_replica1.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica1_insertdatas.py
...-cluster/vnode/4dnode1mnode_basic_replica1_insertdatas.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica1_insertdatas_querys.py
...r/vnode/4dnode1mnode_basic_replica1_insertdatas_querys.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas.py
...-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_force_stop_all_dnodes.py
...mnode_basic_replica3_insertdatas_force_stop_all_dnodes.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys.py
...r/vnode/4dnode1mnode_basic_replica3_insertdatas_querys.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_all_vnode.py
...sic_replica3_insertdatas_querys_loop_restart_all_vnode.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_follower.py
...asic_replica3_insertdatas_querys_loop_restart_follower.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_leader.py
..._basic_replica3_insertdatas_querys_loop_restart_leader.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_all_dnodes.py
...dnode1mnode_basic_replica3_insertdatas_stop_all_dnodes.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_sync.py
...de1mnode_basic_replica3_insertdatas_stop_follower_sync.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_unsync.py
...1mnode_basic_replica3_insertdatas_stop_follower_unsync.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_unsync_force_stop.py
...c_replica3_insertdatas_stop_follower_unsync_force_stop.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_leader.py
...de/4dnode1mnode_basic_replica3_insertdatas_stop_leader.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_leader_forece_stop.py
...ode_basic_replica3_insertdatas_stop_leader_forece_stop.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_mnode3_insertdatas_querys.py
.../4dnode1mnode_basic_replica3_mnode3_insertdatas_querys.py
+2
-2
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_follower.py
...e/4dnode1mnode_basic_replica3_querydatas_stop_follower.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_follower_force_stop.py
...ode_basic_replica3_querydatas_stop_follower_force_stop.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_leader.py
...ode/4dnode1mnode_basic_replica3_querydatas_stop_leader.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_leader_force_stop.py
...mnode_basic_replica3_querydatas_stop_leader_force_stop.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups.py
...st/6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups.py
+1
-1
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups_stopOne.py
...ster/vnode/4dnode1mnode_basic_replica3_vgroups_stopOne.py
+1
-1
tests/system-test/7-tmq/tmq3mnodeSwitch.py
tests/system-test/7-tmq/tmq3mnodeSwitch.py
+3
-3
未找到文件。
tests/pytest/client/client.py
浏览文件 @
d9d892bf
...
@@ -47,7 +47,7 @@ class TDTestCase:
...
@@ -47,7 +47,7 @@ class TDTestCase:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
ret
=
tdSql
.
query
(
's
how
mnodes'
)
ret
=
tdSql
.
query
(
's
elect * from information_schema.ins_
mnodes'
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkData
(
0
,
2
,
"master"
)
tdSql
.
checkData
(
0
,
2
,
"master"
)
...
...
tests/script/tsim/backup/arbitrator/dn3_mn2_killDnode.sim
浏览文件 @
d9d892bf
...
@@ -94,7 +94,7 @@ print ============== step3: stop dnode2
...
@@ -94,7 +94,7 @@ print ============== step3: stop dnode2
system sh/exec.sh -n dnode2 -s stop
system sh/exec.sh -n dnode2 -s stop
sleep 2000
sleep 2000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
...
...
tests/script/tsim/backup/arbitrator/replica_changeWithArbitrator.sim
浏览文件 @
d9d892bf
...
@@ -203,7 +203,7 @@ $cnt = $cnt + 1
...
@@ -203,7 +203,7 @@ $cnt = $cnt + 1
if $cnt == 10 then
if $cnt == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
if $rows != 2 then
if $rows != 2 then
sleep 2000
sleep 2000
goto wait_dnode2_master
goto wait_dnode2_master
...
...
tests/script/tsim/backup/cluster/cluster_main.sim
浏览文件 @
d9d892bf
...
@@ -121,8 +121,8 @@ sleep 10000
...
@@ -121,8 +121,8 @@ sleep 10000
#system rm -rf ../../../sim/dnode1/data
#system rm -rf ../../../sim/dnode1/data
#sleep 20000
#sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -137,8 +137,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -137,8 +137,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step6-1: restart dnode1
print ============== step6-1: restart dnode1
system sh/exec.sh -n dnode1 -s start
system sh/exec.sh -n dnode1 -s start
sleep 10000
sleep 10000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -154,8 +154,8 @@ print ============== step7: stop dnode2
...
@@ -154,8 +154,8 @@ print ============== step7: stop dnode2
system sh/exec.sh -n dnode2 -s stop -x SIGINT
system sh/exec.sh -n dnode2 -s stop -x SIGINT
sleep 3000
sleep 3000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -170,8 +170,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -170,8 +170,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step8: restart dnode2, then wait sync end
print ============== step8: restart dnode2, then wait sync end
system sh/exec.sh -n dnode2 -s start
system sh/exec.sh -n dnode2 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -186,8 +186,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -186,8 +186,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step9: stop dnode3, then wait sync end
print ============== step9: stop dnode3, then wait sync end
system sh/exec.sh -n dnode3 -s stop -x SIGINT
system sh/exec.sh -n dnode3 -s stop -x SIGINT
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -202,8 +202,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -202,8 +202,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step10: restart dnode3, then wait sync end
print ============== step10: restart dnode3, then wait sync end
system sh/exec.sh -n dnode3 -s start
system sh/exec.sh -n dnode3 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -222,8 +222,8 @@ sleep 20000
...
@@ -222,8 +222,8 @@ sleep 20000
print ============== step12: restart dnode4, then wait sync end
print ============== step12: restart dnode4, then wait sync end
system sh/exec.sh -n dnode4 -s start
system sh/exec.sh -n dnode4 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
...
tests/script/tsim/backup/cluster/cluster_main0.sim
浏览文件 @
d9d892bf
...
@@ -124,8 +124,8 @@ print ============== step6-1: restart dnode1
...
@@ -124,8 +124,8 @@ print ============== step6-1: restart dnode1
system sh/exec.sh -n dnode1 -s start
system sh/exec.sh -n dnode1 -s start
sleep 10000
sleep 10000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -141,8 +141,8 @@ print ============== step7: stop dnode2
...
@@ -141,8 +141,8 @@ print ============== step7: stop dnode2
system sh/exec.sh -n dnode2 -s stop -x SIGINT
system sh/exec.sh -n dnode2 -s stop -x SIGINT
sleep 3000
sleep 3000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -157,8 +157,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -157,8 +157,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step8: restart dnode2, then wait sync end
print ============== step8: restart dnode2, then wait sync end
system sh/exec.sh -n dnode2 -s start
system sh/exec.sh -n dnode2 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -173,8 +173,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -173,8 +173,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step9: stop dnode3, then wait sync end
print ============== step9: stop dnode3, then wait sync end
system sh/exec.sh -n dnode3 -s stop -x SIGINT
system sh/exec.sh -n dnode3 -s stop -x SIGINT
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -189,8 +189,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -189,8 +189,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step10: restart dnode3, then wait sync end
print ============== step10: restart dnode3, then wait sync end
system sh/exec.sh -n dnode3 -s start
system sh/exec.sh -n dnode3 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -209,8 +209,8 @@ sleep 20000
...
@@ -209,8 +209,8 @@ sleep 20000
print ============== step12: restart dnode4, then wait sync end
print ============== step12: restart dnode4, then wait sync end
system sh/exec.sh -n dnode4 -s start
system sh/exec.sh -n dnode4 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
...
tests/script/tsim/backup/cluster/cluster_main1.sim
浏览文件 @
d9d892bf
...
@@ -123,8 +123,8 @@ print ============== step6-1: restart dnode1
...
@@ -123,8 +123,8 @@ print ============== step6-1: restart dnode1
system sh/exec.sh -n dnode1 -s start
system sh/exec.sh -n dnode1 -s start
sleep 10000
sleep 10000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -140,8 +140,8 @@ print ============== step7: stop dnode2
...
@@ -140,8 +140,8 @@ print ============== step7: stop dnode2
system sh/exec.sh -n dnode2 -s stop -x SIGINT
system sh/exec.sh -n dnode2 -s stop -x SIGINT
sleep 3000
sleep 3000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -156,8 +156,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -156,8 +156,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step8: restart dnode2, then wait sync end
print ============== step8: restart dnode2, then wait sync end
system sh/exec.sh -n dnode2 -s start
system sh/exec.sh -n dnode2 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -172,8 +172,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -172,8 +172,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step9: stop dnode3, then wait sync end
print ============== step9: stop dnode3, then wait sync end
system sh/exec.sh -n dnode3 -s stop -x SIGINT
system sh/exec.sh -n dnode3 -s stop -x SIGINT
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -188,8 +188,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -188,8 +188,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step10: restart dnode3, then wait sync end
print ============== step10: restart dnode3, then wait sync end
system sh/exec.sh -n dnode3 -s start
system sh/exec.sh -n dnode3 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -208,8 +208,8 @@ sleep 20000
...
@@ -208,8 +208,8 @@ sleep 20000
#print ============== step12: restart dnode4, then wait sync end
#print ============== step12: restart dnode4, then wait sync end
#system sh/exec.sh -n dnode4 -s start
#system sh/exec.sh -n dnode4 -s start
#sleep 20000
#sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
...
tests/script/tsim/backup/cluster/cluster_main2.sim
浏览文件 @
d9d892bf
...
@@ -127,8 +127,8 @@ print ============== step6-1: restart dnode1
...
@@ -127,8 +127,8 @@ print ============== step6-1: restart dnode1
system sh/exec.sh -n dnode1 -s start
system sh/exec.sh -n dnode1 -s start
sleep 10000
sleep 10000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -144,8 +144,8 @@ print ============== step7: stop dnode2
...
@@ -144,8 +144,8 @@ print ============== step7: stop dnode2
system sh/exec.sh -n dnode2 -s stop -x SIGINT
system sh/exec.sh -n dnode2 -s stop -x SIGINT
sleep 3000
sleep 3000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -160,8 +160,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -160,8 +160,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step8: restart dnode2, then wait sync end
print ============== step8: restart dnode2, then wait sync end
system sh/exec.sh -n dnode2 -s start
system sh/exec.sh -n dnode2 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -176,8 +176,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -176,8 +176,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step9: stop dnode3, then wait sync end
print ============== step9: stop dnode3, then wait sync end
system sh/exec.sh -n dnode3 -s stop -x SIGINT
system sh/exec.sh -n dnode3 -s stop -x SIGINT
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -192,8 +192,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
...
@@ -192,8 +192,8 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step10: restart dnode3, then wait sync end
print ============== step10: restart dnode3, then wait sync end
system sh/exec.sh -n dnode3 -s start
system sh/exec.sh -n dnode3 -s start
sleep 20000
sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
@@ -212,8 +212,8 @@ sleep 20000
...
@@ -212,8 +212,8 @@ sleep 20000
#print ============== step12: restart dnode4, then wait sync end
#print ============== step12: restart dnode4, then wait sync end
#system sh/exec.sh -n dnode4 -s start
#system sh/exec.sh -n dnode4 -s start
#sleep 20000
#sleep 20000
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print s
how
mnodes
print s
elect * from information_schema.ins_
mnodes
print rows: $rows
print rows: $rows
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
...
...
tests/script/tsim/backup/clusterSimCase/cluster_main.sim
浏览文件 @
d9d892bf
...
@@ -16,7 +16,7 @@
...
@@ -16,7 +16,7 @@
# 5 | 718 | ready | 2 | 3 | master | 2 | slave |
# 5 | 718 | ready | 2 | 3 | master | 2 | slave |
#Query OK, 4 row(s) in set (0.002749s)
#Query OK, 4 row(s) in set (0.002749s)
#
#
#taos> s
how
mnodes
#taos> s
elect * from information_schema.ins_
mnodes
# -> ;
# -> ;
# id | end_point | role | create_time |
# id | end_point | role | create_time |
#=====================================================================================
#=====================================================================================
...
...
tests/script/tsim/bnode/basic1.sim
浏览文件 @
d9d892bf
...
@@ -15,7 +15,7 @@ if $data00 != 1 then
...
@@ -15,7 +15,7 @@ if $data00 != 1 then
return -1
return -1
endi
endi
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
@@ -62,7 +62,7 @@ if $data14 != ready then
...
@@ -62,7 +62,7 @@ if $data14 != ready then
return -1
return -1
endi
endi
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/dnode/create_dnode.sim
浏览文件 @
d9d892bf
...
@@ -17,7 +17,7 @@ if $data00 != 1 then
...
@@ -17,7 +17,7 @@ if $data00 != 1 then
endi
endi
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4] $data[0][5] $data[0][6]
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4] $data[0][5] $data[0][6]
if $rows != 1 then
if $rows != 1 then
return -1
return -1
...
@@ -65,7 +65,7 @@ if $data14 != ready then
...
@@ -65,7 +65,7 @@ if $data14 != ready then
return -1
return -1
endi
endi
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/dnode/drop_dnode_has_mnode.sim
浏览文件 @
d9d892bf
...
@@ -59,7 +59,7 @@ step3:
...
@@ -59,7 +59,7 @@ step3:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step3
sql s
elect * from information_schema.ins_
mnodes -x step3
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
if $data(1)[2] != leader then
if $data(1)[2] != leader then
...
@@ -84,8 +84,8 @@ if $data00 != 1 then
...
@@ -84,8 +84,8 @@ if $data00 != 1 then
return -1
return -1
endi
endi
print s
how
mnodes;
print s
elect * from information_schema.ins_
mnodes;
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
if $rows != 1 then
if $rows != 1 then
...
...
tests/script/tsim/dnode/use_dropped_dnode.sim
浏览文件 @
d9d892bf
...
@@ -115,7 +115,7 @@ step4:
...
@@ -115,7 +115,7 @@ step4:
print ====> dnode not online!
print ====> dnode not online!
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data10 $data11 $data12 $data13 $data14 $data15
if $rows != 2 then
if $rows != 2 then
...
...
tests/script/tsim/mnode/basic1.sim
浏览文件 @
d9d892bf
...
@@ -6,7 +6,7 @@ system sh/exec.sh -n dnode2 -s start
...
@@ -6,7 +6,7 @@ system sh/exec.sh -n dnode2 -s start
sql connect
sql connect
print =============== select * from information_schema.ins_dnodes
print =============== select * from information_schema.ins_dnodes
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
@@ -49,7 +49,7 @@ step2:
...
@@ -49,7 +49,7 @@ step2:
if $x == 20 then
if $x == 20 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
...
@@ -72,7 +72,7 @@ endi
...
@@ -72,7 +72,7 @@ endi
sleep 2000
sleep 2000
print ============ drop mnode 2
print ============ drop mnode 2
sql drop mnode on dnode 2
sql drop mnode on dnode 2
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
@@ -85,7 +85,7 @@ step2:
...
@@ -85,7 +85,7 @@ step2:
if $x == 20 then
if $x == 20 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
...
@@ -109,7 +109,7 @@ sleep 2000
...
@@ -109,7 +109,7 @@ sleep 2000
print =============== create mnodes
print =============== create mnodes
sql create mnode on dnode 2
sql create mnode on dnode 2
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
if $rows != 2 then
if $rows != 2 then
return -1
return -1
endi
endi
...
@@ -121,7 +121,7 @@ step3:
...
@@ -121,7 +121,7 @@ step3:
if $x == 20 then
if $x == 20 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
...
...
tests/script/tsim/mnode/basic2.sim
浏览文件 @
d9d892bf
...
@@ -6,7 +6,7 @@ system sh/exec.sh -n dnode2 -s start
...
@@ -6,7 +6,7 @@ system sh/exec.sh -n dnode2 -s start
sql connect
sql connect
print =============== select * from information_schema.ins_dnodes
print =============== select * from information_schema.ins_dnodes
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
@@ -46,7 +46,7 @@ step2:
...
@@ -46,7 +46,7 @@ step2:
if $x == 20 then
if $x == 20 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
...
@@ -88,7 +88,7 @@ system sh/exec.sh -n dnode1 -s start
...
@@ -88,7 +88,7 @@ system sh/exec.sh -n dnode1 -s start
system sh/exec.sh -n dnode2 -s start
system sh/exec.sh -n dnode2 -s start
sql connect
sql connect
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
if $rows != 2 then
if $rows != 2 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/mnode/basic3.sim
浏览文件 @
d9d892bf
...
@@ -49,7 +49,7 @@ step2:
...
@@ -49,7 +49,7 @@ step2:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step2
sql s
elect * from information_schema.ins_
mnodes -x step2
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data10 $data11 $data12 $data13 $data14 $data15
...
@@ -87,7 +87,7 @@ step4:
...
@@ -87,7 +87,7 @@ step4:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step4
sql s
elect * from information_schema.ins_
mnodes -x step4
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(3)[0] $data(3)[1] $data(3)[2]
print $data(3)[0] $data(3)[1] $data(3)[2]
...
@@ -126,7 +126,7 @@ step5:
...
@@ -126,7 +126,7 @@ step5:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step5
sql s
elect * from information_schema.ins_
mnodes -x step5
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(3)[0] $data(3)[1] $data(3)[2]
print $data(3)[0] $data(3)[1] $data(3)[2]
...
@@ -165,7 +165,7 @@ step6:
...
@@ -165,7 +165,7 @@ step6:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step6
sql s
elect * from information_schema.ins_
mnodes -x step6
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(3)[0] $data(3)[1] $data(3)[2]
print $data(3)[0] $data(3)[1] $data(3)[2]
...
...
tests/script/tsim/mnode/basic4.sim
浏览文件 @
d9d892bf
...
@@ -49,7 +49,7 @@ endi
...
@@ -49,7 +49,7 @@ endi
system sh/exec.sh -n dnode3 -s stop
system sh/exec.sh -n dnode3 -s stop
sql_error create mnode on dnode 3
sql_error create mnode on dnode 3
print =============== step3: s
how
mnodes
print =============== step3: s
elect * from information_schema.ins_
mnodes
$x = 0
$x = 0
step3:
step3:
...
@@ -58,7 +58,7 @@ step3:
...
@@ -58,7 +58,7 @@ step3:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step3
sql s
elect * from information_schema.ins_
mnodes -x step3
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4]
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4]
...
@@ -96,7 +96,7 @@ step4:
...
@@ -96,7 +96,7 @@ step4:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step4
sql s
elect * from information_schema.ins_
mnodes -x step4
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4]
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4]
...
@@ -135,7 +135,7 @@ step5:
...
@@ -135,7 +135,7 @@ step5:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step5
sql s
elect * from information_schema.ins_
mnodes -x step5
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4]
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4]
...
@@ -173,7 +173,7 @@ step6:
...
@@ -173,7 +173,7 @@ step6:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step6
sql s
elect * from information_schema.ins_
mnodes -x step6
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3] $data[1][4]
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4]
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4]
...
...
tests/script/tsim/mnode/basic5.sim
浏览文件 @
d9d892bf
...
@@ -67,7 +67,7 @@ step31:
...
@@ -67,7 +67,7 @@ step31:
if $x == 50 then
if $x == 50 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
$leaderNum = 0
$leaderNum = 0
if $data(1)[2] == leader then
if $data(1)[2] == leader then
$leaderNum = 1
$leaderNum = 1
...
@@ -161,7 +161,7 @@ step61:
...
@@ -161,7 +161,7 @@ step61:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes -x step61
sql s
elect * from information_schema.ins_
mnodes -x step61
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data20 $data21 $data22 $data23 $data24 $data25
print ===> $data20 $data21 $data22 $data23 $data24 $data25
...
@@ -215,7 +215,7 @@ step81:
...
@@ -215,7 +215,7 @@ step81:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data20 $data21 $data22 $data23 $data24 $data25
print ===> $data20 $data21 $data22 $data23 $data24 $data25
...
@@ -271,7 +271,7 @@ step92:
...
@@ -271,7 +271,7 @@ step92:
if $x == 20 then
if $x == 20 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data20 $data21 $data22 $data23 $data24 $data25
print ===> $data20 $data21 $data22 $data23 $data24 $data25
...
@@ -301,7 +301,7 @@ stepa:
...
@@ -301,7 +301,7 @@ stepa:
if $x == 10 then
if $x == 10 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data20 $data21 $data22 $data23 $data24 $data25
print ===> $data20 $data21 $data22 $data23 $data24 $data25
...
...
tests/script/tsim/qnode/basic1.sim
浏览文件 @
d9d892bf
...
@@ -62,7 +62,7 @@ if $data14 != ready then
...
@@ -62,7 +62,7 @@ if $data14 != ready then
return -1
return -1
endi
endi
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/show/basic.sim
浏览文件 @
d9d892bf
...
@@ -44,7 +44,7 @@ if $rows != 2 then
...
@@ -44,7 +44,7 @@ if $rows != 2 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
@@ -142,7 +142,7 @@ if $rows != 2 then
...
@@ -142,7 +142,7 @@ if $rows != 2 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/snode/basic1.sim
浏览文件 @
d9d892bf
...
@@ -62,7 +62,7 @@ if $data14 != ready then
...
@@ -62,7 +62,7 @@ if $data14 != ready then
return -1
return -1
endi
endi
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/sync/3Replica5VgElect3mnode.sim
浏览文件 @
d9d892bf
...
@@ -276,7 +276,7 @@ check_mnode_ready_2:
...
@@ -276,7 +276,7 @@ check_mnode_ready_2:
print ====> first create three mnode not ready!
print ====> first create three mnode not ready!
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
...
@@ -568,7 +568,7 @@ check_mnode_ready_3:
...
@@ -568,7 +568,7 @@ check_mnode_ready_3:
print ====> second mnode not ready!
print ====> second mnode not ready!
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
...
@@ -847,7 +847,7 @@ check_mnode_ready_3:
...
@@ -847,7 +847,7 @@ check_mnode_ready_3:
print ====> third: mnode not ready!
print ====> third: mnode not ready!
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
...
...
tests/script/tsim/sync/3Replica5VgElect3mnodedrop.sim
浏览文件 @
d9d892bf
...
@@ -278,7 +278,7 @@ check_mnode_ready_2:
...
@@ -278,7 +278,7 @@ check_mnode_ready_2:
print ====> first create three mnode not ready!
print ====> first create three mnode not ready!
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
...
@@ -531,7 +531,7 @@ check_mnode_ready_3:
...
@@ -531,7 +531,7 @@ check_mnode_ready_3:
print ====> second mnode not ready!
print ====> second mnode not ready!
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
...
@@ -580,7 +580,7 @@ if $loop_cnt == 300 then
...
@@ -580,7 +580,7 @@ if $loop_cnt == 300 then
print ====> vgroups not ready!
print ====> vgroups not ready!
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[1][0] $data[1][1] $data[1][2] $data[1][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
print ===> $rows $data[2][0] $data[2][1] $data[2][2] $data[2][3]
...
...
tests/script/tsim/sync/mnodeLeaderTransfer.sim
浏览文件 @
d9d892bf
...
@@ -8,7 +8,7 @@ system sh/exec.sh -n dnode3 -s start
...
@@ -8,7 +8,7 @@ system sh/exec.sh -n dnode3 -s start
sql connect
sql connect
print =============== select * from information_schema.ins_dnodes
print =============== select * from information_schema.ins_dnodes
sql s
how
mnodes;
sql s
elect * from information_schema.ins_
mnodes;
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/user/password.sim
浏览文件 @
d9d892bf
...
@@ -10,7 +10,7 @@ sql create user u_write pass 'taosdata1'
...
@@ -10,7 +10,7 @@ sql create user u_write pass 'taosdata1'
sql alter user u_read pass 'taosdata'
sql alter user u_read pass 'taosdata'
sql alter user u_write pass 'taosdata'
sql alter user u_write pass 'taosdata'
sql s
elect * from information_schema.ins_
users
sql s
how
users
if $rows != 3 then
if $rows != 3 then
return -1
return -1
endi
endi
...
@@ -26,7 +26,7 @@ sql_error alter user u_write pass 'taosdata1'
...
@@ -26,7 +26,7 @@ sql_error alter user u_write pass 'taosdata1'
sql_error create user read1 pass 'taosdata1'
sql_error create user read1 pass 'taosdata1'
sql_error create user write1 pass 'taosdata1'
sql_error create user write1 pass 'taosdata1'
sql s
elect * from information_schema.ins_
users
sql s
how
users
if $rows != 3 then
if $rows != 3 then
return -1
return -1
endi
endi
...
@@ -41,7 +41,7 @@ sql_error create user write2 pass 'taosdata1'
...
@@ -41,7 +41,7 @@ sql_error create user write2 pass 'taosdata1'
sql alter user u_write pass 'taosdata'
sql alter user u_write pass 'taosdata'
sql_error alter user u_read pass 'taosdata'
sql_error alter user u_read pass 'taosdata'
sql s
elect * from information_schema.ins_
users
sql s
how
users
if $rows != 3 then
if $rows != 3 then
return -1
return -1
endi
endi
...
@@ -56,7 +56,7 @@ sql_error create userabcd012345678901234567891234567890abcd012345678901234567891
...
@@ -56,7 +56,7 @@ sql_error create userabcd012345678901234567891234567890abcd012345678901234567891
sql_error create user abcd0123456789012345678901234567890111 PASS '123'
sql_error create user abcd0123456789012345678901234567890111 PASS '123'
sql create user abc01234567890123456789 PASS '123'
sql create user abc01234567890123456789 PASS '123'
sql s
elect * from information_schema.ins_
users
sql s
how
users
if $rows != 5 then
if $rows != 5 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/user/privilege_sysinfo.sim
浏览文件 @
d9d892bf
...
@@ -52,7 +52,7 @@ print =============== check show
...
@@ -52,7 +52,7 @@ print =============== check show
sql_error select * from information_schema.ins_users
sql_error select * from information_schema.ins_users
sql_error show cluster
sql_error show cluster
sql_error select * from information_schema.ins_dnodes
sql_error select * from information_schema.ins_dnodes
sql_error s
how
mnodes
sql_error s
elect * from information_schema.ins_
mnodes
sql_error show snodes
sql_error show snodes
sql_error show qnodes
sql_error show qnodes
sql_error show bnodes
sql_error show bnodes
...
...
tests/script/tsim/valgrind/checkError1.sim
浏览文件 @
d9d892bf
...
@@ -58,7 +58,7 @@ if $rows != 2 then
...
@@ -58,7 +58,7 @@ if $rows != 2 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
if $rows != 1 then
if $rows != 1 then
return -1
return -1
endi
endi
...
...
tests/script/tsim/vnode/replica3_basic.sim
浏览文件 @
d9d892bf
...
@@ -47,7 +47,7 @@ step02:
...
@@ -47,7 +47,7 @@ step02:
if $x == 20 then
if $x == 20 then
return -1
return -1
endi
endi
sql s
how
mnodes
sql s
elect * from information_schema.ins_
mnodes
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(1)[0] $data(1)[1] $data(1)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(2)[0] $data(2)[1] $data(2)[2]
print $data(3)[0] $data(3)[1] $data(3)[2]
print $data(3)[0] $data(3)[1] $data(3)[2]
...
...
tests/system-test/0-others/user_control.py
浏览文件 @
d9d892bf
...
@@ -692,7 +692,7 @@ class TDTestCase:
...
@@ -692,7 +692,7 @@ class TDTestCase:
taos4_conn
=
taos
.
connect
(
user
=
self
.
__user_list
[
4
],
password
=
f
"new
{
self
.
__passwd_list
[
4
]
}
"
)
taos4_conn
=
taos
.
connect
(
user
=
self
.
__user_list
[
4
],
password
=
f
"new
{
self
.
__passwd_list
[
4
]
}
"
)
taos4_except
=
True
taos4_except
=
True
try
:
try
:
taos4_conn
.
query
(
f
"s
how
mnodes"
)
taos4_conn
.
query
(
f
"s
elect * from information_schema.ins_
mnodes"
)
taos4_conn
.
query
(
f
"show
{
DBNAME
}
.vgroups"
)
taos4_conn
.
query
(
f
"show
{
DBNAME
}
.vgroups"
)
except
BaseException
:
except
BaseException
:
taos4_except
=
False
taos4_except
=
False
...
...
tests/system-test/6-cluster/5dnode1mnode.py
浏览文件 @
d9d892bf
...
@@ -94,7 +94,7 @@ class TDTestCase:
...
@@ -94,7 +94,7 @@ class TDTestCase:
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
...
...
tests/system-test/6-cluster/5dnode2mnode.py
浏览文件 @
d9d892bf
...
@@ -48,7 +48,7 @@ class TDTestCase:
...
@@ -48,7 +48,7 @@ class TDTestCase:
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
...
@@ -62,7 +62,7 @@ class TDTestCase:
...
@@ -62,7 +62,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
2
)
tdSql
.
checkRows
(
2
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
1
][
2
]
==
'follower'
:
if
tdSql
.
queryResult
[
1
][
2
]
==
'follower'
:
...
...
tests/system-test/6-cluster/5dnode3mnodeDrop.py
浏览文件 @
d9d892bf
...
@@ -117,7 +117,7 @@ class TDTestCase:
...
@@ -117,7 +117,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -141,7 +141,7 @@ class TDTestCase:
...
@@ -141,7 +141,7 @@ class TDTestCase:
tdLog
.
debug
(
"three mnodes is not ready in 10s "
)
tdLog
.
debug
(
"three mnodes is not ready in 10s "
)
return
-
1
return
-
1
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
...
@@ -154,7 +154,7 @@ class TDTestCase:
...
@@ -154,7 +154,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'offline'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'offline'
:
...
@@ -172,7 +172,7 @@ class TDTestCase:
...
@@ -172,7 +172,7 @@ class TDTestCase:
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 1;"
)
tdSql
.
error
(
"drop mnode on dnode 1;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'offline'
)
tdSql
.
checkData
(
0
,
2
,
'offline'
)
...
@@ -186,7 +186,7 @@ class TDTestCase:
...
@@ -186,7 +186,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
40
:
while
count
<
40
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -200,7 +200,7 @@ class TDTestCase:
...
@@ -200,7 +200,7 @@ class TDTestCase:
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 2;"
)
tdSql
.
error
(
"drop mnode on dnode 2;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -216,7 +216,7 @@ class TDTestCase:
...
@@ -216,7 +216,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -229,7 +229,7 @@ class TDTestCase:
...
@@ -229,7 +229,7 @@ class TDTestCase:
tdLog
.
debug
(
"stop mnodes on dnode 3 failed in 10s"
)
tdLog
.
debug
(
"stop mnodes on dnode 3 failed in 10s"
)
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 3;"
)
tdSql
.
error
(
"drop mnode on dnode 3;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -249,7 +249,7 @@ class TDTestCase:
...
@@ -249,7 +249,7 @@ class TDTestCase:
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -276,11 +276,11 @@ class TDTestCase:
...
@@ -276,11 +276,11 @@ class TDTestCase:
for
i
in
range
(
1
,
3
):
for
i
in
range
(
1
,
3
):
tdLog
.
debug
(
"drop mnode on dnode %d"
%
(
i
+
1
))
tdLog
.
debug
(
"drop mnode on dnode %d"
%
(
i
+
1
))
tdSql
.
execute
(
"drop mnode on dnode %d"
%
(
i
+
1
))
tdSql
.
execute
(
"drop mnode on dnode %d"
%
(
i
+
1
))
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
2
):
if
tdSql
.
checkRows
(
2
):
tdLog
.
debug
(
"drop mnode %d successfully"
%
(
i
+
1
))
tdLog
.
debug
(
"drop mnode %d successfully"
%
(
i
+
1
))
break
break
...
@@ -290,7 +290,7 @@ class TDTestCase:
...
@@ -290,7 +290,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
):
if
tdSql
.
checkRows
(
3
):
tdLog
.
debug
(
"drop mnode %d successfully"
%
(
i
+
1
))
tdLog
.
debug
(
"drop mnode %d successfully"
%
(
i
+
1
))
break
break
...
...
tests/system-test/6-cluster/5dnode3mnodeDropInsert.py
浏览文件 @
d9d892bf
...
@@ -209,7 +209,7 @@ class TDTestCase:
...
@@ -209,7 +209,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
print
(
"mnode is three nodes"
)
print
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -232,7 +232,7 @@ class TDTestCase:
...
@@ -232,7 +232,7 @@ class TDTestCase:
print
(
"three mnodes is not ready in 10s "
)
print
(
"three mnodes is not ready in 10s "
)
return
-
1
return
-
1
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
...
@@ -245,7 +245,7 @@ class TDTestCase:
...
@@ -245,7 +245,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
print
(
"mnode is three nodes"
)
print
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'offline'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'offline'
:
...
@@ -263,7 +263,7 @@ class TDTestCase:
...
@@ -263,7 +263,7 @@ class TDTestCase:
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 1;"
)
tdSql
.
error
(
"drop mnode on dnode 1;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'offline'
)
tdSql
.
checkData
(
0
,
2
,
'offline'
)
...
@@ -277,7 +277,7 @@ class TDTestCase:
...
@@ -277,7 +277,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
40
:
while
count
<
40
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
print
(
"mnode is three nodes"
)
print
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -291,7 +291,7 @@ class TDTestCase:
...
@@ -291,7 +291,7 @@ class TDTestCase:
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 2;"
)
tdSql
.
error
(
"drop mnode on dnode 2;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -307,7 +307,7 @@ class TDTestCase:
...
@@ -307,7 +307,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
print
(
"mnode is three nodes"
)
print
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -320,7 +320,7 @@ class TDTestCase:
...
@@ -320,7 +320,7 @@ class TDTestCase:
print
(
"stop mnodes on dnode 3 failed in 10s"
)
print
(
"stop mnodes on dnode 3 failed in 10s"
)
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 3;"
)
tdSql
.
error
(
"drop mnode on dnode 3;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -348,7 +348,7 @@ class TDTestCase:
...
@@ -348,7 +348,7 @@ class TDTestCase:
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -383,11 +383,11 @@ class TDTestCase:
...
@@ -383,11 +383,11 @@ class TDTestCase:
for
i
in
range
(
1
,
3
):
for
i
in
range
(
1
,
3
):
tdLog
.
debug
(
"drop mnode on dnode %d"
%
(
i
+
1
))
tdLog
.
debug
(
"drop mnode on dnode %d"
%
(
i
+
1
))
tdSql
.
execute
(
"drop mnode on dnode %d"
%
(
i
+
1
))
tdSql
.
execute
(
"drop mnode on dnode %d"
%
(
i
+
1
))
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
2
):
if
tdSql
.
checkRows
(
2
):
print
(
"drop mnode %d successfully"
%
(
i
+
1
))
print
(
"drop mnode %d successfully"
%
(
i
+
1
))
break
break
...
@@ -397,7 +397,7 @@ class TDTestCase:
...
@@ -397,7 +397,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
):
if
tdSql
.
checkRows
(
3
):
print
(
"drop mnode %d successfully"
%
(
i
+
1
))
print
(
"drop mnode %d successfully"
%
(
i
+
1
))
break
break
...
...
tests/system-test/6-cluster/5dnode3mnodeSeperate1VnodeStopInsert.py
浏览文件 @
d9d892bf
...
@@ -128,7 +128,7 @@ class TDTestCase:
...
@@ -128,7 +128,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
print
(
"mnode is three nodes"
)
print
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -151,7 +151,7 @@ class TDTestCase:
...
@@ -151,7 +151,7 @@ class TDTestCase:
print
(
"three mnodes is not ready in 10s "
)
print
(
"three mnodes is not ready in 10s "
)
return
-
1
return
-
1
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
...
@@ -164,7 +164,7 @@ class TDTestCase:
...
@@ -164,7 +164,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
print
(
"mnode is three nodes"
)
print
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'offline'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'offline'
:
...
@@ -182,7 +182,7 @@ class TDTestCase:
...
@@ -182,7 +182,7 @@ class TDTestCase:
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 1;"
)
tdSql
.
error
(
"drop mnode on dnode 1;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'offline'
)
tdSql
.
checkData
(
0
,
2
,
'offline'
)
...
@@ -196,7 +196,7 @@ class TDTestCase:
...
@@ -196,7 +196,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
40
:
while
count
<
40
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
print
(
"mnode is three nodes"
)
print
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -210,7 +210,7 @@ class TDTestCase:
...
@@ -210,7 +210,7 @@ class TDTestCase:
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 2;"
)
tdSql
.
error
(
"drop mnode on dnode 2;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -226,7 +226,7 @@ class TDTestCase:
...
@@ -226,7 +226,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
print
(
"mnode is three nodes"
)
print
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -239,7 +239,7 @@ class TDTestCase:
...
@@ -239,7 +239,7 @@ class TDTestCase:
print
(
"stop mnodes on dnode 3 failed in 10s"
)
print
(
"stop mnodes on dnode 3 failed in 10s"
)
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 3;"
)
tdSql
.
error
(
"drop mnode on dnode 3;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -265,7 +265,7 @@ class TDTestCase:
...
@@ -265,7 +265,7 @@ class TDTestCase:
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
...
tests/system-test/6-cluster/5dnode3mnodeStopInsert.py
浏览文件 @
d9d892bf
...
@@ -167,7 +167,7 @@ class TDTestCase:
...
@@ -167,7 +167,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -190,7 +190,7 @@ class TDTestCase:
...
@@ -190,7 +190,7 @@ class TDTestCase:
tdLog
.
debug
(
"three mnodes is not ready in 10s "
)
tdLog
.
debug
(
"three mnodes is not ready in 10s "
)
return
-
1
return
-
1
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
tdSql
.
checkData
(
0
,
3
,
'ready'
)
...
@@ -203,7 +203,7 @@ class TDTestCase:
...
@@ -203,7 +203,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'offline'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'offline'
:
...
@@ -221,7 +221,7 @@ class TDTestCase:
...
@@ -221,7 +221,7 @@ class TDTestCase:
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 1;"
)
tdSql
.
error
(
"drop mnode on dnode 1;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'offline'
)
tdSql
.
checkData
(
0
,
2
,
'offline'
)
...
@@ -235,7 +235,7 @@ class TDTestCase:
...
@@ -235,7 +235,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
40
:
while
count
<
40
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -249,7 +249,7 @@ class TDTestCase:
...
@@ -249,7 +249,7 @@ class TDTestCase:
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 2;"
)
tdSql
.
error
(
"drop mnode on dnode 2;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -265,7 +265,7 @@ class TDTestCase:
...
@@ -265,7 +265,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
3
)
:
if
tdSql
.
checkRows
(
3
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
if
tdSql
.
queryResult
[
0
][
2
]
==
'leader'
:
...
@@ -278,7 +278,7 @@ class TDTestCase:
...
@@ -278,7 +278,7 @@ class TDTestCase:
tdLog
.
debug
(
"stop mnodes on dnode 3 failed in 10s"
)
tdLog
.
debug
(
"stop mnodes on dnode 3 failed in 10s"
)
return
-
1
return
-
1
tdSql
.
error
(
"drop mnode on dnode 3;"
)
tdSql
.
error
(
"drop mnode on dnode 3;"
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkRows
(
3
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
@@ -296,7 +296,7 @@ class TDTestCase:
...
@@ -296,7 +296,7 @@ class TDTestCase:
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
4
,
1
,
'%s:6430'
%
self
.
host
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
0
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
checkData
(
4
,
4
,
'ready'
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkRows
(
1
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
1
,
'%s:6030'
%
self
.
host
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
tdSql
.
checkData
(
0
,
2
,
'leader'
)
...
...
tests/system-test/6-cluster/clusterCommonCheck.py
浏览文件 @
d9d892bf
...
@@ -117,7 +117,7 @@ class ClusterComCheck:
...
@@ -117,7 +117,7 @@ class ClusterComCheck:
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
self
.
mnodeNums
)
:
if
tdSql
.
checkRows
(
self
.
mnodeNums
)
:
tdLog
.
success
(
"cluster has %d mnodes"
%
self
.
mnodeNums
)
tdLog
.
success
(
"cluster has %d mnodes"
%
self
.
mnodeNums
)
...
@@ -164,7 +164,7 @@ class ClusterComCheck:
...
@@ -164,7 +164,7 @@ class ClusterComCheck:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
mnodeNums
)
:
if
tdSql
.
checkRows
(
mnodeNums
)
:
tdLog
.
success
(
"cluster has %d mnodes"
%
self
.
mnodeNums
)
tdLog
.
success
(
"cluster has %d mnodes"
%
self
.
mnodeNums
)
else
:
else
:
...
@@ -210,7 +210,7 @@ class ClusterComCheck:
...
@@ -210,7 +210,7 @@ class ClusterComCheck:
count
=
0
count
=
0
while
count
<
10
:
while
count
<
10
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
mnodeNums
)
:
if
tdSql
.
checkRows
(
mnodeNums
)
:
tdLog
.
success
(
"cluster has %d mnodes"
%
self
.
mnodeNums
)
tdLog
.
success
(
"cluster has %d mnodes"
%
self
.
mnodeNums
)
else
:
else
:
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_createDb_replica1.py
浏览文件 @
d9d892bf
...
@@ -41,7 +41,7 @@ class TDTestCase:
...
@@ -41,7 +41,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica1_insertdatas.py
浏览文件 @
d9d892bf
...
@@ -47,7 +47,7 @@ class TDTestCase:
...
@@ -47,7 +47,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica1_insertdatas_querys.py
浏览文件 @
d9d892bf
...
@@ -48,7 +48,7 @@ class TDTestCase:
...
@@ -48,7 +48,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas.py
浏览文件 @
d9d892bf
...
@@ -47,7 +47,7 @@ class TDTestCase:
...
@@ -47,7 +47,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_force_stop_all_dnodes.py
浏览文件 @
d9d892bf
...
@@ -57,7 +57,7 @@ class TDTestCase:
...
@@ -57,7 +57,7 @@ class TDTestCase:
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys.py
浏览文件 @
d9d892bf
...
@@ -48,7 +48,7 @@ class TDTestCase:
...
@@ -48,7 +48,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_all_vnode.py
浏览文件 @
d9d892bf
...
@@ -50,7 +50,7 @@ class TDTestCase:
...
@@ -50,7 +50,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_follower.py
浏览文件 @
d9d892bf
...
@@ -50,7 +50,7 @@ class TDTestCase:
...
@@ -50,7 +50,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_leader.py
浏览文件 @
d9d892bf
...
@@ -50,7 +50,7 @@ class TDTestCase:
...
@@ -50,7 +50,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_all_dnodes.py
浏览文件 @
d9d892bf
...
@@ -57,7 +57,7 @@ class TDTestCase:
...
@@ -57,7 +57,7 @@ class TDTestCase:
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_sync.py
浏览文件 @
d9d892bf
...
@@ -56,7 +56,7 @@ class TDTestCase:
...
@@ -56,7 +56,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_unsync.py
浏览文件 @
d9d892bf
...
@@ -56,7 +56,7 @@ class TDTestCase:
...
@@ -56,7 +56,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_unsync_force_stop.py
浏览文件 @
d9d892bf
...
@@ -56,7 +56,7 @@ class TDTestCase:
...
@@ -56,7 +56,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_leader.py
浏览文件 @
d9d892bf
...
@@ -139,7 +139,7 @@ class TDTestCase:
...
@@ -139,7 +139,7 @@ class TDTestCase:
return
check_status
return
check_status
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_leader_forece_stop.py
浏览文件 @
d9d892bf
...
@@ -139,7 +139,7 @@ class TDTestCase:
...
@@ -139,7 +139,7 @@ class TDTestCase:
return
check_status
return
check_status
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_mnode3_insertdatas_querys.py
浏览文件 @
d9d892bf
...
@@ -48,7 +48,7 @@ class TDTestCase:
...
@@ -48,7 +48,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
@@ -190,7 +190,7 @@ class TDTestCase:
...
@@ -190,7 +190,7 @@ class TDTestCase:
# create mnode
# create mnode
tdSql
.
execute
(
"create mnode on dnode 2 "
)
tdSql
.
execute
(
"create mnode on dnode 2 "
)
tdSql
.
execute
(
"create mnode on dnode 3 "
)
tdSql
.
execute
(
"create mnode on dnode 3 "
)
os
.
system
(
"taos -s 's
how
mnodes;'"
)
os
.
system
(
"taos -s 's
elect * from information_schema.ins_
mnodes;'"
)
# start writing constantly
# start writing constantly
writing
=
threading
.
Thread
(
target
=
self
.
create_db_replica_3_insertdatas
,
args
=
(
self
.
db_name
,
self
.
replica
,
self
.
vgroups
,
self
.
tb_nums
,
self
.
row_nums
))
writing
=
threading
.
Thread
(
target
=
self
.
create_db_replica_3_insertdatas
,
args
=
(
self
.
db_name
,
self
.
replica
,
self
.
vgroups
,
self
.
tb_nums
,
self
.
row_nums
))
writing
.
start
()
writing
.
start
()
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_follower.py
浏览文件 @
d9d892bf
...
@@ -58,7 +58,7 @@ class TDTestCase:
...
@@ -58,7 +58,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_follower_force_stop.py
浏览文件 @
d9d892bf
...
@@ -58,7 +58,7 @@ class TDTestCase:
...
@@ -58,7 +58,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_leader.py
浏览文件 @
d9d892bf
...
@@ -58,7 +58,7 @@ class TDTestCase:
...
@@ -58,7 +58,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_leader_force_stop.py
浏览文件 @
d9d892bf
...
@@ -58,7 +58,7 @@ class TDTestCase:
...
@@ -58,7 +58,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups.py
浏览文件 @
d9d892bf
...
@@ -47,7 +47,7 @@ class TDTestCase:
...
@@ -47,7 +47,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups_stopOne.py
浏览文件 @
d9d892bf
...
@@ -50,7 +50,7 @@ class TDTestCase:
...
@@ -50,7 +50,7 @@ class TDTestCase:
return
buildPath
return
buildPath
def
check_setup_cluster_status
(
self
):
def
check_setup_cluster_status
(
self
):
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
for
mnode
in
tdSql
.
queryResult
:
for
mnode
in
tdSql
.
queryResult
:
name
=
mnode
[
1
]
name
=
mnode
[
1
]
info
=
mnode
info
=
mnode
...
...
tests/system-test/7-tmq/tmq3mnodeSwitch.py
浏览文件 @
d9d892bf
...
@@ -63,7 +63,7 @@ class TDTestCase:
...
@@ -63,7 +63,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
self
.
mnodeCheckCnt
:
while
count
<
self
.
mnodeCheckCnt
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
if
tdSql
.
checkRows
(
self
.
mnodes
)
:
if
tdSql
.
checkRows
(
self
.
mnodes
)
:
tdLog
.
debug
(
"mnode is three nodes"
)
tdLog
.
debug
(
"mnode is three nodes"
)
else
:
else
:
...
@@ -87,7 +87,7 @@ class TDTestCase:
...
@@ -87,7 +87,7 @@ class TDTestCase:
else
:
else
:
tdLog
.
exit
(
"three mnodes is not ready in 10s "
)
tdLog
.
exit
(
"three mnodes is not ready in 10s "
)
tdSql
.
query
(
"s
how
mnodes;"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes;"
)
tdSql
.
checkRows
(
self
.
mnodes
)
tdSql
.
checkRows
(
self
.
mnodes
)
tdSql
.
checkData
(
0
,
self
.
mnodeEpIndex
,
'%s:%d'
%
(
self
.
host
,
self
.
startPort
))
tdSql
.
checkData
(
0
,
self
.
mnodeEpIndex
,
'%s:%d'
%
(
self
.
host
,
self
.
startPort
))
tdSql
.
checkData
(
0
,
self
.
mnodeStatusIndex
,
'ready'
)
tdSql
.
checkData
(
0
,
self
.
mnodeStatusIndex
,
'ready'
)
...
@@ -100,7 +100,7 @@ class TDTestCase:
...
@@ -100,7 +100,7 @@ class TDTestCase:
count
=
0
count
=
0
while
count
<
self
.
mnodeCheckCnt
:
while
count
<
self
.
mnodeCheckCnt
:
time
.
sleep
(
1
)
time
.
sleep
(
1
)
tdSql
.
query
(
"s
how
mnodes"
)
tdSql
.
query
(
"s
elect * from information_schema.ins_
mnodes"
)
tdLog
.
debug
(
tdSql
.
queryResult
)
tdLog
.
debug
(
tdSql
.
queryResult
)
# if tdSql.checkRows(self.mnodes) :
# if tdSql.checkRows(self.mnodes) :
# tdLog.debug("mnode is three nodes")
# tdLog.debug("mnode is three nodes")
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录