xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

test: improve the robustness of alterConfig.py

This commit is contained in:
kailixu 2024-11-21 16:16:48 +08:00
parent ba15fb0644
commit 274e40b559
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tests/army/alter/alterConfig.py
View File

@ -113,6 +113,15 @@ class TDTestCase(TBase):
if not result: if not result:
raise Exception(f"key:{key} not found") raise Exception(f"key:{key} not found")
def checkRows(self, sql, nExpect, nRetry):
for i in range(nRetry):
res = tdSql.getResult(sql)
if len(res) == nExpect:
break
time.sleep(1)
if len(res) != nExpect:
raise Exception(f"rows:{len(res)} != {nExpect}")
def alterBypassFlag(self): def alterBypassFlag(self):
"""Add test case for altering bypassFlag(TD-32907) """Add test case for altering bypassFlag(TD-32907)
""" """
@ -151,8 +160,7 @@ class TDTestCase(TBase):
tdSql.query("select * from stb0") tdSql.query("select * from stb0")
tdSql.checkRows(2) tdSql.checkRows(2)
tdSql.execute("flush database db") tdSql.execute("flush database db")
tdSql.query("select * from stb0") self.checkRows("select * from stb0", 0, 10)
tdSql.checkRows(0)
tdSql.execute("alter all dnodes 'bypassFlag 0'") tdSql.execute("alter all dnodes 'bypassFlag 0'")
self.checkKeyValue(tdSql.getResult("show local variables"), "bypassFlag", "0") self.checkKeyValue(tdSql.getResult("show local variables"), "bypassFlag", "0")
self.checkKeyValue(tdSql.getResult("show dnode 1 variables like 'bypassFlag'"), "bypassFlag", "0", 1, 2) self.checkKeyValue(tdSql.getResult("show dnode 1 variables like 'bypassFlag'"), "bypassFlag", "0", 1, 2)
@ -161,8 +169,9 @@ class TDTestCase(TBase):
tdSql.query("select * from stb0") tdSql.query("select * from stb0")
tdSql.checkRows(2) tdSql.checkRows(2)
tdSql.execute("flush database db") tdSql.execute("flush database db")
tdSql.query("select * from stb0") for i in range(5):
tdSql.checkRows(2) self.checkRows("select * from stb0", 2, 1)
time.sleep(1)
# run # run
def run(self): def run(self):