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

delete alias and fix bug on test_hot_refresh_configurations.py

This commit is contained in:
Leo Xu 2024-09-18 15:25:33 +08:00
parent 871352fcb1
commit 0b5ec9035a
1 changed files with 52 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

71
tests/system-test/0-others/test_hot_refresh_configurations.py
View File

@ -13,11 +13,12 @@ from util.common import *
class TDTestCase: class TDTestCase:
"""This test case is used to veirfy hot refresh configurations """This test case is used to veirfy hot refresh configurations
""" """
def init(self, conn, logSql, replicaVar=1): def init(self, conn, logSql, replicaVar=1):
self.replicaVar = int(replicaVar) self.replicaVar = int(replicaVar)
tdLog.debug(f"start to excute {__file__}") tdLog.debug(f"start to excute {__file__}")
tdSql.init(conn.cursor()) tdSql.init(conn.cursor())
self.configration_dic = { self.configration_dic = {
"cli": [ "cli": [
# { # {
@ -100,6 +101,7 @@ class TDTestCase:
"name": "minDiskFreeSize", "name": "minDiskFreeSize",
"alias": "tsMinDiskFreeSize", "alias": "tsMinDiskFreeSize",
"values": ["51200K", "100M", "1G"], "values": ["51200K", "100M", "1G"],
"check_values": ["52428800", "104857600", "1073741824"],
"except_values": ["1024K", "1.1G", "1T"] "except_values": ["1024K", "1.1G", "1T"]
}, },
{ {
@ -159,27 +161,52 @@ class TDTestCase:
] ]
} }
def get_param_value(self, config_name): def cli_get_param_value(self, config_name):
tdSql.query("show local variables;") tdSql.query("show local variables;")
for row in tdSql.queryResult: for row in tdSql.queryResult:
if config_name == row[0]: if config_name == row[0]:
tdLog.debug("Found variable '{}'".format(row[0])) tdLog.debug("Found variable '{}'".format(row[0]))
return row[1] return row[1]
def cli_check(self, name, values, except_values=False): def svr_get_param_value(self, config_name):
tdSql.query("show dnode 1 variables;")
for row in tdSql.queryResult:
if config_name == row[1]:
tdLog.debug("Found variable '{}'".format(row[1]))
return row[2]
def cli_check(self, item, except_values=False):
name = item["name"]
if except_values:
values = item["except_values"]
else:
values = item["values"]
check_values = item.get("check_values", [])
if not except_values: if not except_values:
for v in values: for i in range(len(values)):
v = values[i]
tdLog.debug("Set {} to {}".format(name, v)) tdLog.debug("Set {} to {}".format(name, v))
tdSql.execute(f'alter local "{name} {v}";') tdSql.execute(f'alter local "{name} {v}";')
value = self.get_param_value(name) value = self.cli_get_param_value(name)
tdLog.debug("Get {} value: {}".format(name, value)) tdLog.debug("Get {} value: {}".format(name, value))
assert(v == int(value)) if check_values:
tdLog.debug(f"assert {check_values[i]} == {str(value)}")
assert str(check_values[i]) == str(value)
else:
tdLog.debug(f"assert {v} == {str(value)}")
assert str(v) == str(value)
else: else:
for v in values: for v in values:
tdLog.debug("Set {} to {}".format(name, v)) tdLog.debug("Set {} to {}".format(name, v))
tdSql.error(f'alter local "{name} {v}";') tdSql.error(f'alter local "{name} {v}";')
def svr_check(self, name, alias, values, except_values=False): def svr_check(self, item, except_values=False):
name = item["name"]
if except_values:
values = item["except_values"]
else:
values = item["values"]
check_values = item.get("check_values", [])
p_list = ["dnode 1", "all dnodes"] p_list = ["dnode 1", "all dnodes"]
# check bool param value # check bool param value
if len(values) == 2 and [0, 1] == values and name != "queryRspPolicy": if len(values) == 2 and [0, 1] == values and name != "queryRspPolicy":
@ -188,13 +215,18 @@ class TDTestCase:
is_bool = False is_bool = False
tdLog.debug(f"{name} is_bool: {is_bool}") tdLog.debug(f"{name} is_bool: {is_bool}")
if not except_values: if not except_values:
for v in values: for i in range(len(values)):
v = values[i]
dnode = random.choice(p_list) dnode = random.choice(p_list)
tdSql.execute(f'alter {dnode} "{name} {v}";') tdSql.execute(f'alter {dnode} "{name} {v}";')
value = self.get_param_value(alias) value = self.svr_get_param_value(name)
if value: tdLog.debug(f"value: {value}")
tdLog.debug(f"value: {value}") if check_values:
assert(value == str(bool(v)).lower() if is_bool else str(v)) tdLog.debug(f"assert {check_values[i]} == {str(value)}")
assert str(check_values[i]) == str(value)
else:
tdLog.debug(f"assert {v} == {str(value)}")
assert str(v) == str(value)
else: else:
for v in values: for v in values:
dnode = random.choice(p_list) dnode = random.choice(p_list)
@ -205,28 +237,29 @@ class TDTestCase:
# reset log # reset log
taosdLogAbsoluteFilename = tdCom.getTaosdPath() + "/log/" + "taosdlog*" taosdLogAbsoluteFilename = tdCom.getTaosdPath() + "/log/" + "taosdlog*"
tdSql.execute("alter all dnodes 'resetlog';") tdSql.execute("alter all dnodes 'resetlog';")
r = subprocess.Popen("cat {} | grep 'reset log file'".format(taosdLogAbsoluteFilename), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) r = subprocess.Popen("cat {} | grep 'reset log file'".format(taosdLogAbsoluteFilename), shell=True,
stdout=subprocess.PIPE, stderr=subprocess.PIPE)
stdout, stderr = r.communicate() stdout, stderr = r.communicate()
assert('reset log file' in stdout.decode()) assert ('reset log file' in stdout.decode())
for key in self.configration_dic: for key in self.configration_dic:
if "cli" == key: if "cli" == key:
for item in self.configration_dic[key]: for item in self.configration_dic[key]:
self.cli_check(item["name"], item["values"]) self.cli_check(item)
if "except_values" in item: if "except_values" in item:
self.cli_check(item["name"], item["except_values"], True) self.cli_check(item, True)
elif "svr" == key: elif "svr" == key:
for item in self.configration_dic[key]: for item in self.configration_dic[key]:
self.svr_check(item["name"], item["alias"], item["values"]) self.svr_check(item)
if "except_values" in item: if "except_values" in item:
self.svr_check(item["name"], item["alias"], item["except_values"], True) self.svr_check(item, True)
else: else:
raise Exception(f"unknown key: {key}") raise Exception(f"unknown key: {key}")
def stop(self): def stop(self):
tdSql.close() tdSql.close()
tdLog.success(f"{__file__} successfully executed") tdLog.success(f"{__file__} successfully executed")
tdCases.addLinux(__file__, TDTestCase()) tdCases.addLinux(__file__, TDTestCase())
tdCases.addWindows(__file__, TDTestCase()) tdCases.addWindows(__file__, TDTestCase())