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

[CP] [to #57075306] [FEAT MERGE] 4_2_3_pl_dev merge review

Browse Source 
Co-authored-by: hanr881 <1741282579@qq.com>
Co-authored-by: seuwebber <webber_code@163.com>
Co-authored-by: LiuYoung00 <liuyanglo_ol@163.com>
This commit is contained in:
haohao022
2024-06-18 03:22:32 +00:00
committed by ob-robot
parent 806f88da98
commit eed6b5fd90
52 changed files with 1983 additions and 418 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
src/sql/engine/cmd/ob_variable_set_executor.cpp
View File

@ -327,25 +327,32 @@ int ObVariableSetExecutor::execute(ObExecContext &ctx, ObVariableSetStmt &stmt)
}
}
if (OB_SUCC(ret) && set_var.set_scope_ == ObSetVar::SET_SCOPE_GLOBAL) {
if(set_var.var_name_ == OB_SV_TIME_ZONE) {
if(OB_FAIL(global_variable_timezone_formalize(ctx, value_obj))) {
LOG_WARN("failed to formalize global variables", K(ret));
if(OB_SUCC(ret) && OB_FAIL(is_support(set_var))) {
if(ret == OB_NOT_SUPPORTED) {
ret = OB_SUCCESS;
LOG_USER_WARN(OB_NOT_SUPPORTED, "This system variable now is mock");
}
} else {
if (OB_SUCC(ret) && set_var.set_scope_ == ObSetVar::SET_SCOPE_GLOBAL) {
if(set_var.var_name_ == OB_SV_TIME_ZONE) {
if(OB_FAIL(global_variable_timezone_formalize(ctx, value_obj))) {
LOG_WARN("failed to formalize global variables", K(ret));
}
}
if (OB_SUCC(ret) && OB_FAIL(update_global_variables(ctx, stmt, set_var, value_obj))) {
LOG_WARN("failed to update global variables", K(ret));
} else { }
}
if (OB_SUCC(ret) && set_var.set_scope_ == ObSetVar::SET_SCOPE_SESSION) {
if (OB_FAIL(sys_var->session_update(ctx, set_var, value_obj))) {
LOG_WARN("fail to update", K(ret), K(*sys_var), K(set_var), K(value_obj));
}
}
if (OB_SUCC(ret) && OB_FAIL(update_global_variables(ctx, stmt, set_var, value_obj))) {
LOG_WARN("failed to update global variables", K(ret));
} else { }
}
if (OB_SUCC(ret) && set_var.set_scope_ == ObSetVar::SET_SCOPE_SESSION) {
if (OB_FAIL(sys_var->session_update(ctx, set_var, value_obj))) {
LOG_WARN("fail to update", K(ret), K(*sys_var), K(set_var), K(value_obj));
}
}
//某些变量需要立即更新状态
if (OB_SUCC(ret)) {
if (OB_FAIL(sys_var->update(ctx, set_var, value_obj))) {
LOG_WARN("update sys var state failed", K(ret), K(set_var));
//某些变量需要立即更新状态
if (OB_SUCC(ret)) {
if (OB_FAIL(sys_var->update(ctx, set_var, value_obj))) {
LOG_WARN("update sys var state failed", K(ret), K(set_var));
}
}
}
}
@ -1364,6 +1371,19 @@ int ObVariableSetExecutor::cascade_set_validate_password(ObExecContext &ctx,
return ret;
}
int ObVariableSetExecutor::is_support(const share::ObSetVar &set_var)
{
int ret = OB_SUCCESS;
ObSysVarClassType var_id = SYS_VAR_INVALID;
if(SYS_VAR_INVALID == (var_id = ObSysVarFactory::find_sys_var_id_by_name(set_var.var_name_))) {
ret = OB_ERR_SYS_VARIABLE_UNKNOWN;
LOG_WARN("unknown variable", K(set_var.var_name_), K(ret));
} else if (SYS_VAR_DEBUG <= var_id && SYS_VAR_STORED_PROGRAM_CACHE >= var_id) {
ret = OB_NOT_SUPPORTED;
LOG_WARN("This variable not support, just mock", K(set_var.var_name_), K(var_id), K(ret));
}
return ret;
}
#undef DEFINE_CAST_CTX
}/* ns sql*/