test:add testcase of rolling upgdade
This commit is contained in:
parent
c5ac704b79
commit
447eb8197c
|
@ -260,27 +260,26 @@ class TDTestCase:
|
||||||
|
|
||||||
for tr in threads:
|
for tr in threads:
|
||||||
tr.join()
|
tr.join()
|
||||||
|
|
||||||
|
tdLog.printNoPrefix(f"==========step3:check dnode status ")
|
||||||
# wait 10s for taosd cluster ready
|
# wait 10s for taosd cluster ready
|
||||||
sleep(10)
|
sleep(10)
|
||||||
tdsql=tdCom.newTdSql()
|
tdsql=tdCom.newTdSql()
|
||||||
print(tdsql)
|
|
||||||
tdsql.query("select * from information_schema.ins_dnodes;")
|
tdsql.query("select * from information_schema.ins_dnodes;")
|
||||||
tdLog.info(tdsql.queryResult)
|
tdLog.info(tdsql.queryResult)
|
||||||
tdsql.checkData(2,1,'%s:6230'%self.host)
|
tdsql.checkData(2,1,'%s:6230'%self.host)
|
||||||
tdSql=tdCom.newTdSql()
|
|
||||||
print(tdSql)
|
|
||||||
clusterComCheck.checkDnodes(dnodeNumbers)
|
clusterComCheck.checkDnodes(dnodeNumbers)
|
||||||
|
|
||||||
tdsql1=tdCom.newTdSql()
|
tdsql1=tdCom.newTdSql()
|
||||||
print(tdsql1)
|
|
||||||
tdsql1.query(f"SELECT SERVER_VERSION();")
|
tdsql1.query(f"SELECT SERVER_VERSION();")
|
||||||
nowServerVersion=tdsql1.queryResult[0][0]
|
nowServerVersion=tdsql1.queryResult[0][0]
|
||||||
|
tdLog.printNoPrefix(f"==========step4:prepare and check data in new version-{nowServerVersion}")
|
||||||
|
|
||||||
tdLog.info(f"New server version is {nowServerVersion}")
|
tdLog.info(f"New server version is {nowServerVersion}")
|
||||||
tdsql1.query(f"SELECT CLIENT_VERSION();")
|
tdsql1.query(f"SELECT CLIENT_VERSION();")
|
||||||
nowClientVersion=tdsql1.queryResult[0][0]
|
nowClientVersion=tdsql1.queryResult[0][0]
|
||||||
tdLog.info(f"New client version is {nowClientVersion}")
|
tdLog.info(f"New client version is {nowClientVersion}")
|
||||||
|
|
||||||
tdLog.printNoPrefix(f"==========step3:prepare and check data in new version-{nowServerVersion}")
|
|
||||||
tdsql1.query(f"select count(*) from {stb}")
|
tdsql1.query(f"select count(*) from {stb}")
|
||||||
tdsql1.checkData(0,0,tableNumbers1*recordNumbers1)
|
tdsql1.checkData(0,0,tableNumbers1*recordNumbers1)
|
||||||
tdsql1.query(f"select count(*) from db4096.stb0")
|
tdsql1.query(f"select count(*) from db4096.stb0")
|
||||||
|
|
Loading…
Reference in New Issue