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

[CP] use optimizer_features_enable system variable and optimizer_features_enable hint to control optimizer behaviors

Browse Source
This commit is contained in:
obdev
2024-02-09 14:31:41 +00:00
committed by ob-robot
parent d1a8a16e05
commit c5a5b18553
17 changed files with 153 additions and 108 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/sql/session/ob_basic_session_info.cpp
View File

@ -3312,7 +3312,7 @@ int ObBasicSessionInfo::check_optimizer_features_enable_valid(const ObObj &val)
} else if (OB_FAIL(ObClusterVersion::get_version(version_str, version))) {
LOG_WARN("failed to get version");
LOG_USER_ERROR(OB_INVALID_ARGUMENT, "version for optimizer_features_enable");
} else if (version < CLUSTER_VERSION_4_0_0_0 || version > CLUSTER_CURRENT_VERSION) {
} else if (OB_UNLIKELY(!ObGlobalHint::is_valid_opt_features_version(version))) {
ret = OB_INVALID_ARGUMENT;
LOG_USER_ERROR(OB_INVALID_ARGUMENT, "version for optimizer_features_enable");
}
@ -5303,6 +5303,26 @@ int ObBasicSessionInfo::get_auto_increment_cache_size(int64_t &auto_increment_ca
return ret;
}
int ObBasicSessionInfo::get_optimizer_features_enable_version(uint64_t &version) const
{
int ret = OB_SUCCESS;
// if OPTIMIZER_FEATURES_ENABLE is set as '', use LASTED_COMPAT_VERSION
version = LASTED_COMPAT_VERSION;
ObString version_str;
uint64_t tmp_version = 0;
if (OB_FAIL(get_string_sys_var(SYS_VAR_OPTIMIZER_FEATURES_ENABLE, version_str))) {
LOG_WARN("failed to update session_timeout", K(ret));
} else if (version_str.empty()
|| OB_FAIL(ObClusterVersion::get_version(version_str, tmp_version))
|| !ObGlobalHint::is_valid_opt_features_version(tmp_version)) {
LOG_WARN("fail invalid optimizer features version", K(ret), K(version_str), K(tmp_version));
ret = OB_SUCCESS;
} else {
version = tmp_version;
}
return ret;
}
int ObBasicSessionInfo::get_enable_parallel_dml(bool &v) const
{
return get_bool_sys_var(SYS_VAR__ENABLE_PARALLEL_DML, v);