modify upgrade scripts&&support system variables session_track_*
This commit is contained in:
jk0
LINxiansheng
parent
ed22c8dacd
commit
fa8b838450
@ -4,9 +4,9 @@ include(cmake/Utils.cmake)
|
||||
include(cmake/Env.cmake)
|
||||
|
||||
project("OceanBase CE"
|
||||
VERSION 3.1.1
|
||||
VERSION 3.1.2
|
||||
DESCRIPTION "OceanBase distributed database system"
|
||||
HOMEPAGE_URL "https://www.oceanbase.com/"
|
||||
HOMEPAGE_URL "https://open.oceanbase.com/"
|
||||
LANGUAGES CXX C ASM)
|
||||
|
||||
ob_define(WITH_OSS OFF)
|
||||
|
||||
@ -47,6 +47,15 @@ install(PROGRAMS
|
||||
|
||||
install(FILES
|
||||
tools/timezone/timezone_V1.log
|
||||
tools/upgrade/upgrade_pre.py
|
||||
tools/upgrade/upgrade_post.py
|
||||
tools/upgrade/upgrade_post_checker.py
|
||||
tools/upgrade/upgrade_checker.py
|
||||
tools/upgrade/upgrade_cluster_health_checker.py
|
||||
tools/upgrade/upgrade_rolling_pre.py
|
||||
tools/upgrade/upgrade_rolling_post.py
|
||||
tools/upgrade/priv_checker.py
|
||||
tools/upgrade/oceanbase_upgrade_dep.yml
|
||||
DESTINATION etc
|
||||
COMPONENT server)
|
||||
|
||||
|
||||
@ -93,11 +93,12 @@ uint64_t cal_version(const uint64_t major, const uint64_t minor, const uint64_t
|
||||
#define CLUSTER_VERSION_3000 (oceanbase::common::cal_version(3, 0, 0))
|
||||
#define CLUSTER_VERSION_3100 (oceanbase::common::cal_version(3, 1, 0))
|
||||
#define CLUSTER_VERSION_311 (oceanbase::common::cal_version(3, 1, 1))
|
||||
#define CLUSTER_VERSION_312 (oceanbase::common::cal_version(3, 1, 2))
|
||||
#define CLUSTER_VERSION_MAX UINT64_MAX
|
||||
// FIXME If you update the above version, please update me, CLUSTER_CURRENT_VERSION & ObUpgradeChecker!!!!!!
|
||||
|
||||
//!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
||||
#define CLUSTER_CURRENT_VERSION CLUSTER_VERSION_311
|
||||
#define CLUSTER_CURRENT_VERSION CLUSTER_VERSION_312
|
||||
#define GET_MIN_CLUSTER_VERSION() (oceanbase::common::ObClusterVersion::get_instance().get_cluster_version())
|
||||
#define GET_UNIS_CLUSTER_VERSION() (::oceanbase::lib::get_unis_compat_version() ?: GET_MIN_CLUSTER_VERSION())
|
||||
|
||||
|
||||
@ -30,39 +30,8 @@ using namespace rootserver;
|
||||
namespace share {
|
||||
#define CALC_CLUSTER_VERSION(major, minor, patch) (((major) << 32) + ((minor) << 16) + (patch))
|
||||
const uint64_t ObUpgradeChecker::UPGRADE_PATH[CLUTER_VERSION_NUM] = {
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 3UL), // 1.4.3
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 40UL), // 1.4.40
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 50UL), // 1.4.50
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 51UL), // 1.4.51
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 60UL), // 1.4.60
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 61UL), // 1.4.61
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 70UL), // 1.4.70
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 71UL), // 1.4.71
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 72UL), // 1.4.72
|
||||
CALC_CLUSTER_VERSION(1UL, 4UL, 76UL), // 1.4.76
|
||||
CALC_CLUSTER_VERSION(2UL, 0UL, 0UL), // 2.0.0
|
||||
CALC_CLUSTER_VERSION(2UL, 1UL, 0UL), // 2.1.0
|
||||
CALC_CLUSTER_VERSION(2UL, 1UL, 1UL), // 2.1.1
|
||||
CALC_CLUSTER_VERSION(2UL, 1UL, 11UL), // 2.1.11
|
||||
CALC_CLUSTER_VERSION(2UL, 1UL, 20UL), // 2.1.20
|
||||
CALC_CLUSTER_VERSION(2UL, 1UL, 30UL), // 2.1.30
|
||||
CALC_CLUSTER_VERSION(2UL, 1UL, 31UL), // 2.1.31
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 0UL), // 2.2.0
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 1UL), // 2.2.1
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 20UL), // 2.2.20
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 30UL), // 2.2.30
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 40UL), // 2.2.40
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 50UL), // 2.2.50
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 60UL), // 2.2.60
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 70UL), // 2.2.70
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 71UL), // 2.2.71
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 72UL), // 2.2.72
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 73UL), // 2.2.73
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 74UL), // 2.2.74
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 75UL), // 2.2.75
|
||||
CALC_CLUSTER_VERSION(2UL, 2UL, 76UL), // 2.2.76
|
||||
CALC_CLUSTER_VERSION(3UL, 1UL, 0UL), // 3.1.0
|
||||
CALC_CLUSTER_VERSION(3UL, 1UL, 1UL) //3.1.1
|
||||
CALC_CLUSTER_VERSION(3UL, 1UL, 1UL), //3.1.1
|
||||
CALC_CLUSTER_VERSION(3UL, 1UL, 2UL) //3.1.2
|
||||
};
|
||||
|
||||
bool ObUpgradeChecker::check_cluster_version_exist(const uint64_t version)
|
||||
@ -1117,16 +1086,8 @@ int ObUpgradeProcesserSet::init(ObBaseUpgradeProcessor::UpgradeMode mode, common
|
||||
} \
|
||||
}
|
||||
// order by cluster version asc
|
||||
INIT_PROCESSOR_BY_VERSION(2, 2, 60);
|
||||
INIT_PROCESSOR_BY_VERSION(2, 2, 70);
|
||||
INIT_PROCESSOR_BY_VERSION(2, 2, 71);
|
||||
INIT_PROCESSOR_BY_VERSION(2, 2, 72);
|
||||
INIT_PROCESSOR_BY_VERSION(2, 2, 73);
|
||||
INIT_PROCESSOR_BY_VERSION(2, 2, 74);
|
||||
INIT_PROCESSOR_BY_VERSION(2, 2, 75);
|
||||
INIT_PROCESSOR_BY_VERSION(2, 2, 76);
|
||||
INIT_PROCESSOR_BY_VERSION(3, 1, 0);
|
||||
INIT_PROCESSOR_BY_VERSION(3, 1, 1);
|
||||
INIT_PROCESSOR_BY_VERSION(3, 1, 2);
|
||||
#undef INIT_PROCESSOR_BY_VERSION
|
||||
inited_ = true;
|
||||
}
|
||||
|
||||
@ -181,7 +181,7 @@ public:
|
||||
static bool check_cluster_version_exist(const uint64_t version);
|
||||
|
||||
public:
|
||||
static const int64_t CLUTER_VERSION_NUM = 33;
|
||||
static const int64_t CLUTER_VERSION_NUM = 2;
|
||||
static const uint64_t UPGRADE_PATH[CLUTER_VERSION_NUM];
|
||||
};
|
||||
|
||||
@ -231,6 +231,7 @@ DEF_SIMPLE_UPGRARD_PROCESSER(2, 2, 76);
|
||||
// 3.1.0
|
||||
DEF_SIMPLE_UPGRARD_PROCESSER(3, 1, 0);
|
||||
DEF_SIMPLE_UPGRARD_PROCESSER(3, 1, 1);
|
||||
DEF_SIMPLE_UPGRARD_PROCESSER(3, 1, 2);
|
||||
|
||||
/* =========== upgrade processor end ============= */
|
||||
|
||||
|
||||
@ -275,7 +275,6 @@ DEF_BOOL(_enable_static_typing_engine, OB_CLUSTER_PARAMETER, "True",
|
||||
"specifies whether static typing sql execution engine is activated",
|
||||
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
||||
|
||||
// https://yuque.antfin-inc.com/ob/product_functionality_review/zlp56c
|
||||
DEF_BOOL(_enable_defensive_check, OB_CLUSTER_PARAMETER, "True",
|
||||
"specifies whether allow to do some defensive checks when the query is executed",
|
||||
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
||||
@ -519,7 +518,7 @@ DEF_TIME(get_leader_candidate_rpc_timeout, OB_CLUSTER_PARAMETER, "9s", "[2s, 180
|
||||
"the time during a get leader candidate rpc request "
|
||||
"is permitted to execute before it is terminated. Range: [2s, 180s]",
|
||||
ObParameterAttr(Section::ROOT_SERVICE, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
||||
DEF_STR(min_observer_version, OB_CLUSTER_PARAMETER, "3.1.1", "the min observer version",
|
||||
DEF_STR(min_observer_version, OB_CLUSTER_PARAMETER, "3.1.2", "the min observer version",
|
||||
ObParameterAttr(Section::ROOT_SERVICE, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
|
||||
DEF_BOOL(enable_ddl, OB_CLUSTER_PARAMETER, "True",
|
||||
"specifies whether DDL operation is turned on. "
|
||||
|
||||
999
src/share/system_variable/gen_ob_sys_variables.py
Executable file
999
src/share/system_variable/gen_ob_sys_variables.py
Executable file
@ -0,0 +1,999 @@
|
||||
#!/usr/bin/env python
|
||||
# -*- coding: utf-8 -*-
|
||||
import json
|
||||
import os
|
||||
import stat
|
||||
import shutil
|
||||
import sys
|
||||
|
||||
VARCHAR = "varchar"
|
||||
INT = "int"
|
||||
UINT = "uint"
|
||||
TINY = "tinyint"
|
||||
BOOL = "bool"
|
||||
NUMERIC = "numeric"
|
||||
ENUM = "enum"
|
||||
|
||||
# `ob_max_sys_var_id`表示当前版本预分配的可以使用的system var id的最大值，
|
||||
# 系统会根据ob_max_sys_var_id的值预分配sys var id -> sys var的映射数组，不能将其随意调大，
|
||||
# 如果需要分配的系统变量的sys var id必须大于`ob_max_sys_var_id`，需要将`ob_max_sys_var_id`调大
|
||||
ob_max_sys_var_id = 20000
|
||||
|
||||
flag_dict = {}
|
||||
flag_dict["GLOBAL"] = "GLOBAL_SCOPE"
|
||||
flag_dict["SESSION"] = "SESSION_SCOPE"
|
||||
flag_dict["READONLY"] = "READONLY"
|
||||
flag_dict["READ"] = "READONLY"
|
||||
flag_dict["SESSION_READONLY"] = "SESSION_READONLY"
|
||||
flag_dict["INVISIBLE"] = "INVISIBLE"
|
||||
flag_dict["NULL"] = "NULLABLE"
|
||||
flag_dict["NULLABLE"] = "NULLABLE"
|
||||
flag_dict["INFLUENCE_PLAN"] = "INFLUENCE_PLAN"
|
||||
flag_dict["NEED_SERIALIZE"] = "NEED_SERIALIZE"
|
||||
flag_dict["QUERY_SENSITIVE"] = "QUERY_SENSITIVE"
|
||||
flag_dict["ORACLE_ONLY"] = "ORACLE_ONLY"
|
||||
flag_dict["WITH_CREATE"] = "WITH_CREATE"
|
||||
flag_dict["WITH_UPGRADE"] = "WITH_UPGRADE"
|
||||
flag_dict["MYSQL_ONLY"] = "MYSQL_ONLY"
|
||||
|
||||
flag_value_dict = {}
|
||||
flag_value_dict["GLOBAL"] = 1L
|
||||
flag_value_dict["SESSION"] = (1L << 1)
|
||||
flag_value_dict["READONLY"] = (1L << 2)
|
||||
flag_value_dict["SESSION_READONLY"] = (1L << 3)
|
||||
flag_value_dict["INVISIBLE"] = (1L << 4)
|
||||
flag_value_dict["NULL"] = (1L << 5)
|
||||
flag_value_dict["NULLABLE"] = (1L << 5)
|
||||
flag_value_dict["INFLUENCE_PLAN"] = (1L << 6)
|
||||
flag_value_dict["NEED_SERIALIZE"] = (1L << 7)
|
||||
flag_value_dict["QUERY_SENSITIVE"] = (1L << 8)
|
||||
flag_value_dict["ORACLE_ONLY"] = (1L << 9)
|
||||
flag_value_dict["WITH_CREATE"] = (1L << 10)
|
||||
flag_value_dict["WITH_UPGRADE"] = (1L << 11)
|
||||
flag_value_dict["MYSQL_ONLY"] = (1L << 12)
|
||||
|
||||
type_dict = {}
|
||||
type_dict["tinyint"] = "ObTinyIntType"
|
||||
type_dict["int"] = "ObIntType"
|
||||
type_dict["uint"] = "ObUInt64Type"
|
||||
type_dict["numeric"] = "ObNumberType"
|
||||
type_dict["varchar"] = "ObVarcharType"
|
||||
type_dict["bool"] = "ObIntType" # FIXME: tinyint?
|
||||
type_dict["enum"] = "ObIntType"
|
||||
|
||||
# 这个映射是建立在ObObjType的值不改变的前提的，如果ObObjType的值改变，这里也要跟着改
|
||||
type_value_dict = {}
|
||||
type_value_dict["tinyint"] = 1
|
||||
type_value_dict["int"] = 5
|
||||
type_value_dict["uint"] = 10
|
||||
type_value_dict["numeric"] = 15
|
||||
type_value_dict["varchar"] = 22
|
||||
type_value_dict["bool"] = 5 # FIXME: tinyint?
|
||||
type_value_dict["enum"] = 5
|
||||
|
||||
required_attrs = ["publish_version", "info_cn", "background_cn", "ref_url"]
|
||||
ignored_attrs = ["publish_version", "info_cn", "background_cn", "ref_url"]
|
||||
|
||||
file_head_annotation = """
|
||||
/**
|
||||
* Copyright (c) 2021 OceanBase
|
||||
* OceanBase CE is licensed under Mulan PubL v2.
|
||||
* You can use this software according to the terms and conditions of the Mulan PubL v2.
|
||||
* You may obtain a copy of Mulan PubL v2 at:
|
||||
* http://license.coscl.org.cn/MulanPubL-2.0
|
||||
* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
|
||||
* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
|
||||
* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
|
||||
* See the Mulan PubL v2 for more details.
|
||||
*/
|
||||
|
||||
"""
|
||||
|
||||
def parse_json(json_file_name):
|
||||
json_file = open(json_file_name,'r')
|
||||
all_the_vars = json_file.read( )
|
||||
json_Dict = json.loads(all_the_vars)
|
||||
list_sorted_by_name= sorted(json_Dict.iteritems(), key=lambda d:d[0])
|
||||
list_sorted_by_id= sorted(json_Dict.iteritems(), key=lambda d:d[1]['id'])
|
||||
json_file.close()
|
||||
return (json_Dict, list_sorted_by_name, list_sorted_by_id)
|
||||
|
||||
def make_alias_file(pdir, alias_file_name, sorted_list):
|
||||
alias_file =open(alias_file_name,'w')
|
||||
alias_file.write(file_head_annotation);
|
||||
alias_file.write("""
|
||||
/* 此处定义所有系统变量的名字。初始化@see ob_ddl_operation.cpp和ob_basic_session_info.cpp
|
||||
* @note: 所有OB特有的非mysql的系统变量，都以ob_开头，以区别于mysql系统变量的名字空间。
|
||||
* 反之，所有不以ob_开头的系统变量都必须和mysql语义完全兼容。 */
|
||||
|
||||
""")
|
||||
suffix_idx = alias_file_name.find(".h")
|
||||
file_def_str = "OCEANBASE_" + pdir.replace("/", "_").upper() + "_" + alias_file_name[0 : suffix_idx].upper() + "_"
|
||||
alias_file.write("#ifndef " + file_def_str + "\n");
|
||||
alias_file.write("#define " + file_def_str + "\n");
|
||||
alias_file.write("namespace oceanbase\n");
|
||||
alias_file.write("{\n");
|
||||
alias_file.write("namespace share\n");
|
||||
alias_file.write("{\n");
|
||||
for (name,attributes) in sorted_list:
|
||||
alias = attributes['name']
|
||||
alias_prefix = alias[0:3]
|
||||
if alias_prefix == str("ob_"):
|
||||
alias = alias[3:]
|
||||
alias_upper = alias.upper()
|
||||
out = " static const char* const OB_SV_" + str(alias_upper) + " = \"" + str(name) + "\";\n"
|
||||
alias_file.write(out)
|
||||
|
||||
alias_file.write("\n");
|
||||
alias_file.write("}\n");
|
||||
alias_file.write("}\n");
|
||||
alias_file.write("#endif //OCEANBASE_COMMON_OB_SYSTEM_VARIABLE_ALIAS_H_\n");
|
||||
alias_file.write("\n");
|
||||
|
||||
alias_file.close()
|
||||
print("Generate " + str(alias_file_name) + " successfully!\n");
|
||||
return
|
||||
|
||||
def make_head_file(pdir, head_file_name, sorted_list):
|
||||
head_file = open(head_file_name,'w')
|
||||
head_file.write(file_head_annotation);
|
||||
suffix_idx = head_file_name.find(".h")
|
||||
file_def_str = "OCEANBASE_" + pdir.replace("/", "_").upper() + "_" + head_file_name[0 : suffix_idx].upper() + "_"
|
||||
head_file.write("#ifndef " + file_def_str + "\n");
|
||||
head_file.write("#define " + file_def_str + "\n");
|
||||
head_file.write("#include \"share/system_variable/ob_sys_var_class_type.h\"\n");
|
||||
head_file.write("#include <stdint.h>\n");
|
||||
head_file.write("#include \"common/object/ob_object.h\"\n");
|
||||
head_file.write("namespace oceanbase\n");
|
||||
head_file.write("{\n");
|
||||
head_file.write("namespace share\n");
|
||||
head_file.write("{\n");
|
||||
head_file.write("// ObSysVarFlag的值不可随意增删改, 有任何增删改要同时同步到sql/session/gen_ob_sys_variables.py的flag_value_dict变量中\n");
|
||||
head_file.write("struct ObSysVarFlag\n");
|
||||
head_file.write("{\n");
|
||||
head_file.write(" const static int64_t NONE = 0LL;\n");
|
||||
head_file.write(" const static int64_t GLOBAL_SCOPE = 1LL;\n");
|
||||
head_file.write(" const static int64_t SESSION_SCOPE = (1LL << 1);\n");
|
||||
head_file.write(" const static int64_t READONLY = (1LL << 2);\n");
|
||||
head_file.write(" const static int64_t SESSION_READONLY = (1LL << 3);\n");
|
||||
head_file.write(" const static int64_t INVISIBLE = (1LL << 4);\n");
|
||||
head_file.write(" const static int64_t NULLABLE = (1LL << 5);\n");
|
||||
head_file.write(" const static int64_t INFLUENCE_PLAN = (1LL << 6);\n");
|
||||
head_file.write(" const static int64_t NEED_SERIALIZE = (1LL << 7);\n");
|
||||
head_file.write(" const static int64_t QUERY_SENSITIVE = (1LL << 8);\n");
|
||||
head_file.write(" const static int64_t ORACLE_ONLY = (1LL << 9);\n");
|
||||
head_file.write(" const static int64_t WITH_CREATE = (1LL << 10);\n");
|
||||
head_file.write(" const static int64_t WITH_UPGRADE = (1LL << 11);\n");
|
||||
head_file.write(" const static int64_t MYSQL_ONLY = (1LL << 12);\n");
|
||||
head_file.write("};\n");
|
||||
head_file.write("struct ObSysVarFromJson{\n");
|
||||
head_file.write(" ObSysVarClassType id_;\n");
|
||||
head_file.write(" common::ObString name_;\n");
|
||||
head_file.write(" common::ObObjType data_type_;\n");
|
||||
head_file.write(" common::ObString value_;\n");
|
||||
head_file.write(" common::ObString min_val_;\n");
|
||||
head_file.write(" common::ObString max_val_;\n");
|
||||
head_file.write(" common::ObString enum_names_;\n");
|
||||
head_file.write(" common::ObString info_;\n");
|
||||
head_file.write(" int64_t flags_;\n");
|
||||
head_file.write(" common::ObString alias_;\n");
|
||||
head_file.write(" common::ObString base_class_;\n");
|
||||
head_file.write(" common::ObString on_check_and_convert_func_;\n");
|
||||
head_file.write(" common::ObString on_update_func_;\n");
|
||||
head_file.write(" common::ObString to_select_obj_func_;\n");
|
||||
head_file.write(" common::ObString to_show_str_func_;\n");
|
||||
head_file.write(" common::ObString get_meta_type_func_;\n");
|
||||
head_file.write(" common::ObString session_special_update_func_;\n");
|
||||
head_file.write("\n");
|
||||
head_file.write(" ObSysVarFromJson():id_(SYS_VAR_INVALID), name_(\"\"), data_type_(common::ObNullType), value_(\"\"), min_val_(\"\"), max_val_(\"\"), enum_names_(\"\"), info_(\"\"), flags_(ObSysVarFlag::NONE), alias_(\"\"), base_class_(\"\"), on_check_and_convert_func_(""), on_update_func_(""), to_select_obj_func_(""), to_show_str_func_(""), get_meta_type_func_(""), session_special_update_func_("") {}\n");
|
||||
head_file.write("};\n");
|
||||
head_file.write("\n");
|
||||
head_file.write("class ObSysVariables\n");
|
||||
head_file.write("{\n");
|
||||
head_file.write("public:\n");
|
||||
head_file.write(" static int64_t get_all_sys_var_count();\n");
|
||||
head_file.write(" static ObSysVarClassType get_sys_var_id(int64_t i);\n");
|
||||
head_file.write(" static common::ObString get_name(int64_t i);\n");
|
||||
head_file.write(" static common::ObObjType get_type(int64_t i);\n");
|
||||
head_file.write(" static common::ObString get_value(int64_t i);\n");
|
||||
head_file.write(" static common::ObString get_min(int64_t i);\n");
|
||||
head_file.write(" static common::ObString get_max(int64_t i);\n");
|
||||
head_file.write(" static common::ObString get_info(int64_t i);\n");
|
||||
head_file.write(" static int64_t get_flags(int64_t i);\n");
|
||||
head_file.write(" static bool need_serialize(int64_t i);\n");
|
||||
head_file.write(" static bool is_oracle_only(int64_t i);\n");
|
||||
head_file.write(" static bool is_mysql_only(int64_t i);\n");
|
||||
head_file.write(" static common::ObString get_alias(int64_t i);\n");
|
||||
head_file.write(" static const common::ObObj &get_default_value(int64_t i);\n")
|
||||
head_file.write(" static int64_t get_amount();\n");
|
||||
head_file.write(" static int set_value(const char *name, const char * new_value);\n");
|
||||
head_file.write(" static int set_value(const common::ObString &name, const common::ObString &new_value);\n");
|
||||
head_file.write(" static int init_default_values();\n");
|
||||
head_file.write("};\n");
|
||||
head_file.write("\n");
|
||||
head_file.write("class ObSysVarsToIdxMap\n");
|
||||
head_file.write("{\n");
|
||||
head_file.write("public:\n");
|
||||
head_file.write(" static int64_t get_store_idx(int64_t var_id);\n");
|
||||
head_file.write(" static bool has_invalid_sys_var_id();\n");
|
||||
head_file.write("};\n");
|
||||
|
||||
head_file.write("\n");
|
||||
head_file.write("} // end namespace share\n");
|
||||
head_file.write("} // end namespace oceanbase\n");
|
||||
head_file.write("\n");
|
||||
head_file.write("#endif /* " + file_def_str + " */\n");
|
||||
|
||||
head_file.close( )
|
||||
print("Generate " + str(head_file_name) + " successfully!\n");
|
||||
return
|
||||
|
||||
def make_flags_value(flags):
|
||||
value = ""
|
||||
flags = flags.split("|")
|
||||
for i in range(0, len(flags)):
|
||||
value += ("ObSysVarFlag::" + flag_dict[flags[i].strip().upper()])
|
||||
if (i != len(flags) - 1):
|
||||
value += " | "
|
||||
return value
|
||||
|
||||
def make_type_value(type):
|
||||
return type_dict[type.strip()]
|
||||
|
||||
def make_cpp_file(pdir, cpp_file_name, sorted_list):
|
||||
cpp_file = open(cpp_file_name,'w')
|
||||
cpp_file.write(file_head_annotation)
|
||||
cpp_file.write("#define USING_LOG_PREFIX SHARE\n")
|
||||
cpp_file.write("#include \"" + pdir + "/" + cpp_file_name.replace(".cpp", ".h") + "\"\n")
|
||||
cpp_file.write("#include \"share/system_variable/ob_system_variable_factory.h\"\n")
|
||||
cpp_file.write("#include \"share/object/ob_obj_cast.h\"\n")
|
||||
cpp_file.write("#include \"common/expression/ob_expr_string_buf.h\"\n")
|
||||
cpp_file.write("#include \"common/expression/ob_expr_string_buf.h\"\n")
|
||||
cpp_file.write("using namespace oceanbase::common;\n");
|
||||
cpp_file.write("\n")
|
||||
cpp_file.write("namespace oceanbase\n");
|
||||
cpp_file.write("{\n");
|
||||
cpp_file.write("namespace share\n");
|
||||
cpp_file.write("{\n");
|
||||
cpp_file.write("static ObSysVarFromJson ObSysVars[ObSysVarFactory::ALL_SYS_VARS_COUNT];\n")
|
||||
cpp_file.write("static ObObj ObSysVarDefaultValues[ObSysVarFactory::ALL_SYS_VARS_COUNT];\n")
|
||||
cpp_file.write("static ObArenaAllocator ObSysVarAllocator(ObModIds::OB_COMMON_SYS_VAR_DEFAULT_VALUE);\n")
|
||||
cpp_file.write("static int64_t ObSysVarsIdToArrayIdx[ObSysVarFactory::OB_MAX_SYS_VAR_ID];\n")
|
||||
cpp_file.write("// VarsInit中需要判断当前最大的SysVars对应的id，是否大于OB_MAX_SYS_VAR_ID\n")
|
||||
cpp_file.write("// 如果大于OB_MAX_SYS_VAR_ID表示存在无效的SysVarsId\n")
|
||||
cpp_file.write("static bool HasInvalidSysVar = false;\n")
|
||||
|
||||
cpp_file.write("\n")
|
||||
cpp_file.write("static struct VarsInit{\n")
|
||||
cpp_file.write(" VarsInit(){\n")
|
||||
|
||||
var_num = 0
|
||||
cpp_file.write(" // 保存当前系统变量的最大的id\n")
|
||||
cpp_file.write(" int64_t cur_max_var_id = 0;\n")
|
||||
cpp_file.write(" // ObSysVarsIdToArrayIdx数组默认初始值为-1，-1表示无效索引\n")
|
||||
cpp_file.write(" memset(ObSysVarsIdToArrayIdx, -1, sizeof(ObSysVarsIdToArrayIdx));\n")
|
||||
for (name,attributes) in sorted_list:
|
||||
for required_attr in required_attrs:
|
||||
if required_attr not in attributes:
|
||||
sys.exit("attribute '" + str(required_attr) + "' is required for item '" + str(name) + "'")
|
||||
for (attribute_key, attribute_value) in attributes.items():
|
||||
if attribute_value == " ":
|
||||
attribute_value = str("")
|
||||
if attribute_key in ignored_attrs:
|
||||
continue
|
||||
elif attribute_key == "id":
|
||||
out = " ObSysVars[" + str(var_num) + "]." + str(attribute_key) + "_ = SYS_VAR_" + str(name).upper() + " ;\n"
|
||||
elif attribute_key == "flags":
|
||||
out = " ObSysVars[" + str(var_num) + "]." + str(attribute_key) + "_ = " + make_flags_value(attribute_value) + " ;\n"
|
||||
elif attribute_key == "data_type":
|
||||
out = " ObSysVars[" + str(var_num) + "]." + str(attribute_key) + "_ = " + make_type_value(attribute_value) + " ;\n"
|
||||
else:
|
||||
out = " ObSysVars[" + str(var_num) + "]." + str(attribute_key) + "_ = \"" + str(attribute_value) + "\" ;\n"
|
||||
cpp_file.write(out)
|
||||
if attribute_key == "id":
|
||||
out = " cur_max_var_id = MAX(cur_max_var_id, "+"static_cast<int64_t>(SYS_VAR_" + str(name).upper()+")"+") ;\n"
|
||||
cpp_file.write(out)
|
||||
out = " ObSysVarsIdToArrayIdx[" + "SYS_VAR_" + str(name).upper() + "] = " + str(var_num) + " ;\n"
|
||||
cpp_file.write(out)
|
||||
alias = attributes['name']
|
||||
alias_prefix = alias[0:3]
|
||||
if alias_prefix == str("ob_"):
|
||||
alias = alias[3:]
|
||||
alias_upper = alias.upper()
|
||||
out = " ObSysVars[" + str(var_num) + "].alias_ = \"OB_SV_" + str(alias_upper) + "\" ;\n"
|
||||
cpp_file.write(out)
|
||||
cpp_file.write("\n")
|
||||
var_num += 1
|
||||
|
||||
cpp_file.write(" if (cur_max_var_id >= ObSysVarFactory::OB_MAX_SYS_VAR_ID) { \n")
|
||||
cpp_file.write(" HasInvalidSysVar = true;\n")
|
||||
cpp_file.write(" }\n")
|
||||
cpp_file.write(" }\n")
|
||||
cpp_file.write("}vars_init;\n")
|
||||
cpp_file.write("\n")
|
||||
cpp_file.write("static int64_t var_amount = " + str(var_num) + ";" + "\n")
|
||||
cpp_file.write("\n")
|
||||
cpp_file.write("int64_t ObSysVariables::get_all_sys_var_count(){ return ObSysVarFactory::ALL_SYS_VARS_COUNT;}\n")
|
||||
cpp_file.write("ObSysVarClassType ObSysVariables::get_sys_var_id(int64_t i){ return ObSysVars[i].id_;}\n")
|
||||
cpp_file.write("ObString ObSysVariables::get_name(int64_t i){ return ObSysVars[i].name_;}\n")
|
||||
cpp_file.write("ObObjType ObSysVariables::get_type(int64_t i){ return ObSysVars[i].data_type_;}\n")
|
||||
cpp_file.write("ObString ObSysVariables::get_value(int64_t i){ return ObSysVars[i].value_;}\n")
|
||||
cpp_file.write("ObString ObSysVariables::get_min(int64_t i){ return ObSysVars[i].min_val_;}\n")
|
||||
cpp_file.write("ObString ObSysVariables::get_max(int64_t i){ return ObSysVars[i].max_val_;}\n")
|
||||
cpp_file.write("ObString ObSysVariables::get_info(int64_t i){ return ObSysVars[i].info_;}\n")
|
||||
cpp_file.write("int64_t ObSysVariables::get_flags(int64_t i){ return ObSysVars[i].flags_;}\n")
|
||||
cpp_file.write("bool ObSysVariables::need_serialize(int64_t i){ return ObSysVars[i].flags_ & ObSysVarFlag::NEED_SERIALIZE;}\n")
|
||||
cpp_file.write("bool ObSysVariables::is_oracle_only(int64_t i){ return ObSysVars[i].flags_ & ObSysVarFlag::ORACLE_ONLY;}\n")
|
||||
cpp_file.write("bool ObSysVariables::is_mysql_only(int64_t i){ return ObSysVars[i].flags_ & ObSysVarFlag::MYSQL_ONLY;}\n")
|
||||
cpp_file.write("ObString ObSysVariables::get_alias(int64_t i){ return ObSysVars[i].alias_;}\n")
|
||||
cpp_file.write("const ObObj &ObSysVariables::get_default_value(int64_t i){ return ObSysVarDefaultValues[i];}\n")
|
||||
cpp_file.write("int64_t ObSysVariables::get_amount(){ return var_amount;}\n")
|
||||
cpp_file.write("\n")
|
||||
cpp_file.write("int ObSysVariables::set_value(const char *name, const char * new_value)\n")
|
||||
cpp_file.write("{\n")
|
||||
cpp_file.write(" ObString tmp_name(static_cast<int32_t>(strlen(name)), name);\n")
|
||||
cpp_file.write(" ObString tmp_value(static_cast<int32_t>(strlen(new_value)), new_value);\n")
|
||||
cpp_file.write(" return set_value(tmp_name, tmp_value);\n")
|
||||
cpp_file.write("}\n")
|
||||
cpp_file.write("int ObSysVariables::set_value(const common::ObString &name, const common::ObString &new_value)\n")
|
||||
cpp_file.write("{\n")
|
||||
cpp_file.write(" int ret = OB_SUCCESS;\n")
|
||||
cpp_file.write(" bool name_exist = false;\n")
|
||||
cpp_file.write(" for (int64_t i = 0; OB_SUCC(ret) && false == name_exist && i < var_amount; ++i){\n")
|
||||
cpp_file.write(" if (0 == ObSysVars[i].name_.compare(name)) {\n")
|
||||
cpp_file.write(" ObSysVars[i].value_.assign_ptr(new_value.ptr(), new_value.length());\n")
|
||||
cpp_file.write(" name_exist = true;\n")
|
||||
cpp_file.write(" }\n")
|
||||
cpp_file.write(" }\n")
|
||||
cpp_file.write(" if (OB_SUCC(ret)) {\n")
|
||||
cpp_file.write(" if (false == name_exist) {\n")
|
||||
cpp_file.write(" ret = OB_ENTRY_NOT_EXIST;\n")
|
||||
cpp_file.write(" }\n")
|
||||
cpp_file.write(" }\n")
|
||||
cpp_file.write(" return ret;\n")
|
||||
cpp_file.write("}\n")
|
||||
cpp_file.write("""
|
||||
int ObSysVariables::init_default_values()
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
int64_t sys_var_count = get_amount();
|
||||
for (int64_t i = 0; OB_SUCC(ret) && i < sys_var_count; ++i) {
|
||||
const ObString &sys_var_val_str = ObSysVariables::get_value(i);
|
||||
const ObObjType sys_var_type = ObSysVariables::get_type(i);
|
||||
if (OB_UNLIKELY(sys_var_type == ObTimestampType)) {
|
||||
ret = OB_ERR_UNEXPECTED;
|
||||
LOG_ERROR("need tz_info when cast to timestamp", K(ret), K(sys_var_val_str));
|
||||
} else {
|
||||
ObObj in_obj;
|
||||
ObObj out_obj;
|
||||
in_obj.set_varchar(sys_var_val_str);
|
||||
in_obj.set_collation_type(CS_TYPE_UTF8MB4_GENERAL_CI);
|
||||
//varchar to others. so, no need to get collation from session
|
||||
ObCastCtx cast_ctx(&ObSysVarAllocator,
|
||||
NULL,
|
||||
0,
|
||||
CM_NONE,
|
||||
CS_TYPE_INVALID,
|
||||
NULL);
|
||||
if (OB_FAIL(ObObjCaster::to_type(sys_var_type, cast_ctx, in_obj, out_obj))) {
|
||||
ObString sys_var_name = ObSysVariables::get_name(i);
|
||||
LOG_WARN("fail to cast object",
|
||||
K(ret), "cell", in_obj, "from_type", ob_obj_type_str(in_obj.get_type()),
|
||||
"to_type", ob_obj_type_str(sys_var_type), K(sys_var_name), K(i));
|
||||
} else {
|
||||
if (ob_is_string_type(out_obj.get_type())) {
|
||||
out_obj.set_collation_level(CS_LEVEL_SYSCONST);
|
||||
}
|
||||
ObSysVarDefaultValues[i] = out_obj;
|
||||
}
|
||||
}
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
""")
|
||||
cpp_file.write("\n")
|
||||
cpp_file.write("int64_t ObSysVarsToIdxMap::get_store_idx(int64_t var_id){ return ObSysVarsIdToArrayIdx[var_id];}\n")
|
||||
cpp_file.write("bool ObSysVarsToIdxMap::has_invalid_sys_var_id(){ return HasInvalidSysVar;}\n")
|
||||
cpp_file.write("\n")
|
||||
cpp_file.write("} // end namespace share\n")
|
||||
cpp_file.write("} // end namespace oceanbase\n")
|
||||
cpp_file.write("\n")
|
||||
|
||||
cpp_file.close( )
|
||||
print("Generate " + str(cpp_file_name) + " successfully! Including " + str(var_num) + " system variables. \n")
|
||||
return
|
||||
|
||||
def write_sys_var_class_types(wfile, sorted_list):
|
||||
wfile.write("enum ObSysVarClassType\n{\n")
|
||||
wfile.write(" SYS_VAR_INVALID = -1,\n")
|
||||
for (name, attributes) in sorted_list:
|
||||
wfile.write(" SYS_VAR_" + str(name).upper() + " = " + str(attributes['id']) + ",\n")
|
||||
wfile.write("};\n")
|
||||
|
||||
def write_sys_var_classes(wfile, sorted_list):
|
||||
idx = 0
|
||||
for (name, attributes) in sorted_list:
|
||||
write_sys_var_class(\
|
||||
wfile, idx, str(name), \
|
||||
attributes["data_type"], \
|
||||
attributes["base_class"] if "base_class" in attributes.keys() else None, \
|
||||
attributes["on_check_and_convert_func"] if "on_check_and_convert_func" in attributes.keys() else None, \
|
||||
attributes["on_update_func"] if "on_update_func" in attributes.keys() else None, \
|
||||
attributes["to_select_obj_func"] if "to_select_obj_func" in attributes.keys() else None, \
|
||||
attributes["to_show_str_func"] if "to_show_str_func" in attributes.keys() else None, \
|
||||
attributes["get_meta_type_func"] if "get_meta_type_func" in attributes.keys() else None, \
|
||||
attributes["session_special_update_func"] if "session_special_update_func" in attributes.keys() else None)
|
||||
idx += 1
|
||||
|
||||
def write_sys_var_fac_class(wfile, sorted_list):
|
||||
mysql_sys_var_names_count = 0
|
||||
ob_sys_var_names_count = 0
|
||||
for (name, attributes) in sorted_list:
|
||||
if attributes['id'] < 10000:
|
||||
mysql_sys_var_names_count += 1
|
||||
else:
|
||||
ob_sys_var_names_count += 1
|
||||
wfile.write("""
|
||||
class ObSysVarFactory
|
||||
{
|
||||
public:
|
||||
ObSysVarFactory();
|
||||
virtual ~ObSysVarFactory();
|
||||
void destroy();
|
||||
int create_sys_var(ObSysVarClassType sys_var_id, ObBasicSysVar *&sys_var);
|
||||
int create_all_sys_vars();
|
||||
int free_sys_var(ObBasicSysVar *sys_var, int64_t sys_var_idx);
|
||||
static int calc_sys_var_store_idx(ObSysVarClassType sys_var_id, int64_t &store_idx);
|
||||
static int calc_sys_var_store_idx_by_name(const common::ObString &sys_var_name, int64_t &store_idx);
|
||||
static bool is_valid_sys_var_store_idx(int64_t store_idx);
|
||||
static ObSysVarClassType find_sys_var_id_by_name(const common::ObString &sys_var_name, bool is_from_sys_table = false); //二分查找
|
||||
static int get_sys_var_name_by_id(ObSysVarClassType sys_var_id, common::ObString &sys_var_name);
|
||||
static const common::ObString get_sys_var_name_by_id(ObSysVarClassType sys_var_id);
|
||||
|
||||
const static int64_t MYSQL_SYS_VARS_COUNT = """)
|
||||
wfile.write(str(mysql_sys_var_names_count) + ";")
|
||||
wfile.write("""
|
||||
const static int64_t OB_SYS_VARS_COUNT = """)
|
||||
wfile.write(str(ob_sys_var_names_count) + ";")
|
||||
wfile.write("""
|
||||
const static int64_t ALL_SYS_VARS_COUNT = MYSQL_SYS_VARS_COUNT + OB_SYS_VARS_COUNT;
|
||||
|
||||
const static int16_t OB_SPECIFIC_SYS_VAR_ID_OFFSET = 10000;
|
||||
// 表示当前OB能够使用的sys var id的最大值，正常情况下，不需要申请大于OB_MAX_SYS_VAR_ID的sys var id，
|
||||
// 如果需要申请大于OB_MAX_SYS_VAR_ID的sys var id，需要先调整ob_max_sys_var_id的值
|
||||
const static int32_t OB_MAX_SYS_VAR_ID = """)
|
||||
wfile.write(str(ob_max_sys_var_id) + ";")
|
||||
wfile.write("""
|
||||
|
||||
private:
|
||||
static bool sys_var_name_case_cmp(const char *name1, const common::ObString &name2);
|
||||
const static char *SYS_VAR_NAMES_SORTED_BY_NAME[ALL_SYS_VARS_COUNT];
|
||||
const static ObSysVarClassType SYS_VAR_IDS_SORTED_BY_NAME[ALL_SYS_VARS_COUNT];
|
||||
const static char *SYS_VAR_NAMES_SORTED_BY_ID[ALL_SYS_VARS_COUNT];
|
||||
common::ObArenaAllocator allocator_;
|
||||
ObBasicSysVar *store_[ALL_SYS_VARS_COUNT];
|
||||
ObBasicSysVar *store_buf_[ALL_SYS_VARS_COUNT];
|
||||
bool all_sys_vars_created_;
|
||||
};
|
||||
""")
|
||||
|
||||
def write_sys_var_class(wfile, idx, sys_var_name, data_type, base_class, \
|
||||
on_check_and_convert_func, on_update_func, to_select_obj_func, \
|
||||
to_show_str_func, get_meta_type_func, session_special_update_func):
|
||||
name_segs = sys_var_name.split("_")
|
||||
sys_var_cls_name = "ObSysVar"
|
||||
for name_seg in name_segs:
|
||||
sys_var_cls_name += name_seg.capitalize()
|
||||
base_cls_name = "invalid"
|
||||
if base_class is not None:
|
||||
base_cls_name = base_class
|
||||
elif VARCHAR == data_type:
|
||||
base_cls_name = "ObVarcharSysVar"
|
||||
elif INT == data_type:
|
||||
base_cls_name = "ObIntSysVar"
|
||||
elif UINT == data_type:
|
||||
base_cls_name = "ObIntSysVar"
|
||||
elif TINY == data_type:
|
||||
base_cls_name = "ObTinyintSysVar"
|
||||
elif BOOL == data_type:
|
||||
base_cls_name = "ObBoolSysVar"
|
||||
elif NUMERIC == data_type:
|
||||
base_cls_name = "ObNumericSysVar"
|
||||
elif ENUM == data_type:
|
||||
base_cls_name = "ObEnumSysVar"
|
||||
|
||||
wfile.write("class " + sys_var_cls_name + " : public " + base_cls_name + "\n")
|
||||
wfile.write("{\n");
|
||||
if ENUM == data_type:
|
||||
enum_name = sys_var_name.upper();
|
||||
enum_name += "_NAMES"
|
||||
wfile.write("public:\n");
|
||||
wfile.write(" const static char * " + enum_name + "[];\n");
|
||||
wfile.write("public:\n");
|
||||
if base_cls_name == "ObEnumSysVar":
|
||||
wfile.write(" " + sys_var_cls_name + "() : " + base_cls_name + "(" + enum_name \
|
||||
+ ", " + ("NULL" if on_check_and_convert_func is None else on_check_and_convert_func) \
|
||||
+ ", " + ("NULL" if on_update_func is None else on_update_func) \
|
||||
+ ", " + ("NULL" if to_select_obj_func is None else to_select_obj_func) \
|
||||
+ ", " + ("NULL" if to_show_str_func is None else to_show_str_func) \
|
||||
+ ", " + ("NULL" if get_meta_type_func is None else get_meta_type_func) \
|
||||
+ ") {}\n")
|
||||
elif base_cls_name == "ObSessionSpecialIntSysVar":
|
||||
wfile.write(" " + sys_var_cls_name + "() : " + base_cls_name + "(" \
|
||||
+ ("NULL" if on_check_and_convert_func is None else on_check_and_convert_func) \
|
||||
+ ", " + ("NULL" if session_special_update_func is None else session_special_update_func) \
|
||||
+ ", " + ("NULL" if to_select_obj_func is None else to_select_obj_func) \
|
||||
+ ", " + ("NULL" if to_show_str_func is None else to_show_str_func) \
|
||||
+ ", " + ("NULL" if get_meta_type_func is None else get_meta_type_func) \
|
||||
+ ") {}\n")
|
||||
elif base_cls_name == "ObSessionSpecialVarcharSysVar":
|
||||
wfile.write(" " + sys_var_cls_name + "() : " + base_cls_name + "(" \
|
||||
+ ("NULL" if on_check_and_convert_func is None else on_check_and_convert_func) \
|
||||
+ ", " + ("NULL" if on_update_func is None else on_update_func) \
|
||||
+ ", " + ("NULL" if session_special_update_func is None else session_special_update_func) \
|
||||
+ ", " + ("NULL" if to_select_obj_func is None else to_select_obj_func) \
|
||||
+ ", " + ("NULL" if to_show_str_func is None else to_show_str_func) \
|
||||
+ ", " + ("NULL" if get_meta_type_func is None else get_meta_type_func) \
|
||||
+ ") {}\n")
|
||||
elif base_cls_name == "ObSessionSpecialBoolSysVar":
|
||||
wfile.write(" " + sys_var_cls_name + "() : " + base_cls_name + "(" \
|
||||
+ ("NULL" if on_check_and_convert_func is None else on_check_and_convert_func) \
|
||||
+ ", " + ("NULL" if on_update_func is None else on_update_func) \
|
||||
+ ", " + ("NULL" if session_special_update_func is None else session_special_update_func) \
|
||||
+ ", " + ("NULL" if to_select_obj_func is None else to_select_obj_func) \
|
||||
+ ", " + ("NULL" if to_show_str_func is None else to_show_str_func) \
|
||||
+ ", " + ("NULL" if get_meta_type_func is None else get_meta_type_func) \
|
||||
+ ") {}\n")
|
||||
else:
|
||||
wfile.write(" " + sys_var_cls_name + "() : " + base_cls_name + "(" \
|
||||
+ ("NULL" if on_check_and_convert_func is None else on_check_and_convert_func) \
|
||||
+ ", " + ("NULL" if on_update_func is None else on_update_func) \
|
||||
+ ", " + ("NULL" if to_select_obj_func is None else to_select_obj_func) \
|
||||
+ ", " + ("NULL" if to_show_str_func is None else to_show_str_func) \
|
||||
+ ", " + ("NULL" if get_meta_type_func is None else get_meta_type_func) \
|
||||
+ ") {}\n")
|
||||
wfile.write(" inline virtual ObSysVarClassType get_type() const { return SYS_VAR_" + sys_var_name.upper() + "; }\n")
|
||||
wfile.write(" inline virtual const common::ObObj &get_global_default_value() const { return ObSysVariables::get_default_value(" + str(idx) + "); }\n")
|
||||
wfile.write("};\n");
|
||||
|
||||
def make_sys_var_class_type_h(pdir, filename, sorted_list):
|
||||
wfile = open(filename, 'w')
|
||||
wfile.write(file_head_annotation);
|
||||
suffix_idx = filename.find(".h")
|
||||
file_def_str = "OCEANBASE_" + pdir.replace("/", "_").upper() + "_" + filename[0 : suffix_idx].upper() + "_"
|
||||
wfile.write("#ifndef " + file_def_str + "\n")
|
||||
wfile.write("#define " + file_def_str + "\n")
|
||||
wfile.write("#include <stdint.h>\n")
|
||||
wfile.write("""
|
||||
namespace oceanbase
|
||||
{
|
||||
namespace share
|
||||
{
|
||||
""")
|
||||
write_sys_var_class_types(wfile, sorted_list)
|
||||
wfile.write("""
|
||||
}
|
||||
}
|
||||
""")
|
||||
wfile.write("#endif //" + file_def_str)
|
||||
print("Generate " + str(filename) + " successfully!\n");
|
||||
|
||||
def make_sys_var_h(pdir, filename, sorted_list):
|
||||
wfile = open(filename, 'w')
|
||||
wfile.write(file_head_annotation);
|
||||
suffix_idx = filename.find(".h")
|
||||
file_def_str = "OCEANBASE_" + pdir.replace("/", "_").upper() + "_" + filename[0 : suffix_idx].upper() + "_"
|
||||
wfile.write("#ifndef " + file_def_str + "\n")
|
||||
wfile.write("#define " + file_def_str + "\n")
|
||||
wfile.write("#include \"common/object/ob_object.h\"\n")
|
||||
wfile.write("#include \"share/system_variable/ob_system_variable.h\"\n")
|
||||
wfile.write("#include \"share/system_variable/ob_system_variable_init.h\"\n")
|
||||
wfile.write("#include \"lib/allocator/page_arena.h\"\n")
|
||||
wfile.write("#include \"lib/string/ob_string.h\"\n");
|
||||
wfile.write("#include \"lib/container/ob_array.h\"\n")
|
||||
wfile.write("""
|
||||
namespace oceanbase
|
||||
{
|
||||
namespace share
|
||||
{
|
||||
""")
|
||||
write_sys_var_classes(wfile, sorted_list)
|
||||
wfile.write("\n")
|
||||
write_sys_var_fac_class(wfile, sorted_list)
|
||||
wfile.write("""
|
||||
}
|
||||
}
|
||||
""")
|
||||
wfile.write("#endif //" + file_def_str)
|
||||
print("Generate " + str(filename) + " successfully!\n");
|
||||
|
||||
def make_sys_var_cpp(pdir, filename, list_sorted_by_name, list_sorted_by_id):
|
||||
wfile = open(filename, 'w')
|
||||
wfile.write(file_head_annotation);
|
||||
wfile.write("#define USING_LOG_PREFIX SQL_SESSION\n");
|
||||
wfile.write("#include \"share/ob_define.h\"\n")
|
||||
wfile.write("#include \"" + pdir + "/" + filename.replace(".cpp", ".h") + "\"\n")
|
||||
# wfile.write("#include \"share/system_variable/ob_system_variable_init.cpp\"\n")
|
||||
wfile.write("#include \"share/ob_errno.h\"\n")
|
||||
wfile.write("#include <algorithm>\n")
|
||||
wfile.write("using namespace oceanbase::common;\n");
|
||||
wfile.write("""
|
||||
namespace oceanbase
|
||||
{
|
||||
namespace share
|
||||
{
|
||||
""")
|
||||
for (name, attributes) in list_sorted_by_id:
|
||||
if ENUM == attributes["data_type"]:
|
||||
name_segs = str(name).split("_")
|
||||
sys_var_cls_name = "ObSysVar"
|
||||
for name_seg in name_segs:
|
||||
sys_var_cls_name += name_seg.capitalize();
|
||||
enum_name = str(name).upper();
|
||||
enum_name += "_NAMES";
|
||||
wfile.write("const char *" + sys_var_cls_name + "::" + enum_name + "[] = {");
|
||||
idx = 0
|
||||
for val in attributes["enum_names"]:
|
||||
if idx > 0:
|
||||
wfile.write(",")
|
||||
wfile.write("\n \"" + val + "\"")
|
||||
idx += 1
|
||||
wfile.write(",\n 0\n};\n")
|
||||
|
||||
wfile.write("""
|
||||
const char *ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME[] = {
|
||||
""")
|
||||
idx = 0
|
||||
for (name, attributes) in list_sorted_by_name:
|
||||
if idx > 0:
|
||||
wfile.write(",\n")
|
||||
wfile.write(" \"" + name + "\"")
|
||||
idx += 1
|
||||
wfile.write("""
|
||||
};
|
||||
|
||||
const ObSysVarClassType ObSysVarFactory::SYS_VAR_IDS_SORTED_BY_NAME[] = {
|
||||
""")
|
||||
idx = 0
|
||||
for (name, attributes) in list_sorted_by_name:
|
||||
if idx > 0:
|
||||
wfile.write(",\n")
|
||||
wfile.write(" SYS_VAR_" + str(name).upper())
|
||||
idx += 1
|
||||
wfile.write("""
|
||||
};
|
||||
|
||||
const char *ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_ID[] = {
|
||||
""")
|
||||
idx = 0
|
||||
for (name, attributes) in list_sorted_by_id:
|
||||
if idx > 0:
|
||||
wfile.write(",\n")
|
||||
wfile.write(" \"" + name + "\"")
|
||||
idx += 1
|
||||
wfile.write("""
|
||||
};
|
||||
|
||||
bool ObSysVarFactory::sys_var_name_case_cmp(const char *name1, const ObString &name2)
|
||||
{
|
||||
return name2.case_compare(name1) > 0;
|
||||
}
|
||||
|
||||
ObSysVarClassType ObSysVarFactory::find_sys_var_id_by_name(const ObString &sys_var_name,
|
||||
bool is_from_sys_table /*= false*/)
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
ObSysVarClassType sys_var_id = SYS_VAR_INVALID;
|
||||
int64_t lower_idx = std::lower_bound(ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME,
|
||||
ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME + ObSysVarFactory::ALL_SYS_VARS_COUNT,
|
||||
sys_var_name, ObSysVarFactory::sys_var_name_case_cmp) -
|
||||
ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME;
|
||||
if (OB_UNLIKELY(lower_idx < 0)) {
|
||||
ret = OB_ERR_UNEXPECTED;
|
||||
LOG_ERROR("invalid lower index", K(ret), K(sys_var_name), K(lower_idx), K(lbt()));
|
||||
} else if (OB_UNLIKELY(lower_idx > ObSysVarFactory::ALL_SYS_VARS_COUNT)) {
|
||||
ret = OB_ERR_UNEXPECTED;
|
||||
LOG_ERROR("invalid lower index", K(ret), K(sys_var_name), K(lower_idx),
|
||||
LITERAL_K(ObSysVarFactory::ALL_SYS_VARS_COUNT), K(lbt()));
|
||||
} else if (OB_UNLIKELY(ObSysVarFactory::ALL_SYS_VARS_COUNT == lower_idx)) {
|
||||
// std::lower_bound返回ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME +
|
||||
// ObSysVarFactory::ALL_SYS_VARS_COUNT的地址，即是找不到，而不是出错
|
||||
ret = OB_SEARCH_NOT_FOUND;
|
||||
} else if (0 != sys_var_name.case_compare(
|
||||
ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME[lower_idx])) {
|
||||
// 找不到
|
||||
ret = OB_SEARCH_NOT_FOUND;
|
||||
} else {
|
||||
sys_var_id = ObSysVarFactory::SYS_VAR_IDS_SORTED_BY_NAME[lower_idx]; // 找到了
|
||||
}
|
||||
if (OB_UNLIKELY(OB_SEARCH_NOT_FOUND == ret)) {
|
||||
if (is_from_sys_table) {
|
||||
LOG_INFO("new system variable is added , so can not found; don't worry", K(sys_var_name),
|
||||
K(lower_idx), LITERAL_K(ObSysVarFactory::ALL_SYS_VARS_COUNT), K(lbt()));
|
||||
} else {
|
||||
LOG_WARN("sys var name not found", K(sys_var_name), K(lower_idx),
|
||||
LITERAL_K(ObSysVarFactory::ALL_SYS_VARS_COUNT), K(lbt()));
|
||||
}
|
||||
}
|
||||
return sys_var_id;
|
||||
}
|
||||
|
||||
int ObSysVarFactory::calc_sys_var_store_idx(ObSysVarClassType sys_var_id, int64_t &store_idx)
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
int64_t real_idx = -1;
|
||||
int64_t var_id = static_cast<int64_t>(sys_var_id);
|
||||
if (ObSysVarsToIdxMap::has_invalid_sys_var_id()) {
|
||||
ret = OB_INVALID_ARGUMENT;
|
||||
LOG_ERROR("has invalid sys var id", K(ret), K(ObSysVarsToIdxMap::has_invalid_sys_var_id()));
|
||||
} else if (OB_UNLIKELY(var_id < 0)) {
|
||||
ret = OB_INVALID_ARGUMENT;
|
||||
LOG_ERROR("invalid sys var id", K(ret), K(var_id));
|
||||
} else {
|
||||
// 直接利用ObSysVarsIdToArrayIdx 索引数组查询到对应的store idx
|
||||
real_idx = ObSysVarsToIdxMap::get_store_idx(var_id);
|
||||
if (real_idx < 0) {
|
||||
ret = OB_SYS_VARS_MAYBE_DIFF_VERSION;
|
||||
LOG_WARN("invalid sys var id, maybe sys vars version is different", K(ret), K(var_id), K(real_idx),
|
||||
LITERAL_K(ObSysVarFactory::OB_SPECIFIC_SYS_VAR_ID_OFFSET),
|
||||
LITERAL_K(ObSysVarFactory::OB_SYS_VARS_COUNT));
|
||||
}
|
||||
}
|
||||
|
||||
if (OB_FAIL(ret)) {
|
||||
} else {
|
||||
store_idx = real_idx;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
int ObSysVarFactory::calc_sys_var_store_idx_by_name(const common::ObString &sys_var_name,
|
||||
int64_t &store_idx)
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
ObSysVarClassType sys_var_id = find_sys_var_id_by_name(sys_var_name);
|
||||
if (OB_FAIL(calc_sys_var_store_idx(sys_var_id, store_idx))) {
|
||||
LOG_WARN("fail to calc sys var store idx", K(ret), K(sys_var_name), K(lbt()));
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
bool ObSysVarFactory::is_valid_sys_var_store_idx(int64_t store_idx)
|
||||
{
|
||||
return 0 <= store_idx && store_idx < ObSysVarFactory::ALL_SYS_VARS_COUNT;
|
||||
}
|
||||
|
||||
int ObSysVarFactory::get_sys_var_name_by_id(ObSysVarClassType sys_var_id, ObString &sys_var_name)
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
int64_t store_idx = -1;
|
||||
if (OB_FAIL(calc_sys_var_store_idx(sys_var_id, store_idx))) {
|
||||
LOG_WARN("fail to calc sys var store idx", K(ret), K(sys_var_id));
|
||||
} else {
|
||||
sys_var_name = ObString::make_string(ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_ID[store_idx]);
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
const ObString ObSysVarFactory::get_sys_var_name_by_id(ObSysVarClassType sys_var_id)
|
||||
{
|
||||
ObString sys_var_name;
|
||||
int ret = OB_SUCCESS;
|
||||
if (OB_FAIL(get_sys_var_name_by_id(sys_var_id, sys_var_name))) {
|
||||
sys_var_name = ObString::make_string("invalid_sys_var_name");
|
||||
LOG_WARN("invalid sys var id", K(ret), K(sys_var_id));
|
||||
}
|
||||
return sys_var_name;
|
||||
}
|
||||
|
||||
ObSysVarFactory::ObSysVarFactory()
|
||||
: allocator_(ObModIds::OB_COMMON_SYS_VAR_FAC), all_sys_vars_created_(false)
|
||||
{
|
||||
MEMSET(store_, 0, sizeof(store_));
|
||||
MEMSET(store_buf_, 0, sizeof(store_buf_));
|
||||
}
|
||||
|
||||
ObSysVarFactory::~ObSysVarFactory()
|
||||
{
|
||||
destroy();
|
||||
}
|
||||
|
||||
void ObSysVarFactory::destroy()
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
for (int64_t i = 0; i < ALL_SYS_VARS_COUNT; ++i) {
|
||||
if (OB_NOT_NULL(store_[i])) {
|
||||
store_[i]->~ObBasicSysVar();
|
||||
store_[i] = nullptr;
|
||||
}
|
||||
if (OB_NOT_NULL(store_buf_[i])) {
|
||||
store_buf_[i]->~ObBasicSysVar();
|
||||
store_buf_[i] = nullptr;
|
||||
}
|
||||
}
|
||||
allocator_.reset();
|
||||
all_sys_vars_created_ = false;
|
||||
}
|
||||
|
||||
int ObSysVarFactory::free_sys_var(ObBasicSysVar *sys_var, int64_t sys_var_idx)
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
OV (OB_NOT_NULL(sys_var));
|
||||
OV (is_valid_sys_var_store_idx(sys_var_idx));
|
||||
OV (sys_var == store_[sys_var_idx], OB_ERR_UNEXPECTED, sys_var, sys_var_idx);
|
||||
if (OB_NOT_NULL(store_buf_[sys_var_idx])) {
|
||||
OX (store_buf_[sys_var_idx]->~ObBasicSysVar());
|
||||
OX (allocator_.free(store_buf_[sys_var_idx]));
|
||||
OX (store_buf_[sys_var_idx] = nullptr);
|
||||
}
|
||||
OX (store_buf_[sys_var_idx] = store_[sys_var_idx]);
|
||||
OX (store_buf_[sys_var_idx]->clean_value());
|
||||
OX (store_[sys_var_idx] = nullptr);
|
||||
return ret;
|
||||
}
|
||||
|
||||
int ObSysVarFactory::create_all_sys_vars()
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
if (!all_sys_vars_created_) {
|
||||
int64_t store_idx = -1;
|
||||
ObBasicSysVar *sys_var_ptr = NULL;
|
||||
int64_t total_mem_size = 0
|
||||
""")
|
||||
for (name, attributes) in list_sorted_by_id:
|
||||
name_segs = name.split("_")
|
||||
sys_var_cls_name = "ObSysVar"
|
||||
for name_seg in name_segs:
|
||||
sys_var_cls_name += name_seg.capitalize()
|
||||
wfile.write(" + sizeof(" + sys_var_cls_name + ")\n")
|
||||
wfile.write(" ;\n")
|
||||
wfile.write(" void *ptr = NULL;\n")
|
||||
wfile.write(" if (OB_ISNULL(ptr = allocator_.alloc(total_mem_size))) {\n")
|
||||
wfile.write(" ret = OB_ALLOCATE_MEMORY_FAILED;\n")
|
||||
wfile.write(" LOG_ERROR(\"fail to alloc memory\", K(ret));\n")
|
||||
wfile.write(" } else {\n")
|
||||
wfile.write(" all_sys_vars_created_ = true;\n")
|
||||
wfile.write(" }\n")
|
||||
|
||||
for (name, attributes) in list_sorted_by_id:
|
||||
name_segs = name.split("_")
|
||||
sys_var_cls_name = "ObSysVar"
|
||||
for name_seg in name_segs:
|
||||
sys_var_cls_name += name_seg.capitalize()
|
||||
wfile.write(" if (OB_SUCC(ret)) {\n")
|
||||
wfile.write(" if (OB_ISNULL(sys_var_ptr = new (ptr)" + sys_var_cls_name + "())) {\n")
|
||||
wfile.write(" ret = OB_ALLOCATE_MEMORY_FAILED;\n")
|
||||
wfile.write(" LOG_ERROR(\"fail to new " + sys_var_cls_name + "\", K(ret));\n")
|
||||
wfile.write(" } else {\n")
|
||||
wfile.write(" store_buf_[ObSysVarsToIdxMap::get_store_idx(static_cast<int64_t>(SYS_VAR_" + name.upper() + "))] = sys_var_ptr;\n")
|
||||
wfile.write(" ptr = (void *)((char *)ptr + sizeof(" + sys_var_cls_name + "));\n")
|
||||
wfile.write(" }\n")
|
||||
wfile.write(" }\n")
|
||||
|
||||
wfile.write("""
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
int ObSysVarFactory::create_sys_var(ObSysVarClassType sys_var_id, ObBasicSysVar *&sys_var)
|
||||
{
|
||||
int ret = OB_SUCCESS;
|
||||
int64_t store_idx = -1;
|
||||
ObBasicSysVar *sys_var_ptr = NULL;
|
||||
if (OB_FAIL(calc_sys_var_store_idx(sys_var_id, store_idx))) {
|
||||
LOG_WARN("fail to calc sys var store idx", K(ret), K(sys_var_id));
|
||||
} else if (store_idx < 0 || store_idx >= ALL_SYS_VARS_COUNT) {
|
||||
ret = OB_ERR_UNEXPECTED;
|
||||
LOG_WARN("unexpected store idx", K(ret), K(store_idx), K(sys_var_id));
|
||||
} else if (OB_NOT_NULL(store_[store_idx])) {
|
||||
ret = OB_ERR_UNEXPECTED;
|
||||
LOG_WARN("store ptr shoule be null", K(ret), K(store_idx), K(sys_var_id));
|
||||
} else {
|
||||
if (OB_NOT_NULL(store_buf_[store_idx])) {
|
||||
sys_var_ptr = store_buf_[store_idx];
|
||||
store_buf_[store_idx] = nullptr;
|
||||
}
|
||||
}
|
||||
if (OB_ISNULL(sys_var_ptr)) {
|
||||
switch(sys_var_id) {
|
||||
""")
|
||||
for (name, attributes) in list_sorted_by_id:
|
||||
name_segs = name.split("_")
|
||||
sys_var_cls_name = "ObSysVar"
|
||||
for name_seg in name_segs:
|
||||
sys_var_cls_name += name_seg.capitalize()
|
||||
wfile.write(" case SYS_VAR_" + str(name).upper() + ": {\n")
|
||||
wfile.write(" void *ptr = NULL;\n")
|
||||
wfile.write(" if (OB_ISNULL(ptr = allocator_.alloc(sizeof(" + sys_var_cls_name + ")))) {\n")
|
||||
wfile.write(" ret = OB_ALLOCATE_MEMORY_FAILED;\n")
|
||||
wfile.write(" LOG_ERROR(\"fail to alloc memory\", K(ret), K(sizeof(" + sys_var_cls_name + ")));\n")
|
||||
wfile.write(" } else if (OB_ISNULL(sys_var_ptr = new (ptr)" + sys_var_cls_name + "())) {\n")
|
||||
wfile.write(" ret = OB_ALLOCATE_MEMORY_FAILED;\n")
|
||||
wfile.write(" LOG_ERROR(\"fail to new " + sys_var_cls_name + "\", K(ret));\n")
|
||||
wfile.write(" }\n")
|
||||
wfile.write(" break;\n")
|
||||
wfile.write(" }\n")
|
||||
wfile.write("""
|
||||
default: {
|
||||
ret = OB_ERR_UNEXPECTED;
|
||||
LOG_ERROR("invalid system variable id", K(ret), K(sys_var_id));
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
if (OB_SUCC(ret)) {
|
||||
if (OB_ISNULL(sys_var_ptr)) {
|
||||
ret = OB_ERR_UNEXPECTED;
|
||||
LOG_ERROR("ret is OB_SUCCESS, but sys_var_ptr is NULL", K(ret), K(sys_var_id));
|
||||
} else if (OB_NOT_NULL(store_[store_idx])) {
|
||||
ret = OB_ERR_UNEXPECTED;
|
||||
LOG_WARN("store_[store_idx] should be NULL", K(ret), K(sys_var_id));
|
||||
} else {
|
||||
store_[store_idx] = sys_var_ptr;
|
||||
sys_var = sys_var_ptr;
|
||||
}
|
||||
}
|
||||
if (OB_FAIL(ret) && sys_var_ptr != nullptr) {
|
||||
sys_var_ptr->~ObBasicSysVar();
|
||||
sys_var_ptr = NULL;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
""")
|
||||
wfile.write("""
|
||||
}
|
||||
}
|
||||
""")
|
||||
print("Generate " + str(filename) + " successfully!\n")
|
||||
|
||||
def calc_flags_from_str(flags_str):
|
||||
result = 0
|
||||
flags = flags_str.split("|")
|
||||
flags_len = len(flags)
|
||||
for i in range(0, flags_len):
|
||||
result = (result | flag_value_dict[flags[i].strip().upper()])
|
||||
return result
|
||||
|
||||
def gen_sys_vars_dict_script_for_upgrade(filename, list_sorted_by_id):
|
||||
os.chmod(filename, stat.S_IRUSR + stat.S_IWUSR + stat.S_IRGRP + stat.S_IROTH)
|
||||
wfile = open(filename, 'w')
|
||||
annotation_is_written = False
|
||||
wfile.write('#!/usr/bin/env python\n')
|
||||
wfile.write('# -*- coding: utf-8 -*-\n')
|
||||
wfile.write('\n')
|
||||
wfile.write("# sys_vars_dict.py是由gen_ob_sys_variables.py根据ob_system_variable_init.json和upgrade_sys_var_base_script.py文件生成的，不可修改\n")
|
||||
wfile.write('sys_var_dict = {}\n')
|
||||
for (name, attributes) in list_sorted_by_id:
|
||||
wfile.write("sys_var_dict[\"" + name + "\"] = {\"id\": " + str(attributes["id"]) + ", \"name\": \"" + attributes["name"] + "\", \"value\": \"" + attributes["value"] + "\", \"data_type\": " + str(type_value_dict[attributes["data_type"]]) + ", \"info\": \"" + attributes["info"] + "\", \"flags\": " + str(calc_flags_from_str(attributes["flags"])) + ((", \"min_val\": \"" + attributes["min_val"] + "\"") if "min_val" in attributes.keys() else "") + ((", \"max_val\": \"" + attributes["max_val"] + "\"") if "max_val" in attributes.keys() else "") + "}\n")
|
||||
wfile.close()
|
||||
os.chmod(filename, stat.S_IRUSR + stat.S_IRGRP + stat.S_IROTH)
|
||||
print("Generate " + str(filename) + " successfully!\n")
|
||||
|
||||
def gen_upgrade_script():
|
||||
print('\n=========run gen_upgrade_scripts.py, begin=========\n')
|
||||
info = os.popen('cd ../../../tools/upgrade/; ./gen_upgrade_scripts.py;')
|
||||
print(info.read())
|
||||
print('\n=========run gen_upgrade_scripts.py, end=========\n')
|
||||
|
||||
pdir = "share/system_variable"
|
||||
json_file_name = "ob_system_variable_init.json"
|
||||
head_file_name = "ob_system_variable_init.h"
|
||||
cpp_file_name = "ob_system_variable_init.cpp"
|
||||
alias_file_name ="ob_system_variable_alias.h"
|
||||
sys_var_class_type_head_file_name = "ob_sys_var_class_type.h"
|
||||
sys_var_fac_head_file_name = "ob_system_variable_factory.h"
|
||||
sys_var_fac_cpp_file_name = "ob_system_variable_factory.cpp"
|
||||
sys_vars_dict_script_file_name = "../../../tools/upgrade/sys_vars_dict.py"
|
||||
|
||||
(json_Dict, list_sorted_by_name, list_sorted_by_id) = parse_json(json_file_name)
|
||||
|
||||
make_head_file(pdir, head_file_name, list_sorted_by_id)
|
||||
make_cpp_file(pdir, cpp_file_name, list_sorted_by_id)
|
||||
make_alias_file(pdir, alias_file_name, list_sorted_by_id)
|
||||
|
||||
make_sys_var_class_type_h(pdir, sys_var_class_type_head_file_name, list_sorted_by_id)
|
||||
make_sys_var_h(pdir, sys_var_fac_head_file_name, list_sorted_by_id)
|
||||
make_sys_var_cpp(pdir, sys_var_fac_cpp_file_name, list_sorted_by_name, list_sorted_by_id)
|
||||
|
||||
gen_sys_vars_dict_script_for_upgrade(sys_vars_dict_script_file_name, list_sorted_by_id)
|
||||
gen_upgrade_script()
|
||||
@ -14,9 +14,12 @@
|
||||
#define OCEANBASE_SHARE_SYSTEM_VARIABLE_OB_SYS_VAR_CLASS_TYPE_
|
||||
#include <stdint.h>
|
||||
|
||||
namespace oceanbase {
|
||||
namespace share {
|
||||
enum ObSysVarClassType {
|
||||
namespace oceanbase
|
||||
{
|
||||
namespace share
|
||||
{
|
||||
enum ObSysVarClassType
|
||||
{
|
||||
SYS_VAR_INVALID = -1,
|
||||
SYS_VAR_AUTO_INCREMENT_INCREMENT = 0,
|
||||
SYS_VAR_AUTO_INCREMENT_OFFSET = 1,
|
||||
@ -99,6 +102,9 @@ enum ObSysVarClassType {
|
||||
SYS_VAR_VERSION_COMPILE_MACHINE = 78,
|
||||
SYS_VAR_VERSION_COMPILE_OS = 79,
|
||||
SYS_VAR_WARNING_COUNT = 80,
|
||||
SYS_VAR_SESSION_TRACK_SCHEMA = 81,
|
||||
SYS_VAR_SESSION_TRACK_SYSTEM_VARIABLES = 82,
|
||||
SYS_VAR_SESSION_TRACK_STATE_CHANGE = 83,
|
||||
SYS_VAR_OB_DEFAULT_REPLICA_NUM = 10000,
|
||||
SYS_VAR_OB_INTERM_RESULT_MEM_LIMIT = 10001,
|
||||
SYS_VAR_OB_PROXY_PARTITION_HIT = 10002,
|
||||
@ -216,5 +222,5 @@ enum ObSysVarClassType {
|
||||
};
|
||||
|
||||
}
|
||||
} // namespace oceanbase
|
||||
#endif // OCEANBASE_SHARE_SYSTEM_VARIABLE_OB_SYS_VAR_CLASS_TYPE_
|
||||
}
|
||||
#endif //OCEANBASE_SHARE_SYSTEM_VARIABLE_OB_SYS_VAR_CLASS_TYPE_
|
||||
|
||||
@ -10,206 +10,217 @@
|
||||
* See the Mulan PubL v2 for more details.
|
||||
*/
|
||||
|
||||
|
||||
/* 此处定义所有系统变量的名字。初始化@see ob_ddl_operation.cpp和ob_basic_session_info.cpp
|
||||
* @note: 所有OB特有的非mysql的系统变量，都以ob_开头，以区别于mysql系统变量的名字空间。
|
||||
* 反之，所有不以ob_开头的系统变量都必须和mysql语义完全兼容。 */
|
||||
|
||||
#ifndef OCEANBASE_SHARE_SYSTEM_VARIABLE_OB_SYSTEM_VARIABLE_ALIAS_
|
||||
#define OCEANBASE_SHARE_SYSTEM_VARIABLE_OB_SYSTEM_VARIABLE_ALIAS_
|
||||
namespace oceanbase {
|
||||
namespace share {
|
||||
static const char* const OB_SV_AUTO_INCREMENT_INCREMENT = "auto_increment_increment";
|
||||
static const char* const OB_SV_AUTO_INCREMENT_OFFSET = "auto_increment_offset";
|
||||
static const char* const OB_SV_AUTOCOMMIT = "autocommit";
|
||||
static const char* const OB_SV_CHARACTER_SET_CLIENT = "character_set_client";
|
||||
static const char* const OB_SV_CHARACTER_SET_CONNECTION = "character_set_connection";
|
||||
static const char* const OB_SV_CHARACTER_SET_DATABASE = "character_set_database";
|
||||
static const char* const OB_SV_CHARACTER_SET_RESULTS = "character_set_results";
|
||||
static const char* const OB_SV_CHARACTER_SET_SERVER = "character_set_server";
|
||||
static const char* const OB_SV_CHARACTER_SET_SYSTEM = "character_set_system";
|
||||
static const char* const OB_SV_COLLATION_CONNECTION = "collation_connection";
|
||||
static const char* const OB_SV_COLLATION_DATABASE = "collation_database";
|
||||
static const char* const OB_SV_COLLATION_SERVER = "collation_server";
|
||||
static const char* const OB_SV_INTERACTIVE_TIMEOUT = "interactive_timeout";
|
||||
static const char* const OB_SV_LAST_INSERT_ID = "last_insert_id";
|
||||
static const char* const OB_SV_MAX_ALLOWED_PACKET = "max_allowed_packet";
|
||||
static const char* const OB_SV_SQL_MODE = "sql_mode";
|
||||
static const char* const OB_SV_TIME_ZONE = "time_zone";
|
||||
static const char* const OB_SV_TX_ISOLATION = "tx_isolation";
|
||||
static const char* const OB_SV_VERSION_COMMENT = "version_comment";
|
||||
static const char* const OB_SV_WAIT_TIMEOUT = "wait_timeout";
|
||||
static const char* const OB_SV_BINLOG_ROW_IMAGE = "binlog_row_image";
|
||||
static const char* const OB_SV_CHARACTER_SET_FILESYSTEM = "character_set_filesystem";
|
||||
static const char* const OB_SV_CONNECT_TIMEOUT = "connect_timeout";
|
||||
static const char* const OB_SV_DATADIR = "datadir";
|
||||
static const char* const OB_SV_DEBUG_SYNC = "debug_sync";
|
||||
static const char* const OB_SV_DIV_PRECISION_INCREMENT = "div_precision_increment";
|
||||
static const char* const OB_SV_EXPLICIT_DEFAULTS_FOR_TIMESTAMP = "explicit_defaults_for_timestamp";
|
||||
static const char* const OB_SV_GROUP_CONCAT_MAX_LEN = "group_concat_max_len";
|
||||
static const char* const OB_SV_IDENTITY = "identity";
|
||||
static const char* const OB_SV_LOWER_CASE_TABLE_NAMES = "lower_case_table_names";
|
||||
static const char* const OB_SV_NET_READ_TIMEOUT = "net_read_timeout";
|
||||
static const char* const OB_SV_NET_WRITE_TIMEOUT = "net_write_timeout";
|
||||
static const char* const OB_SV_READ_ONLY = "read_only";
|
||||
static const char* const OB_SV_SQL_AUTO_IS_NULL = "sql_auto_is_null";
|
||||
static const char* const OB_SV_SQL_SELECT_LIMIT = "sql_select_limit";
|
||||
static const char* const OB_SV_TIMESTAMP = "timestamp";
|
||||
static const char* const OB_SV_TX_READ_ONLY = "tx_read_only";
|
||||
static const char* const OB_SV_VERSION = "version";
|
||||
static const char* const OB_SV_SQL_WARNINGS = "sql_warnings";
|
||||
static const char* const OB_SV_MAX_USER_CONNECTIONS = "max_user_connections";
|
||||
static const char* const OB_SV_INIT_CONNECT = "init_connect";
|
||||
static const char* const OB_SV_LICENSE = "license";
|
||||
static const char* const OB_SV_NET_BUFFER_LENGTH = "net_buffer_length";
|
||||
static const char* const OB_SV_SYSTEM_TIME_ZONE = "system_time_zone";
|
||||
static const char* const OB_SV_QUERY_CACHE_SIZE = "query_cache_size";
|
||||
static const char* const OB_SV_QUERY_CACHE_TYPE = "query_cache_type";
|
||||
static const char* const OB_SV_SQL_QUOTE_SHOW_CREATE = "sql_quote_show_create";
|
||||
static const char* const OB_SV_MAX_SP_RECURSION_DEPTH = "max_sp_recursion_depth";
|
||||
static const char* const OB_SV_SQL_SAFE_UPDATES = "sql_safe_updates";
|
||||
static const char* const OB_SV_CONCURRENT_INSERT = "concurrent_insert";
|
||||
static const char* const OB_SV_DEFAULT_AUTHENTICATION_PLUGIN = "default_authentication_plugin";
|
||||
static const char* const OB_SV_DISABLED_STORAGE_ENGINES = "disabled_storage_engines";
|
||||
static const char* const OB_SV_ERROR_COUNT = "error_count";
|
||||
static const char* const OB_SV_GENERAL_LOG = "general_log";
|
||||
static const char* const OB_SV_HAVE_OPENSSL = "have_openssl";
|
||||
static const char* const OB_SV_HAVE_PROFILING = "have_profiling";
|
||||
static const char* const OB_SV_HAVE_SSL = "have_ssl";
|
||||
static const char* const OB_SV_HOSTNAME = "hostname";
|
||||
static const char* const OB_SV_LC_MESSAGES = "lc_messages";
|
||||
static const char* const OB_SV_LOCAL_INFILE = "local_infile";
|
||||
static const char* const OB_SV_LOCK_WAIT_TIMEOUT = "lock_wait_timeout";
|
||||
static const char* const OB_SV_LONG_QUERY_TIME = "long_query_time";
|
||||
static const char* const OB_SV_MAX_CONNECTIONS = "max_connections";
|
||||
static const char* const OB_SV_MAX_EXECUTION_TIME = "max_execution_time";
|
||||
static const char* const OB_SV_PROTOCOL_VERSION = "protocol_version";
|
||||
static const char* const OB_SV_SERVER_ID = "server_id";
|
||||
static const char* const OB_SV_SSL_CA = "ssl_ca";
|
||||
static const char* const OB_SV_SSL_CAPATH = "ssl_capath";
|
||||
static const char* const OB_SV_SSL_CERT = "ssl_cert";
|
||||
static const char* const OB_SV_SSL_CIPHER = "ssl_cipher";
|
||||
static const char* const OB_SV_SSL_CRL = "ssl_crl";
|
||||
static const char* const OB_SV_SSL_CRLPATH = "ssl_crlpath";
|
||||
static const char* const OB_SV_SSL_KEY = "ssl_key";
|
||||
static const char* const OB_SV_TIME_FORMAT = "time_format";
|
||||
static const char* const OB_SV_TLS_VERSION = "tls_version";
|
||||
static const char* const OB_SV_TMP_TABLE_SIZE = "tmp_table_size";
|
||||
static const char* const OB_SV_TMPDIR = "tmpdir";
|
||||
static const char* const OB_SV_UNIQUE_CHECKS = "unique_checks";
|
||||
static const char* const OB_SV_VERSION_COMPILE_MACHINE = "version_compile_machine";
|
||||
static const char* const OB_SV_VERSION_COMPILE_OS = "version_compile_os";
|
||||
static const char* const OB_SV_WARNING_COUNT = "warning_count";
|
||||
static const char* const OB_SV_DEFAULT_REPLICA_NUM = "ob_default_replica_num";
|
||||
static const char* const OB_SV_INTERM_RESULT_MEM_LIMIT = "ob_interm_result_mem_limit";
|
||||
static const char* const OB_SV_PROXY_PARTITION_HIT = "ob_proxy_partition_hit";
|
||||
static const char* const OB_SV_LOG_LEVEL = "ob_log_level";
|
||||
static const char* const OB_SV_MAX_PARALLEL_DEGREE = "ob_max_parallel_degree";
|
||||
static const char* const OB_SV_QUERY_TIMEOUT = "ob_query_timeout";
|
||||
static const char* const OB_SV_READ_CONSISTENCY = "ob_read_consistency";
|
||||
static const char* const OB_SV_ENABLE_TRANSFORMATION = "ob_enable_transformation";
|
||||
static const char* const OB_SV_TRX_TIMEOUT = "ob_trx_timeout";
|
||||
static const char* const OB_SV_ENABLE_PLAN_CACHE = "ob_enable_plan_cache";
|
||||
static const char* const OB_SV_ENABLE_INDEX_DIRECT_SELECT = "ob_enable_index_direct_select";
|
||||
static const char* const OB_SV_PROXY_SET_TRX_EXECUTED = "ob_proxy_set_trx_executed";
|
||||
static const char* const OB_SV_ENABLE_AGGREGATION_PUSHDOWN = "ob_enable_aggregation_pushdown";
|
||||
static const char* const OB_SV_LAST_SCHEMA_VERSION = "ob_last_schema_version";
|
||||
static const char* const OB_SV_GLOBAL_DEBUG_SYNC = "ob_global_debug_sync";
|
||||
static const char* const OB_SV_PROXY_GLOBAL_VARIABLES_VERSION = "ob_proxy_global_variables_version";
|
||||
static const char* const OB_SV_ENABLE_TRACE_LOG = "ob_enable_trace_log";
|
||||
static const char* const OB_SV_ENABLE_HASH_GROUP_BY = "ob_enable_hash_group_by";
|
||||
static const char* const OB_SV_ENABLE_BLK_NESTEDLOOP_JOIN = "ob_enable_blk_nestedloop_join";
|
||||
static const char* const OB_SV_BNL_JOIN_CACHE_SIZE = "ob_bnl_join_cache_size";
|
||||
static const char* const OB_SV_PROXY_USER_PRIVILEGE = "ob_proxy_user_privilege";
|
||||
static const char* const OB_SV_ORG_CLUSTER_ID = "ob_org_cluster_id";
|
||||
static const char* const OB_SV_PLAN_CACHE_PERCENTAGE = "ob_plan_cache_percentage";
|
||||
static const char* const OB_SV_PLAN_CACHE_EVICT_HIGH_PERCENTAGE = "ob_plan_cache_evict_high_percentage";
|
||||
static const char* const OB_SV_PLAN_CACHE_EVICT_LOW_PERCENTAGE = "ob_plan_cache_evict_low_percentage";
|
||||
static const char* const OB_SV_RECYCLEBIN = "recyclebin";
|
||||
static const char* const OB_SV_CAPABILITY_FLAG = "ob_capability_flag";
|
||||
static const char* const OB_SV_STMT_PARALLEL_DEGREE = "ob_stmt_parallel_degree";
|
||||
static const char* const OB_SV_IS_RESULT_ACCURATE = "is_result_accurate";
|
||||
static const char* const OB_SV_ERROR_ON_OVERLAP_TIME = "error_on_overlap_time";
|
||||
static const char* const OB_SV_COMPATIBILITY_MODE = "ob_compatibility_mode";
|
||||
static const char* const OB_SV_CREATE_TABLE_STRICT_MODE = "ob_create_table_strict_mode";
|
||||
static const char* const OB_SV_SQL_WORK_AREA_PERCENTAGE = "ob_sql_work_area_percentage";
|
||||
static const char* const OB_SV_SAFE_WEAK_READ_SNAPSHOT = "ob_safe_weak_read_snapshot";
|
||||
static const char* const OB_SV_ROUTE_POLICY = "ob_route_policy";
|
||||
static const char* const OB_SV_ENABLE_TRANSMISSION_CHECKSUM = "ob_enable_transmission_checksum";
|
||||
static const char* const OB_SV_FOREIGN_KEY_CHECKS = "foreign_key_checks";
|
||||
static const char* const OB_SV_STATEMENT_TRACE_ID = "ob_statement_trace_id";
|
||||
static const char* const OB_SV_ENABLE_TRUNCATE_FLASHBACK = "ob_enable_truncate_flashback";
|
||||
static const char* const OB_SV_TCP_INVITED_NODES = "ob_tcp_invited_nodes";
|
||||
static const char* const OB_SV_SQL_THROTTLE_CURRENT_PRIORITY = "sql_throttle_current_priority";
|
||||
static const char* const OB_SV_SQL_THROTTLE_PRIORITY = "sql_throttle_priority";
|
||||
static const char* const OB_SV_SQL_THROTTLE_RT = "sql_throttle_rt";
|
||||
static const char* const OB_SV_SQL_THROTTLE_CPU = "sql_throttle_cpu";
|
||||
static const char* const OB_SV_SQL_THROTTLE_IO = "sql_throttle_io";
|
||||
static const char* const OB_SV_SQL_THROTTLE_NETWORK = "sql_throttle_network";
|
||||
static const char* const OB_SV_SQL_THROTTLE_LOGICAL_READS = "sql_throttle_logical_reads";
|
||||
static const char* const OB_SV_AUTO_INCREMENT_CACHE_SIZE = "auto_increment_cache_size";
|
||||
static const char* const OB_SV_ENABLE_JIT = "ob_enable_jit";
|
||||
static const char* const OB_SV_TEMP_TABLESPACE_SIZE_PERCENTAGE = "ob_temp_tablespace_size_percentage";
|
||||
static const char* const OB_SV__OPTIMIZER_ADAPTIVE_CURSOR_SHARING = "_optimizer_adaptive_cursor_sharing";
|
||||
static const char* const OB_SV_TIMESTAMP_SERVICE = "ob_timestamp_service";
|
||||
static const char* const OB_SV_PLUGIN_DIR = "plugin_dir";
|
||||
static const char* const OB_SV_UNDO_RETENTION = "undo_retention";
|
||||
static const char* const OB_SV__OB_USE_PARALLEL_EXECUTION = "_ob_use_parallel_execution";
|
||||
static const char* const OB_SV_SQL_AUDIT_PERCENTAGE = "ob_sql_audit_percentage";
|
||||
static const char* const OB_SV_ENABLE_SQL_AUDIT = "ob_enable_sql_audit";
|
||||
static const char* const OB_SV_OPTIMIZER_USE_SQL_PLAN_BASELINES = "optimizer_use_sql_plan_baselines";
|
||||
static const char* const OB_SV_OPTIMIZER_CAPTURE_SQL_PLAN_BASELINES = "optimizer_capture_sql_plan_baselines";
|
||||
static const char* const OB_SV_PARALLEL_MAX_SERVERS = "parallel_max_servers";
|
||||
static const char* const OB_SV_PARALLEL_SERVERS_TARGET = "parallel_servers_target";
|
||||
static const char* const OB_SV_EARLY_LOCK_RELEASE = "ob_early_lock_release";
|
||||
static const char* const OB_SV_TRX_IDLE_TIMEOUT = "ob_trx_idle_timeout";
|
||||
static const char* const OB_SV_BLOCK_ENCRYPTION_MODE = "block_encryption_mode";
|
||||
static const char* const OB_SV_NLS_DATE_FORMAT = "nls_date_format";
|
||||
static const char* const OB_SV_NLS_TIMESTAMP_FORMAT = "nls_timestamp_format";
|
||||
static const char* const OB_SV_NLS_TIMESTAMP_TZ_FORMAT = "nls_timestamp_tz_format";
|
||||
static const char* const OB_SV_RESERVED_META_MEMORY_PERCENTAGE = "ob_reserved_meta_memory_percentage";
|
||||
static const char* const OB_SV_CHECK_SYS_VARIABLE = "ob_check_sys_variable";
|
||||
static const char* const OB_SV_NLS_LANGUAGE = "nls_language";
|
||||
static const char* const OB_SV_NLS_TERRITORY = "nls_territory";
|
||||
static const char* const OB_SV_NLS_SORT = "nls_sort";
|
||||
static const char* const OB_SV_NLS_COMP = "nls_comp";
|
||||
static const char* const OB_SV_NLS_CHARACTERSET = "nls_characterset";
|
||||
static const char* const OB_SV_NLS_NCHAR_CHARACTERSET = "nls_nchar_characterset";
|
||||
static const char* const OB_SV_NLS_DATE_LANGUAGE = "nls_date_language";
|
||||
static const char* const OB_SV_NLS_LENGTH_SEMANTICS = "nls_length_semantics";
|
||||
static const char* const OB_SV_NLS_NCHAR_CONV_EXCP = "nls_nchar_conv_excp";
|
||||
static const char* const OB_SV_NLS_CALENDAR = "nls_calendar";
|
||||
static const char* const OB_SV_NLS_NUMERIC_CHARACTERS = "nls_numeric_characters";
|
||||
static const char* const OB_SV__NLJ_BATCHING_ENABLED = "_nlj_batching_enabled";
|
||||
static const char* const OB_SV_TRACEFILE_IDENTIFIER = "tracefile_identifier";
|
||||
static const char* const OB_SV__GROUPBY_NOPUSHDOWN_CUT_RATIO = "_groupby_nopushdown_cut_ratio";
|
||||
static const char* const OB_SV__PX_BROADCAST_FUDGE_FACTOR = "_px_broadcast_fudge_factor";
|
||||
static const char* const OB_SV__PRIMARY_ZONE_ENTITY_COUNT = "_primary_zone_entity_count";
|
||||
static const char* const OB_SV_TRANSACTION_ISOLATION = "transaction_isolation";
|
||||
static const char* const OB_SV_TRX_LOCK_TIMEOUT = "ob_trx_lock_timeout";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_CHECK_USER_NAME = "validate_password_check_user_name";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_LENGTH = "validate_password_length";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_MIXED_CASE_COUNT = "validate_password_mixed_case_count";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_NUMBER_COUNT = "validate_password_number_count";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_POLICY = "validate_password_policy";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_SPECIAL_CHAR_COUNT = "validate_password_special_char_count";
|
||||
static const char* const OB_SV_DEFAULT_PASSWORD_LIFETIME = "default_password_lifetime";
|
||||
static const char* const OB_SV_TRACE_INFO = "ob_trace_info";
|
||||
static const char* const OB_SV_ENABLE_BATCHED_MULTI_STATEMENT = "ob_enable_batched_multi_statement";
|
||||
static const char* const OB_SV__PX_PARTITION_SCAN_THRESHOLD = "_px_partition_scan_threshold";
|
||||
static const char* const OB_SV__OB_PX_BCAST_OPTIMIZATION = "_ob_px_bcast_optimization";
|
||||
static const char* const OB_SV__OB_PX_SLAVE_MAPPING_THRESHOLD = "_ob_px_slave_mapping_threshold";
|
||||
static const char* const OB_SV__ENABLE_PARALLEL_DML = "_enable_parallel_dml";
|
||||
static const char* const OB_SV__PX_MIN_GRANULES_PER_SLAVE = "_px_min_granules_per_slave";
|
||||
static const char* const OB_SV_SECURE_FILE_PRIV = "secure_file_priv";
|
||||
static const char* const OB_SV_PLSQL_WARNINGS = "plsql_warnings";
|
||||
static const char* const OB_SV__ENABLE_PARALLEL_QUERY = "_enable_parallel_query";
|
||||
static const char* const OB_SV__FORCE_PARALLEL_QUERY_DOP = "_force_parallel_query_dop";
|
||||
static const char* const OB_SV__FORCE_PARALLEL_DML_DOP = "_force_parallel_dml_dop";
|
||||
static const char* const OB_SV_PL_BLOCK_TIMEOUT = "ob_pl_block_timeout";
|
||||
static const char* const OB_SV_TRANSACTION_READ_ONLY = "transaction_read_only";
|
||||
static const char* const OB_SV_RESOURCE_MANAGER_PLAN = "resource_manager_plan";
|
||||
static const char* const OB_SV_PERFORMANCE_SCHEMA = "performance_schema";
|
||||
static const char* const OB_SV_NLS_CURRENCY = "nls_currency";
|
||||
static const char* const OB_SV_NLS_ISO_CURRENCY = "nls_iso_currency";
|
||||
static const char* const OB_SV_NLS_DUAL_CURRENCY = "nls_dual_currency";
|
||||
static const char* const OB_SV__OB_PROXY_SESSION_TEMPORARY_TABLE_USED = "_ob_proxy_session_temporary_table_used";
|
||||
namespace oceanbase
|
||||
{
|
||||
namespace share
|
||||
{
|
||||
static const char* const OB_SV_AUTO_INCREMENT_INCREMENT = "auto_increment_increment";
|
||||
static const char* const OB_SV_AUTO_INCREMENT_OFFSET = "auto_increment_offset";
|
||||
static const char* const OB_SV_AUTOCOMMIT = "autocommit";
|
||||
static const char* const OB_SV_CHARACTER_SET_CLIENT = "character_set_client";
|
||||
static const char* const OB_SV_CHARACTER_SET_CONNECTION = "character_set_connection";
|
||||
static const char* const OB_SV_CHARACTER_SET_DATABASE = "character_set_database";
|
||||
static const char* const OB_SV_CHARACTER_SET_RESULTS = "character_set_results";
|
||||
static const char* const OB_SV_CHARACTER_SET_SERVER = "character_set_server";
|
||||
static const char* const OB_SV_CHARACTER_SET_SYSTEM = "character_set_system";
|
||||
static const char* const OB_SV_COLLATION_CONNECTION = "collation_connection";
|
||||
static const char* const OB_SV_COLLATION_DATABASE = "collation_database";
|
||||
static const char* const OB_SV_COLLATION_SERVER = "collation_server";
|
||||
static const char* const OB_SV_INTERACTIVE_TIMEOUT = "interactive_timeout";
|
||||
static const char* const OB_SV_LAST_INSERT_ID = "last_insert_id";
|
||||
static const char* const OB_SV_MAX_ALLOWED_PACKET = "max_allowed_packet";
|
||||
static const char* const OB_SV_SQL_MODE = "sql_mode";
|
||||
static const char* const OB_SV_TIME_ZONE = "time_zone";
|
||||
static const char* const OB_SV_TX_ISOLATION = "tx_isolation";
|
||||
static const char* const OB_SV_VERSION_COMMENT = "version_comment";
|
||||
static const char* const OB_SV_WAIT_TIMEOUT = "wait_timeout";
|
||||
static const char* const OB_SV_BINLOG_ROW_IMAGE = "binlog_row_image";
|
||||
static const char* const OB_SV_CHARACTER_SET_FILESYSTEM = "character_set_filesystem";
|
||||
static const char* const OB_SV_CONNECT_TIMEOUT = "connect_timeout";
|
||||
static const char* const OB_SV_DATADIR = "datadir";
|
||||
static const char* const OB_SV_DEBUG_SYNC = "debug_sync";
|
||||
static const char* const OB_SV_DIV_PRECISION_INCREMENT = "div_precision_increment";
|
||||
static const char* const OB_SV_EXPLICIT_DEFAULTS_FOR_TIMESTAMP = "explicit_defaults_for_timestamp";
|
||||
static const char* const OB_SV_GROUP_CONCAT_MAX_LEN = "group_concat_max_len";
|
||||
static const char* const OB_SV_IDENTITY = "identity";
|
||||
static const char* const OB_SV_LOWER_CASE_TABLE_NAMES = "lower_case_table_names";
|
||||
static const char* const OB_SV_NET_READ_TIMEOUT = "net_read_timeout";
|
||||
static const char* const OB_SV_NET_WRITE_TIMEOUT = "net_write_timeout";
|
||||
static const char* const OB_SV_READ_ONLY = "read_only";
|
||||
static const char* const OB_SV_SQL_AUTO_IS_NULL = "sql_auto_is_null";
|
||||
static const char* const OB_SV_SQL_SELECT_LIMIT = "sql_select_limit";
|
||||
static const char* const OB_SV_TIMESTAMP = "timestamp";
|
||||
static const char* const OB_SV_TX_READ_ONLY = "tx_read_only";
|
||||
static const char* const OB_SV_VERSION = "version";
|
||||
static const char* const OB_SV_SQL_WARNINGS = "sql_warnings";
|
||||
static const char* const OB_SV_MAX_USER_CONNECTIONS = "max_user_connections";
|
||||
static const char* const OB_SV_INIT_CONNECT = "init_connect";
|
||||
static const char* const OB_SV_LICENSE = "license";
|
||||
static const char* const OB_SV_NET_BUFFER_LENGTH = "net_buffer_length";
|
||||
static const char* const OB_SV_SYSTEM_TIME_ZONE = "system_time_zone";
|
||||
static const char* const OB_SV_QUERY_CACHE_SIZE = "query_cache_size";
|
||||
static const char* const OB_SV_QUERY_CACHE_TYPE = "query_cache_type";
|
||||
static const char* const OB_SV_SQL_QUOTE_SHOW_CREATE = "sql_quote_show_create";
|
||||
static const char* const OB_SV_MAX_SP_RECURSION_DEPTH = "max_sp_recursion_depth";
|
||||
static const char* const OB_SV_SQL_SAFE_UPDATES = "sql_safe_updates";
|
||||
static const char* const OB_SV_CONCURRENT_INSERT = "concurrent_insert";
|
||||
static const char* const OB_SV_DEFAULT_AUTHENTICATION_PLUGIN = "default_authentication_plugin";
|
||||
static const char* const OB_SV_DISABLED_STORAGE_ENGINES = "disabled_storage_engines";
|
||||
static const char* const OB_SV_ERROR_COUNT = "error_count";
|
||||
static const char* const OB_SV_GENERAL_LOG = "general_log";
|
||||
static const char* const OB_SV_HAVE_OPENSSL = "have_openssl";
|
||||
static const char* const OB_SV_HAVE_PROFILING = "have_profiling";
|
||||
static const char* const OB_SV_HAVE_SSL = "have_ssl";
|
||||
static const char* const OB_SV_HOSTNAME = "hostname";
|
||||
static const char* const OB_SV_LC_MESSAGES = "lc_messages";
|
||||
static const char* const OB_SV_LOCAL_INFILE = "local_infile";
|
||||
static const char* const OB_SV_LOCK_WAIT_TIMEOUT = "lock_wait_timeout";
|
||||
static const char* const OB_SV_LONG_QUERY_TIME = "long_query_time";
|
||||
static const char* const OB_SV_MAX_CONNECTIONS = "max_connections";
|
||||
static const char* const OB_SV_MAX_EXECUTION_TIME = "max_execution_time";
|
||||
static const char* const OB_SV_PROTOCOL_VERSION = "protocol_version";
|
||||
static const char* const OB_SV_SERVER_ID = "server_id";
|
||||
static const char* const OB_SV_SSL_CA = "ssl_ca";
|
||||
static const char* const OB_SV_SSL_CAPATH = "ssl_capath";
|
||||
static const char* const OB_SV_SSL_CERT = "ssl_cert";
|
||||
static const char* const OB_SV_SSL_CIPHER = "ssl_cipher";
|
||||
static const char* const OB_SV_SSL_CRL = "ssl_crl";
|
||||
static const char* const OB_SV_SSL_CRLPATH = "ssl_crlpath";
|
||||
static const char* const OB_SV_SSL_KEY = "ssl_key";
|
||||
static const char* const OB_SV_TIME_FORMAT = "time_format";
|
||||
static const char* const OB_SV_TLS_VERSION = "tls_version";
|
||||
static const char* const OB_SV_TMP_TABLE_SIZE = "tmp_table_size";
|
||||
static const char* const OB_SV_TMPDIR = "tmpdir";
|
||||
static const char* const OB_SV_UNIQUE_CHECKS = "unique_checks";
|
||||
static const char* const OB_SV_VERSION_COMPILE_MACHINE = "version_compile_machine";
|
||||
static const char* const OB_SV_VERSION_COMPILE_OS = "version_compile_os";
|
||||
static const char* const OB_SV_WARNING_COUNT = "warning_count";
|
||||
static const char* const OB_SV_SESSION_TRACK_SCHEMA = "session_track_schema";
|
||||
static const char* const OB_SV_SESSION_TRACK_SYSTEM_VARIABLES = "session_track_system_variables";
|
||||
static const char* const OB_SV_SESSION_TRACK_STATE_CHANGE = "session_track_state_change";
|
||||
static const char* const OB_SV_DEFAULT_REPLICA_NUM = "ob_default_replica_num";
|
||||
static const char* const OB_SV_INTERM_RESULT_MEM_LIMIT = "ob_interm_result_mem_limit";
|
||||
static const char* const OB_SV_PROXY_PARTITION_HIT = "ob_proxy_partition_hit";
|
||||
static const char* const OB_SV_LOG_LEVEL = "ob_log_level";
|
||||
static const char* const OB_SV_MAX_PARALLEL_DEGREE = "ob_max_parallel_degree";
|
||||
static const char* const OB_SV_QUERY_TIMEOUT = "ob_query_timeout";
|
||||
static const char* const OB_SV_READ_CONSISTENCY = "ob_read_consistency";
|
||||
static const char* const OB_SV_ENABLE_TRANSFORMATION = "ob_enable_transformation";
|
||||
static const char* const OB_SV_TRX_TIMEOUT = "ob_trx_timeout";
|
||||
static const char* const OB_SV_ENABLE_PLAN_CACHE = "ob_enable_plan_cache";
|
||||
static const char* const OB_SV_ENABLE_INDEX_DIRECT_SELECT = "ob_enable_index_direct_select";
|
||||
static const char* const OB_SV_PROXY_SET_TRX_EXECUTED = "ob_proxy_set_trx_executed";
|
||||
static const char* const OB_SV_ENABLE_AGGREGATION_PUSHDOWN = "ob_enable_aggregation_pushdown";
|
||||
static const char* const OB_SV_LAST_SCHEMA_VERSION = "ob_last_schema_version";
|
||||
static const char* const OB_SV_GLOBAL_DEBUG_SYNC = "ob_global_debug_sync";
|
||||
static const char* const OB_SV_PROXY_GLOBAL_VARIABLES_VERSION = "ob_proxy_global_variables_version";
|
||||
static const char* const OB_SV_ENABLE_TRACE_LOG = "ob_enable_trace_log";
|
||||
static const char* const OB_SV_ENABLE_HASH_GROUP_BY = "ob_enable_hash_group_by";
|
||||
static const char* const OB_SV_ENABLE_BLK_NESTEDLOOP_JOIN = "ob_enable_blk_nestedloop_join";
|
||||
static const char* const OB_SV_BNL_JOIN_CACHE_SIZE = "ob_bnl_join_cache_size";
|
||||
static const char* const OB_SV_PROXY_USER_PRIVILEGE = "ob_proxy_user_privilege";
|
||||
static const char* const OB_SV_ORG_CLUSTER_ID = "ob_org_cluster_id";
|
||||
static const char* const OB_SV_PLAN_CACHE_PERCENTAGE = "ob_plan_cache_percentage";
|
||||
static const char* const OB_SV_PLAN_CACHE_EVICT_HIGH_PERCENTAGE = "ob_plan_cache_evict_high_percentage";
|
||||
static const char* const OB_SV_PLAN_CACHE_EVICT_LOW_PERCENTAGE = "ob_plan_cache_evict_low_percentage";
|
||||
static const char* const OB_SV_RECYCLEBIN = "recyclebin";
|
||||
static const char* const OB_SV_CAPABILITY_FLAG = "ob_capability_flag";
|
||||
static const char* const OB_SV_STMT_PARALLEL_DEGREE = "ob_stmt_parallel_degree";
|
||||
static const char* const OB_SV_IS_RESULT_ACCURATE = "is_result_accurate";
|
||||
static const char* const OB_SV_ERROR_ON_OVERLAP_TIME = "error_on_overlap_time";
|
||||
static const char* const OB_SV_COMPATIBILITY_MODE = "ob_compatibility_mode";
|
||||
static const char* const OB_SV_CREATE_TABLE_STRICT_MODE = "ob_create_table_strict_mode";
|
||||
static const char* const OB_SV_SQL_WORK_AREA_PERCENTAGE = "ob_sql_work_area_percentage";
|
||||
static const char* const OB_SV_SAFE_WEAK_READ_SNAPSHOT = "ob_safe_weak_read_snapshot";
|
||||
static const char* const OB_SV_ROUTE_POLICY = "ob_route_policy";
|
||||
static const char* const OB_SV_ENABLE_TRANSMISSION_CHECKSUM = "ob_enable_transmission_checksum";
|
||||
static const char* const OB_SV_FOREIGN_KEY_CHECKS = "foreign_key_checks";
|
||||
static const char* const OB_SV_STATEMENT_TRACE_ID = "ob_statement_trace_id";
|
||||
static const char* const OB_SV_ENABLE_TRUNCATE_FLASHBACK = "ob_enable_truncate_flashback";
|
||||
static const char* const OB_SV_TCP_INVITED_NODES = "ob_tcp_invited_nodes";
|
||||
static const char* const OB_SV_SQL_THROTTLE_CURRENT_PRIORITY = "sql_throttle_current_priority";
|
||||
static const char* const OB_SV_SQL_THROTTLE_PRIORITY = "sql_throttle_priority";
|
||||
static const char* const OB_SV_SQL_THROTTLE_RT = "sql_throttle_rt";
|
||||
static const char* const OB_SV_SQL_THROTTLE_CPU = "sql_throttle_cpu";
|
||||
static const char* const OB_SV_SQL_THROTTLE_IO = "sql_throttle_io";
|
||||
static const char* const OB_SV_SQL_THROTTLE_NETWORK = "sql_throttle_network";
|
||||
static const char* const OB_SV_SQL_THROTTLE_LOGICAL_READS = "sql_throttle_logical_reads";
|
||||
static const char* const OB_SV_AUTO_INCREMENT_CACHE_SIZE = "auto_increment_cache_size";
|
||||
static const char* const OB_SV_ENABLE_JIT = "ob_enable_jit";
|
||||
static const char* const OB_SV_TEMP_TABLESPACE_SIZE_PERCENTAGE = "ob_temp_tablespace_size_percentage";
|
||||
static const char* const OB_SV__OPTIMIZER_ADAPTIVE_CURSOR_SHARING = "_optimizer_adaptive_cursor_sharing";
|
||||
static const char* const OB_SV_TIMESTAMP_SERVICE = "ob_timestamp_service";
|
||||
static const char* const OB_SV_PLUGIN_DIR = "plugin_dir";
|
||||
static const char* const OB_SV_UNDO_RETENTION = "undo_retention";
|
||||
static const char* const OB_SV__OB_USE_PARALLEL_EXECUTION = "_ob_use_parallel_execution";
|
||||
static const char* const OB_SV_SQL_AUDIT_PERCENTAGE = "ob_sql_audit_percentage";
|
||||
static const char* const OB_SV_ENABLE_SQL_AUDIT = "ob_enable_sql_audit";
|
||||
static const char* const OB_SV_OPTIMIZER_USE_SQL_PLAN_BASELINES = "optimizer_use_sql_plan_baselines";
|
||||
static const char* const OB_SV_OPTIMIZER_CAPTURE_SQL_PLAN_BASELINES = "optimizer_capture_sql_plan_baselines";
|
||||
static const char* const OB_SV_PARALLEL_MAX_SERVERS = "parallel_max_servers";
|
||||
static const char* const OB_SV_PARALLEL_SERVERS_TARGET = "parallel_servers_target";
|
||||
static const char* const OB_SV_EARLY_LOCK_RELEASE = "ob_early_lock_release";
|
||||
static const char* const OB_SV_TRX_IDLE_TIMEOUT = "ob_trx_idle_timeout";
|
||||
static const char* const OB_SV_BLOCK_ENCRYPTION_MODE = "block_encryption_mode";
|
||||
static const char* const OB_SV_NLS_DATE_FORMAT = "nls_date_format";
|
||||
static const char* const OB_SV_NLS_TIMESTAMP_FORMAT = "nls_timestamp_format";
|
||||
static const char* const OB_SV_NLS_TIMESTAMP_TZ_FORMAT = "nls_timestamp_tz_format";
|
||||
static const char* const OB_SV_RESERVED_META_MEMORY_PERCENTAGE = "ob_reserved_meta_memory_percentage";
|
||||
static const char* const OB_SV_CHECK_SYS_VARIABLE = "ob_check_sys_variable";
|
||||
static const char* const OB_SV_NLS_LANGUAGE = "nls_language";
|
||||
static const char* const OB_SV_NLS_TERRITORY = "nls_territory";
|
||||
static const char* const OB_SV_NLS_SORT = "nls_sort";
|
||||
static const char* const OB_SV_NLS_COMP = "nls_comp";
|
||||
static const char* const OB_SV_NLS_CHARACTERSET = "nls_characterset";
|
||||
static const char* const OB_SV_NLS_NCHAR_CHARACTERSET = "nls_nchar_characterset";
|
||||
static const char* const OB_SV_NLS_DATE_LANGUAGE = "nls_date_language";
|
||||
static const char* const OB_SV_NLS_LENGTH_SEMANTICS = "nls_length_semantics";
|
||||
static const char* const OB_SV_NLS_NCHAR_CONV_EXCP = "nls_nchar_conv_excp";
|
||||
static const char* const OB_SV_NLS_CALENDAR = "nls_calendar";
|
||||
static const char* const OB_SV_NLS_NUMERIC_CHARACTERS = "nls_numeric_characters";
|
||||
static const char* const OB_SV__NLJ_BATCHING_ENABLED = "_nlj_batching_enabled";
|
||||
static const char* const OB_SV_TRACEFILE_IDENTIFIER = "tracefile_identifier";
|
||||
static const char* const OB_SV__GROUPBY_NOPUSHDOWN_CUT_RATIO = "_groupby_nopushdown_cut_ratio";
|
||||
static const char* const OB_SV__PX_BROADCAST_FUDGE_FACTOR = "_px_broadcast_fudge_factor";
|
||||
static const char* const OB_SV__PRIMARY_ZONE_ENTITY_COUNT = "_primary_zone_entity_count";
|
||||
static const char* const OB_SV_TRANSACTION_ISOLATION = "transaction_isolation";
|
||||
static const char* const OB_SV_TRX_LOCK_TIMEOUT = "ob_trx_lock_timeout";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_CHECK_USER_NAME = "validate_password_check_user_name";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_LENGTH = "validate_password_length";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_MIXED_CASE_COUNT = "validate_password_mixed_case_count";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_NUMBER_COUNT = "validate_password_number_count";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_POLICY = "validate_password_policy";
|
||||
static const char* const OB_SV_VALIDATE_PASSWORD_SPECIAL_CHAR_COUNT = "validate_password_special_char_count";
|
||||
static const char* const OB_SV_DEFAULT_PASSWORD_LIFETIME = "default_password_lifetime";
|
||||
static const char* const OB_SV_TRACE_INFO = "ob_trace_info";
|
||||
static const char* const OB_SV_ENABLE_BATCHED_MULTI_STATEMENT = "ob_enable_batched_multi_statement";
|
||||
static const char* const OB_SV__PX_PARTITION_SCAN_THRESHOLD = "_px_partition_scan_threshold";
|
||||
static const char* const OB_SV__OB_PX_BCAST_OPTIMIZATION = "_ob_px_bcast_optimization";
|
||||
static const char* const OB_SV__OB_PX_SLAVE_MAPPING_THRESHOLD = "_ob_px_slave_mapping_threshold";
|
||||
static const char* const OB_SV__ENABLE_PARALLEL_DML = "_enable_parallel_dml";
|
||||
static const char* const OB_SV__PX_MIN_GRANULES_PER_SLAVE = "_px_min_granules_per_slave";
|
||||
static const char* const OB_SV_SECURE_FILE_PRIV = "secure_file_priv";
|
||||
static const char* const OB_SV_PLSQL_WARNINGS = "plsql_warnings";
|
||||
static const char* const OB_SV__ENABLE_PARALLEL_QUERY = "_enable_parallel_query";
|
||||
static const char* const OB_SV__FORCE_PARALLEL_QUERY_DOP = "_force_parallel_query_dop";
|
||||
static const char* const OB_SV__FORCE_PARALLEL_DML_DOP = "_force_parallel_dml_dop";
|
||||
static const char* const OB_SV_PL_BLOCK_TIMEOUT = "ob_pl_block_timeout";
|
||||
static const char* const OB_SV_TRANSACTION_READ_ONLY = "transaction_read_only";
|
||||
static const char* const OB_SV_RESOURCE_MANAGER_PLAN = "resource_manager_plan";
|
||||
static const char* const OB_SV_PERFORMANCE_SCHEMA = "performance_schema";
|
||||
static const char* const OB_SV_NLS_CURRENCY = "nls_currency";
|
||||
static const char* const OB_SV_NLS_ISO_CURRENCY = "nls_iso_currency";
|
||||
static const char* const OB_SV_NLS_DUAL_CURRENCY = "nls_dual_currency";
|
||||
static const char* const OB_SV__OB_PROXY_SESSION_TEMPORARY_TABLE_USED = "_ob_proxy_session_temporary_table_used";
|
||||
|
||||
}
|
||||
}
|
||||
#endif //OCEANBASE_COMMON_OB_SYSTEM_VARIABLE_ALIAS_H_
|
||||
|
||||
} // namespace share
|
||||
} // namespace oceanbase
|
||||
#endif // OCEANBASE_COMMON_OB_SYSTEM_VARIABLE_ALIAS_H_
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
@ -15,9 +15,13 @@
|
||||
#include "share/system_variable/ob_sys_var_class_type.h"
|
||||
#include <stdint.h>
|
||||
#include "common/object/ob_object.h"
|
||||
namespace oceanbase {
|
||||
namespace share {
|
||||
struct ObSysVarFlag {
|
||||
namespace oceanbase
|
||||
{
|
||||
namespace share
|
||||
{
|
||||
// ObSysVarFlag的值不可随意增删改, 有任何增删改要同时同步到sql/session/gen_ob_sys_variables.py的flag_value_dict变量中
|
||||
struct ObSysVarFlag
|
||||
{
|
||||
const static int64_t NONE = 0LL;
|
||||
const static int64_t GLOBAL_SCOPE = 1LL;
|
||||
const static int64_t SESSION_SCOPE = (1LL << 1);
|
||||
@ -33,7 +37,7 @@ struct ObSysVarFlag {
|
||||
const static int64_t WITH_UPGRADE = (1LL << 11);
|
||||
const static int64_t MYSQL_ONLY = (1LL << 12);
|
||||
};
|
||||
struct ObSysVarFromJson {
|
||||
struct ObSysVarFromJson{
|
||||
ObSysVarClassType id_;
|
||||
common::ObString name_;
|
||||
common::ObObjType data_type_;
|
||||
@ -52,28 +56,11 @@ struct ObSysVarFromJson {
|
||||
common::ObString get_meta_type_func_;
|
||||
common::ObString session_special_update_func_;
|
||||
|
||||
ObSysVarFromJson()
|
||||
: id_(SYS_VAR_INVALID),
|
||||
name_(""),
|
||||
data_type_(common::ObNullType),
|
||||
value_(""),
|
||||
min_val_(""),
|
||||
max_val_(""),
|
||||
enum_names_(""),
|
||||
info_(""),
|
||||
flags_(ObSysVarFlag::NONE),
|
||||
alias_(""),
|
||||
base_class_(""),
|
||||
on_check_and_convert_func_(),
|
||||
on_update_func_(),
|
||||
to_select_obj_func_(),
|
||||
to_show_str_func_(),
|
||||
get_meta_type_func_(),
|
||||
session_special_update_func_()
|
||||
{}
|
||||
ObSysVarFromJson():id_(SYS_VAR_INVALID), name_(""), data_type_(common::ObNullType), value_(""), min_val_(""), max_val_(""), enum_names_(""), info_(""), flags_(ObSysVarFlag::NONE), alias_(""), base_class_(""), on_check_and_convert_func_(), on_update_func_(), to_select_obj_func_(), to_show_str_func_(), get_meta_type_func_(), session_special_update_func_() {}
|
||||
};
|
||||
|
||||
class ObSysVariables {
|
||||
class ObSysVariables
|
||||
{
|
||||
public:
|
||||
static int64_t get_all_sys_var_count();
|
||||
static ObSysVarClassType get_sys_var_id(int64_t i);
|
||||
@ -88,20 +75,21 @@ public:
|
||||
static bool is_oracle_only(int64_t i);
|
||||
static bool is_mysql_only(int64_t i);
|
||||
static common::ObString get_alias(int64_t i);
|
||||
static const common::ObObj& get_default_value(int64_t i);
|
||||
static const common::ObObj &get_default_value(int64_t i);
|
||||
static int64_t get_amount();
|
||||
static int set_value(const char* name, const char* new_value);
|
||||
static int set_value(const common::ObString& name, const common::ObString& new_value);
|
||||
static int set_value(const char *name, const char * new_value);
|
||||
static int set_value(const common::ObString &name, const common::ObString &new_value);
|
||||
static int init_default_values();
|
||||
};
|
||||
|
||||
class ObSysVarsToIdxMap {
|
||||
class ObSysVarsToIdxMap
|
||||
{
|
||||
public:
|
||||
static int64_t get_store_idx(int64_t var_id);
|
||||
static bool has_invalid_sys_var_id();
|
||||
};
|
||||
|
||||
} // end namespace share
|
||||
} // end namespace oceanbase
|
||||
} // end namespace share
|
||||
} // end namespace oceanbase
|
||||
|
||||
#endif /* OCEANBASE_SHARE_SYSTEM_VARIABLE_OB_SYSTEM_VARIABLE_INIT_ */
|
||||
|
||||
@ -1099,6 +1099,42 @@
|
||||
"background_cn": "",
|
||||
"ref_url": ""
|
||||
},
|
||||
"session_track_schema": {
|
||||
"id": 81,
|
||||
"name": "session_track_schema",
|
||||
"value": "1",
|
||||
"data_type": "bool",
|
||||
"info": "specifies whether return schema change info in ok packet",
|
||||
"flags": "GLOBAL | SESSION | MYSQL_ONLY",
|
||||
"publish_version": "312",
|
||||
"info_cn": "控制返回的ok包中是否包含schema变更的信息",
|
||||
"background_cn": "",
|
||||
"ref_url": "ob/product_functionality_review/pw3wd2"
|
||||
},
|
||||
"session_track_system_variables": {
|
||||
"id": 82,
|
||||
"name": "session_track_system_variables",
|
||||
"value": "time_zone, autocommit, character_set_client, character_set_results, character_set_connection",
|
||||
"data_type": "varchar",
|
||||
"info": "specifies whether return system variables change info in ok packet",
|
||||
"flags": "GLOBAL | SESSION | MYSQL_ONLY",
|
||||
"publish_version": "312",
|
||||
"info_cn": "控制返回的ok包中是否包含系统变量变更的信息",
|
||||
"background_cn": "",
|
||||
"ref_url": "ob/product_functionality_review/pw3wd2"
|
||||
},
|
||||
"session_track_state_change": {
|
||||
"id": 83,
|
||||
"name": "session_track_state_change",
|
||||
"value": "0",
|
||||
"data_type": "bool",
|
||||
"info": "specifies whether return session state change info in ok packet",
|
||||
"flags": "GLOBAL | SESSION | MYSQL_ONLY",
|
||||
"publish_version": "312",
|
||||
"info_cn": "控制返回的ok包中是否包含session状态变更的信息",
|
||||
"background_cn": "",
|
||||
"ref_url": "ob/product_functionality_review/pw3wd2"
|
||||
},
|
||||
"ob_default_replica_num": {
|
||||
"id": 10000,
|
||||
"name": "ob_default_replica_num",
|
||||
@ -2441,7 +2477,7 @@
|
||||
"publish_version": "226",
|
||||
"info_cn": "限制导入导出功能访问的路径",
|
||||
"background_cn": "导入导出功能未限制文件访问可能存在漏洞",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/sxwpug"
|
||||
"ref_url": "ob/product_functionality_review/sxwpug"
|
||||
},
|
||||
"plsql_warnings": {
|
||||
"id": 10103,
|
||||
@ -2454,7 +2490,7 @@
|
||||
"publish_version": "3.1.0",
|
||||
"info_cn": "控制pl/sql编译器的报错行为, 可以指定某类型或某个warning码的状态为:enable, disable, error",
|
||||
"background_cn": "pl/sql编译器的警告信息分成了几个分类, 这个系统参数可以控制这些警告信息的行为",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/xxibln"
|
||||
"ref_url": "ob/product_functionality_review/xxibln"
|
||||
},
|
||||
"_enable_parallel_query": {
|
||||
"id": 10104,
|
||||
@ -2466,7 +2502,7 @@
|
||||
"publish_version": "227",
|
||||
"info_cn": "在session上打开parallel query配置项, 查询默认情况下才可以被并行执行(parallel>=2)",
|
||||
"background_cn": "px上控制parallel的方式有很多, session上有对应的parallel的控制开关, 这个开关用于控制session级别的默认并行度是否可以大于等于2",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/tblezn"
|
||||
"ref_url": "ob/product_functionality_review/tblezn"
|
||||
},
|
||||
"_force_parallel_query_dop": {
|
||||
"id": 10105,
|
||||
@ -2478,7 +2514,7 @@
|
||||
"publish_version": "310",
|
||||
"info_cn": "在session上打开parallel query配置项, 并指定默认并行度",
|
||||
"background_cn": "px上控制parallel的方式有很多, session上有对应的parallel的控制开关, 这个变量用于设置session级别的 query 默认并行度大小",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/bpv992"
|
||||
"ref_url": "ob/product_functionality_review/bpv992"
|
||||
},
|
||||
"_force_parallel_dml_dop": {
|
||||
"id": 10106,
|
||||
@ -2490,7 +2526,7 @@
|
||||
"publish_version": "310",
|
||||
"info_cn": "在session上打开parallel dml配置项, 并指定默认并行度.当未通过 hint 指定 dml 并行度时, 会使用本变量值作为默认并行度",
|
||||
"background_cn": "px上控制parallel的方式有很多, session上有对应的parallel的控制开关, 这个变量用于设置session级别的 dml 默认并行度大小",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/bpv992"
|
||||
"ref_url": "ob/product_functionality_review/bpv992"
|
||||
},
|
||||
"ob_pl_block_timeout": {
|
||||
"id": 10107,
|
||||
@ -2505,7 +2541,7 @@
|
||||
"publish_version": "227",
|
||||
"info_cn": "",
|
||||
"background_cn": "",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/gry0a1"
|
||||
"ref_url": "ob/product_functionality_review/gry0a1"
|
||||
},
|
||||
"transaction_read_only": {
|
||||
"id": 10108,
|
||||
@ -2521,7 +2557,7 @@
|
||||
"publish_version": "320",
|
||||
"info_cn": "控制是否只允许开启只读事务",
|
||||
"background_cn": "用户可以通过这两个变量访问或者设置事务的访问模式, 当transaction_read_only设置为true时, 不允许执行dml语句",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/qcneoc"
|
||||
"ref_url": "ob/product_functionality_review/qcneoc"
|
||||
},
|
||||
"resource_manager_plan": {
|
||||
"id": 10109,
|
||||
@ -2533,7 +2569,7 @@
|
||||
"publish_version": "320",
|
||||
"info_cn": "指定租户的资源隔离计划",
|
||||
"background_cn": "租户内的普通线程和并行执行线程会相互抢占CPU资源, 通过给租户指定资源隔离计划, 可以控制资源抢占策略, 隔离资源使用量",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/do11tp"
|
||||
"ref_url": "ob/product_functionality_review/do11tp"
|
||||
},
|
||||
"performance_schema": {
|
||||
"id": 10110,
|
||||
@ -2545,7 +2581,7 @@
|
||||
"publish_version": "227",
|
||||
"info_cn": "向客户端声明是否支持 performance 信息查询",
|
||||
"background_cn": "纯兼容性变量.不支持 performance_schema 系统变量, 导致 8.0 JDBC 驱动在连接认证后初始化系统变量阶段执行 select @performance_schema 抛出异常",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/mg0sbv"
|
||||
"ref_url": "ob/product_functionality_review/mg0sbv"
|
||||
},
|
||||
"nls_currency": {
|
||||
"id": 10111,
|
||||
@ -2557,7 +2593,7 @@
|
||||
"publish_version": "320",
|
||||
"info_cn": "L数字格式元素的本地货币符号",
|
||||
"background_cn": "兼容 oracle number format model L 数字格式元素",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/efqk1r"
|
||||
"ref_url": "ob/product_functionality_review/efqk1r"
|
||||
},
|
||||
"nls_iso_currency": {
|
||||
"id": 10112,
|
||||
@ -2569,7 +2605,7 @@
|
||||
"publish_version": "320",
|
||||
"info_cn": "C数字格式元素的国际货币符号",
|
||||
"background_cn": "兼容 oracle number format model C 数字格式元素",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/efqk1r"
|
||||
"ref_url": "ob/product_functionality_review/efqk1r"
|
||||
},
|
||||
"nls_dual_currency": {
|
||||
"id": 10113,
|
||||
@ -2581,7 +2617,7 @@
|
||||
"publish_version": "320",
|
||||
"info_cn": "U数字格式元素的双货币符号",
|
||||
"background_cn": "兼容 oracle number format model U 数字格式元素",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/efqk1r"
|
||||
"ref_url": "ob/product_functionality_review/efqk1r"
|
||||
},
|
||||
"_ob_proxy_session_temporary_table_used": {
|
||||
"id": 10116,
|
||||
@ -2593,6 +2629,6 @@
|
||||
"publish_version": "310",
|
||||
"info_cn": "标记当前Session是否使用过Session级别临时表，用于告知proxy并修改路由决策",
|
||||
"background_cn": "为了解决Session临时表断链接时可能导致的问题，当Session临时表第一次使用后，后续请求Proxy只会路由到同一个Session",
|
||||
"ref_url": "https://yuque.antfin-inc.com/ob/product_functionality_review/hinq1e"
|
||||
"ref_url": "ob/product_functionality_review/hinq1e"
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user