hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

modify upgrade checker

Browse Source
This commit is contained in:
obdev 2024-02-09 11:54:15 +00:00 committed by ob-robot
parent 4eae18cdb3
commit a6b7aef2a5
3 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tools/upgrade/upgrade_checker.py
View File

@ -428,6 +428,15 @@ def check_tenant_status(query_cur):
else:
logging.info('check tenant info success')
# check tenant lock status
(desc, results) = query_cur.exec_query("""select count(*) from DBA_OB_TENANTS where LOCKED = 'YES'""")
if len(results) != 1 or len(results[0]) != 1:
fail_list.append('results len not match')
elif 0 != results[0][0]:
fail_list.append('has locked tenant, should unlock')
else:
logging.info('check tenant lock status success')
# 6. 检查无恢复任务
def check_restore_job_exist(query_cur):
(desc, results) = query_cur.exec_query("""select count(1) from CDB_OB_RESTORE_PROGRESS""")

9
tools/upgrade/upgrade_post.py
View File

@ -2059,6 +2059,15 @@
# else:
# logging.info('check tenant info success')
#
# # check tenant lock status
# (desc, results) = query_cur.exec_query("""select count(*) from DBA_OB_TENANTS where LOCKED = 'YES'""")
# if len(results) != 1 or len(results[0]) != 1:
# fail_list.append('results len not match')
# elif 0 != results[0][0]:
# fail_list.append('has locked tenant, should unlock')
# else:
# logging.info('check tenant lock status success')
#
## 6. 检查无恢复任务
#def check_restore_job_exist(query_cur):
# (desc, results) = query_cur.exec_query("""select count(1) from CDB_OB_RESTORE_PROGRESS""")

9
tools/upgrade/upgrade_pre.py
View File

@ -2059,6 +2059,15 @@
# else:
# logging.info('check tenant info success')
#
# # check tenant lock status
# (desc, results) = query_cur.exec_query("""select count(*) from DBA_OB_TENANTS where LOCKED = 'YES'""")
# if len(results) != 1 or len(results[0]) != 1:
# fail_list.append('results len not match')
# elif 0 != results[0][0]:
# fail_list.append('has locked tenant, should unlock')
# else:
# logging.info('check tenant lock status success')
#
## 6. 检查无恢复任务
#def check_restore_job_exist(query_cur):
# (desc, results) = query_cur.exec_query("""select count(1) from CDB_OB_RESTORE_PROGRESS""")