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

[CP] [to #55493381] fix synonym with create UDAF resolve

Browse Source
This commit is contained in:
obdev
2024-03-22 09:47:05 +00:00
committed by ob-robot
parent 961df8a087
commit d98a647a20
1 changed files with 36 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
src/sql/resolver/ddl/ob_create_routine_resolver.cpp
View File

@ -820,24 +820,47 @@ int ObCreateRoutineResolver::resolve_aggregate_body(
if (OB_ISNULL(udt_info) && ret != OB_ERR_NO_DB_SELECTED) { // try synonym if (OB_ISNULL(udt_info) && ret != OB_ERR_NO_DB_SELECTED) { // try synonym
uint64_t tenant_id = session_info_->get_effective_tenant_id(); uint64_t tenant_id = session_info_->get_effective_tenant_id();
uint64_t database_id = session_info_->get_database_id(); uint64_t database_id = session_info_->get_database_id();
ObSEArray<uint64_t, 4> syn_id_array; ObSynonymChecker synonym_checker;
uint64_t object_database_id = OB_INVALID_ID;
ObString object_name;
bool exist = false;
if (!db_name.empty() // try database name synonym if (!db_name.empty() // try database name synonym
&& (OB_FAIL(schema_checker_->get_database_id(tenant_id, db_name, database_id)) && (OB_FAIL(schema_checker_->get_database_id(tenant_id, db_name, database_id))
|| OB_INVALID_ID == database_id)) { || OB_INVALID_ID == database_id)) {
database_id = session_info_->get_database_id(); database_id = session_info_->get_database_id();
OZ (schema_checker_->get_obj_info_recursively_with_synonym( OZ (ObResolverUtils::resolve_synonym_object_recursively(*schema_checker_,
tenant_id, database_id, db_name, database_id, db_name, syn_id_array, true)); synonym_checker,
OZ (schema_checker_->get_udt_info(tenant_id, db_name, type_name, udt_info)); tenant_id,
} else { // try type name synonym database_id,
OZ (schema_checker_->get_obj_info_recursively_with_synonym( db_name,
tenant_id, database_id, type_name, database_id, type_name, syn_id_array, true)); object_database_id,
if (OB_SUCC(ret) && database_id != session_info_->get_database_id()) { object_name,
const share::schema::ObDatabaseSchema *database_schema = NULL; exist,
OZ (schema_checker_->get_database_schema(tenant_id, database_id, database_schema)); true));
CK (OB_NOT_NULL(database_schema)); if (OB_SUCC(ret) && exist) {
OX (real_db_name = database_schema->get_database_name_str()); OZ (schema_checker_->get_udt_info(tenant_id, object_name, type_name, udt_info));
}
} else { // try type name synonym
OZ (ObResolverUtils::resolve_synonym_object_recursively(*schema_checker_,
synonym_checker,
tenant_id,
database_id,
type_name,
object_database_id,
object_name,
exist,
true));
if (OB_FAIL(ret) || !exist) {
// do nothing ...
} else {
if (object_database_id != session_info_->get_database_id()) {
const share::schema::ObDatabaseSchema *database_schema = NULL;
OZ (schema_checker_->get_database_schema(tenant_id, object_database_id, database_schema));
CK (OB_NOT_NULL(database_schema));
OX (real_db_name = database_schema->get_database_name_str());
}
OZ (schema_checker_->get_udt_info(tenant_id, real_db_name, object_name, udt_info));
} }
OZ (schema_checker_->get_udt_info(tenant_id, real_db_name, type_name, udt_info));
} }
} }