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

[CP] add enable_dblink cfg

Browse Source
This commit is contained in:
obdev
2024-02-10 00:08:39 +00:00
committed by ob-robot
parent c37f9de8d2
commit 3ff08be727
8 changed files with 25 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/share/parameter/ob_parameter_seed.ipp
View File

@ -1616,6 +1616,9 @@ ERRSIM_DEF_STR(errsim_transfer_backfill_server_addr, OB_CLUSTER_PARAMETER, "",
DEF_BOOL(_ob_enable_direct_load, OB_CLUSTER_PARAMETER, "True",
"Enable or disable direct path load",
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
DEF_BOOL(enable_dblink, OB_CLUSTER_PARAMETER, "True",
"Enable or disable dblink",
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
DEF_BOOL(_px_join_skew_handling, OB_TENANT_PARAMETER, "False",
"enables skew handling for parallel joins. The default value is True.",
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));

5
src/sql/dblink/ob_dblink_utils.cpp
View File

@ -38,6 +38,11 @@ bool get_dblink_reuse_connection_cfg()
return tenant_config.is_valid() ? tenant_config->_enable_dblink_reuse_connection : true;
}
bool get_enable_dblink_cfg()
{
return GCONF.enable_dblink;
}
uint64_t ObDblinkService::get_current_tenant_id()
{
return MTL_ID();

3
src/sql/resolver/ddl/ob_create_dblink_resolver.cpp
View File

@ -43,6 +43,9 @@ int ObCreateDbLinkResolver::resolve(const ParseNode &parse_tree)
|| OB_UNLIKELY(node->num_child_ != DBLINK_NODE_COUNT)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("invalid parse tree", K(ret), KP(node), K(node->type_), K(T_CREATE_DBLINK), K(node->num_child_));
} else if (!GCONF.enable_dblink) {
ret = OB_OP_NOT_ALLOW;
LOG_WARN("dblink is disabled", K(ret));
} else if (OB_ISNULL(session_info_) || OB_ISNULL(schema_checker_)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("session info should not be null", K(ret));

3
src/sql/resolver/ddl/ob_drop_dblink_resolver.cpp
View File

@ -43,6 +43,9 @@ int ObDropDbLinkResolver::resolve(const ParseNode &parse_tree)
|| OB_UNLIKELY(node->num_child_ != DBLINK_NODE_COUNT)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("invalid parse tree", K(ret));
} else if (!GCONF.enable_dblink) {
ret = OB_OP_NOT_ALLOW;
LOG_WARN("dblink is disabled", K(ret));
} else if (OB_ISNULL(session_info_)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("session info should not be null", K(ret));