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

enh/TD-29974-improve-trans-fix-case

This commit is contained in:
dmchen 2024-12-17 10:00:33 +00:00
parent 2d29f5ac7d
commit 344c51fcc7
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/system-test/0-others/show_transaction_detail.py
View File

@ -68,25 +68,25 @@ class TDTestCase:
tdLog.info(f"show transaction {tranId2}, {oper2}") tdLog.info(f"show transaction {tranId2}, {oper2}")
rows = tdSql.query(f"show transaction {tranId1}", queryTimes=1) rows = tdSql.query(f"show transaction {tranId1}", queryTimes=1)
if rows != 160 and rows != 176: if rows != 120 and rows != 176:
tdLog.exit(f"restore transaction detial error, rows={rows}") tdLog.exit(f"show transaction detial error, rows={rows}")
return False return False
rows = tdSql.query(f"show transaction {tranId2}", queryTimes=1) rows = tdSql.query(f"show transaction {tranId2}", queryTimes=1)
if rows != 176 and rows != 160: if rows != 176 and rows != 120:
tdLog.exit(f"restore transaction detial error, rows={rows}") tdLog.exit(f"show transaction detial error, rows={rows}")
return False return False
tdLog.info(f"select * from ins_transaction_details") tdLog.info(f"select * from ins_transaction_details")
rows = tdSql.query(f"select * from information_schema.ins_transaction_details", queryTimes=1) rows = tdSql.query(f"select * from information_schema.ins_transaction_details", queryTimes=1)
if rows != 336: if rows != 296:
tdLog.exit(f"restore transaction detial error, rows={rows}") tdLog.exit(f"restore transaction detial error, rows={rows}")
return False return False
def createDbThread(self, sql, newTdSql): def createDbThread(self, sql, newTdSql):
tdLog.info("CREATE DATABASE db2 vgroups 160 replica 3;") tdLog.info("CREATE DATABASE db2 vgroups 40 replica 3;")
newTdSql.execute('CREATE DATABASE db2 vgroups 160 replica 3;', queryTimes=1) newTdSql.execute('CREATE DATABASE db2 vgroups 40 replica 3;', queryTimes=1)
def alterDbThread(self, sql, newTdSql): def alterDbThread(self, sql, newTdSql):
tdLog.info("alter DATABASE db1 replica 3;") tdLog.info("alter DATABASE db1 replica 3;")