Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
aa042c60
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
未验证
提交
aa042c60
编写于
5月 25, 2022
作者:
H
Hui Li
提交者:
GitHub
5月 25, 2022
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #12938 from taosdata/test/chr/TD-14699
Test/chr/td 14699
上级
12e99187
6e661765
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
23 addition
and
32 deletion
+23
-32
tests/script/tsim/sync/insertDataByRunBack.sim
tests/script/tsim/sync/insertDataByRunBack.sim
+5
-0
tests/script/tsim/sync/threeReplica1VgElectWihtInsert.sim
tests/script/tsim/sync/threeReplica1VgElectWihtInsert.sim
+8
-22
tests/system-test/1-insert/insertWithMoreVgroup.py
tests/system-test/1-insert/insertWithMoreVgroup.py
+7
-7
tests/system-test/1-insert/manyVgroups.json
tests/system-test/1-insert/manyVgroups.json
+3
-3
未找到文件。
tests/script/tsim/sync/insertDataByRunBack.sim
浏览文件 @
aa042c60
...
...
@@ -20,6 +20,8 @@ print $data[1][0] $data[1][1] $data[1][2] $data[1][3]
if $rows == 2 then
if $data[1][1] == stop then
goto end_insert
elif $data[0][1] == stop then
goto end_insert
endi
endi
...
...
@@ -47,6 +49,9 @@ endw
if $loop_cnt == 0 then
print ====> notify main to working for insert data
sql insert into interaction values (now, 'working', 0, 0);
sql select * from interaction
print $data[0][0] $data[0][1] $data[0][2] $data[0][3]
print $data[1][0] $data[1][1] $data[1][2] $data[1][3]
endi
$loop_cnt = $loop_cnt + 1
goto loop_insert
...
...
tests/script/tsim/sync/threeReplica1VgElectWihtInsert.sim
浏览文件 @
aa042c60
...
...
@@ -155,28 +155,13 @@ while $i < $tbNum
sql create table $ctb using stb tags( $i )
$ntb = $ntbPrefix . $i
sql create table $ntb (ts timestamp, c1 int, c2 float, c3 binary(10))
# $x = 0
# while $x < $rowNum
# $binary = ' . binary
# $binary = $binary . $i
# $binary = $binary . '
#
# sql insert into $ctb values ($tstart , $i , $x , $binary )
# sql insert into $ntb values ($tstart , 999 , 999 , 'binary-ntb' )
# $tstart = $tstart + 1
# $x = $x + 1
# endw
# print ====> insert rows: $rowNum into $ctb and $ntb
$i = $i + 1
# $tstart = 1640966400000
endw
$totalTblNum = $tbNum * 2
print ====>totalTblNum:$totalTblNum
sleep 1000
sql show tables
print ====> expect $totalTblNum and infinsert $rows in fact
if $rows != $totalTblNum then
return -1
endi
...
...
@@ -222,6 +207,9 @@ endi
$dnodeId = dnode . $dnodeId
print ====> stop $dnodeId
system sh/exec.sh -n $dnodeId -s stop -x SIGINT
sleep 1000
print ====> start $dnodeId
system sh/exec.sh -n $dnodeId -s start
$loop_cnt = 0
check_vg_ready_2:
...
...
@@ -245,7 +233,7 @@ if $data[0][4] == LEADER then
if $data[0][8] != FOLLOWER then
goto check_vg_ready_2
endi
print ---- vgroup $d
ata[0][0]
leader switch to dnode $data[0][3]
print ---- vgroup $d
nodeId
leader switch to dnode $data[0][3]
goto vg_ready_2
elif $data[0][6] == LEADER then
if $data[0][4] != FOLLOWER then
...
...
@@ -254,7 +242,7 @@ elif $data[0][6] == LEADER then
if $data[0][8] != FOLLOWER then
goto check_vg_ready_2
endi
print ---- vgroup $d
ata[0][0]
leader switch to dnode $data[0][5]
print ---- vgroup $d
nodeId
leader switch to dnode $data[0][5]
goto vg_ready_2
elif $data[0][8] == LEADER then
if $data[0][4] != FOLLOWER then
...
...
@@ -263,7 +251,7 @@ elif $data[0][8] == LEADER then
if $data[0][6] != FOLLOWER then
goto check_vg_ready_2
endi
print ---- vgroup $d
ata[0][0]
leader switch to dnode $data[0][7]
print ---- vgroup $d
nodeId
leader switch to dnode $data[0][7]
goto vg_ready_2
else
goto check_vg_ready_2
...
...
@@ -272,8 +260,6 @@ vg_ready_2:
$switch_loop_cnt = $switch_loop_cnt + 1
if $switch_loop_cnt < 3 then
print ====> start $dnodeId
system sh/exec.sh -n $dnodeId -s start
goto switch_leader_loop
endi
...
...
tests/system-test/1-insert/insertWithMoreVgroup.py
浏览文件 @
aa042c60
...
...
@@ -294,7 +294,7 @@ class TDTestCase:
return
def
test_case3
(
self
):
self
.
taosBenchCreate
(
"127.0.0.1"
,
"no"
,
"db1"
,
"stb1"
,
1
,
8
,
1
*
1000
0
)
self
.
taosBenchCreate
(
"127.0.0.1"
,
"no"
,
"db1"
,
"stb1"
,
1
,
1
,
1
*
1
0
)
# self.taosBenchCreate("test209","no","db2", "stb2", 1, 8, 1*10000)
# self.taosBenchCreate("chenhaoran02","no","db1", "stb1", 1, 8, 1*10000)
...
...
@@ -349,17 +349,17 @@ class TDTestCase:
# run case
def
run
(
self
):
# create database and tables。
self
.
test_case1
()
tdLog
.
debug
(
" LIMIT test_case1 ............ [OK]"
)
#
#
create database and tables。
#
self.test_case1()
#
tdLog.debug(" LIMIT test_case1 ............ [OK]")
# # taosBenchmark : create database and table
# self.test_case2()
# tdLog.debug(" LIMIT test_case2 ............ [OK]")
#
#
taosBenchmark:create database/table and insert data
#
self.test_case3()
#
tdLog.debug(" LIMIT test_case3 ............ [OK]")
# taosBenchmark:create database/table and insert data
self
.
test_case3
()
tdLog
.
debug
(
" LIMIT test_case3 ............ [OK]"
)
# # test qnode
...
...
tests/system-test/1-insert/manyVgroups.json
浏览文件 @
aa042c60
...
...
@@ -10,7 +10,7 @@
"result_file"
:
"./insert_res.txt"
,
"confirm_parameter_prompt"
:
"no"
,
"insert_interval"
:
0
,
"interlace_rows"
:
10000
0
,
"interlace_rows"
:
0
,
"num_of_records_per_req"
:
100
,
"databases"
:
[
{
...
...
@@ -29,8 +29,8 @@
"batch_create_tbl_num"
:
50000
,
"data_source"
:
"rand"
,
"insert_mode"
:
"taosc"
,
"insert_rows"
:
1
0
,
"interlace_rows"
:
10000
0
,
"insert_rows"
:
1
,
"interlace_rows"
:
0
,
"insert_interval"
:
0
,
"max_sql_len"
:
10000000
,
"disorder_ratio"
:
0
,
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录