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

modify upgrade script

Browse Source
This commit is contained in:
obdev 2024-12-16 20:46:19 +00:00 committed by ob-robot
parent cd154a7287
commit 528f282dc7
3 changed files with 21 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tools/upgrade/upgrade_checker.py
View File

@ -18,7 +18,7 @@ if sys.version_info.major == 3:
class UpgradeParams:
log_filename = 'upgrade_checker.log'
old_version = '4.0.0.0'
old_version = '4.2.5.1'
class PasswordMaskingFormatter(logging.Formatter):
def format(self, record):

31
tools/upgrade/upgrade_post.py
View File

@ -1667,7 +1667,7 @@
#
#class UpgradeParams:
# log_filename = 'upgrade_checker.log'
# old_version = '4.0.0.0'
# old_version = '4.2.5.1'
#
#class PasswordMaskingFormatter(logging.Formatter):
# def format(self, record):
@ -2547,26 +2547,15 @@
#
## 检查 direct_load 是否已经结束，开启升级之前需要确保没有 direct_load 任务，且升级期间尽量禁止 direct_load 任务
#def disable_and_check_direct_load_task(cur, query_cur):
# get_version_sql = """select distinct value from GV$OB_PARAMETERS where name='min_observer_version'"""
# (version_desc, version_results) = query_cur.exec_query(get_version_sql)
# if len(version_results) != 1:
# fail_list.append('min_observer_version is not sync')
# elif len(version_results[0]) != 1:
# fail_list.append('column cnt not match')
# else:
# min_cluster_version = get_version(version_results[0][0])
# if min_cluster_version < get_version("4.3.3.0"):
# # 通过配置项关闭 direct_load
# set_parameter(cur, '_ob_enable_direct_load', 'False')
# # 等待 5s，确保没有导入任务
# time.sleep(5)
# sql = """select count(1) from __all_virtual_load_data_stat"""
# (desc, results) = query_cur.exec_query(sql)
# if 0 != results[0][0]:
# fail_list.append("There are direct load task in progress")
# logging.info('check direct load task execut status success')
# else:
# logging.info('min cluster version is greater than 4.3.3, no need to disable and check direct load task')
# # 通过配置项关闭 direct_load
# set_parameter(cur, '_ob_enable_direct_load', 'False')
# # 等待 5s，确保没有导入任务
# time.sleep(5)
# sql = """select count(1) from __all_virtual_load_data_stat"""
# (desc, results) = query_cur.exec_query(sql)
# if 0 != results[0][0]:
# fail_list.append("There are direct load task in progress")
# logging.info('check direct load task execut status success')
#
## 检查cs_encoding格式是否兼容，对小于4.3.3版本的cpu不支持avx2指令集的集群，我们要求升级前schema上不存在cs_encoding的存储格式
## 注意：这里对混布集群 / schema上row_format进行了ddl变更的场景无法做到完全的防御

31
tools/upgrade/upgrade_pre.py
View File

@ -1667,7 +1667,7 @@
#
#class UpgradeParams:
# log_filename = 'upgrade_checker.log'
# old_version = '4.0.0.0'
# old_version = '4.2.5.1'
#
#class PasswordMaskingFormatter(logging.Formatter):
# def format(self, record):
@ -2547,26 +2547,15 @@
#
## 检查 direct_load 是否已经结束，开启升级之前需要确保没有 direct_load 任务，且升级期间尽量禁止 direct_load 任务
#def disable_and_check_direct_load_task(cur, query_cur):
# get_version_sql = """select distinct value from GV$OB_PARAMETERS where name='min_observer_version'"""
# (version_desc, version_results) = query_cur.exec_query(get_version_sql)
# if len(version_results) != 1:
# fail_list.append('min_observer_version is not sync')
# elif len(version_results[0]) != 1:
# fail_list.append('column cnt not match')
# else:
# min_cluster_version = get_version(version_results[0][0])
# if min_cluster_version < get_version("4.3.3.0"):
# # 通过配置项关闭 direct_load
# set_parameter(cur, '_ob_enable_direct_load', 'False')
# # 等待 5s，确保没有导入任务
# time.sleep(5)
# sql = """select count(1) from __all_virtual_load_data_stat"""
# (desc, results) = query_cur.exec_query(sql)
# if 0 != results[0][0]:
# fail_list.append("There are direct load task in progress")
# logging.info('check direct load task execut status success')
# else:
# logging.info('min cluster version is greater than 4.3.3, no need to disable and check direct load task')
# # 通过配置项关闭 direct_load
# set_parameter(cur, '_ob_enable_direct_load', 'False')
# # 等待 5s，确保没有导入任务
# time.sleep(5)
# sql = """select count(1) from __all_virtual_load_data_stat"""
# (desc, results) = query_cur.exec_query(sql)
# if 0 != results[0][0]:
# fail_list.append("There are direct load task in progress")
# logging.info('check direct load task execut status success')
#
## 检查cs_encoding格式是否兼容，对小于4.3.3版本的cpu不支持avx2指令集的集群，我们要求升级前schema上不存在cs_encoding的存储格式
## 注意：这里对混布集群 / schema上row_format进行了ddl变更的场景无法做到完全的防御