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

to issue<53361277>:support flush pl cache single cache object

Browse Source
This commit is contained in:
obdev
2024-02-08 16:11:21 +00:00
committed by ob-robot
parent 201a6fc94d
commit f47be7342e
18 changed files with 281 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/sql/resolver/cmd/ob_alter_system_resolver.cpp
View File

@ -818,7 +818,8 @@ int ObFlushCacheResolver::resolve(const ParseNode &parse_tree)
} else if (OB_ISNULL(sql_id_node)) {
// do nothing
// currently, only support plan cache's fine-grained cache evict
} else if (stmt->flush_cache_arg_.cache_type_ != CACHE_TYPE_PLAN) {
} else if (stmt->flush_cache_arg_.cache_type_ != CACHE_TYPE_PLAN &&
stmt->flush_cache_arg_.cache_type_ != CACHE_TYPE_PL_OBJ) {
ret = OB_NOT_SUPPORTED;
LOG_WARN("only support plan cache's fine-grained cache evict", K(stmt->flush_cache_arg_.cache_type_), K(ret));
LOG_USER_ERROR(OB_NOT_SUPPORTED, "only support plan cache's fine-grained cache evict, other type");
@ -827,18 +828,25 @@ int ObFlushCacheResolver::resolve(const ParseNode &parse_tree)
LOG_WARN("not supported plan cache's fine-grained cache evict in oracle mode", K(ret));
LOG_USER_ERROR(OB_NOT_SUPPORTED, "plan cache's fine-grained cache evict in oracle mode is");
} else if (OB_ISNULL(sql_id_node->children_)
|| OB_ISNULL(sql_id_node->children_[0])
|| T_SQL_ID != sql_id_node->type_) {
|| OB_ISNULL(sql_id_node->children_[0])) {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", K(ret));
} else if (sql_id_node->children_[0]->str_len_ > (OB_MAX_SQL_ID_LENGTH+1)) {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", K(ret));
} else {
stmt->flush_cache_arg_.sql_id_.assign_ptr(
sql_id_node->children_[0]->str_value_,
static_cast<ObString::obstr_size_t>(sql_id_node->children_[0]->str_len_));
} else if (T_SQL_ID == sql_id_node->type_) {
if (sql_id_node->children_[0]->str_len_ > (OB_MAX_SQL_ID_LENGTH+1)) {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", K(ret));
} else {
stmt->flush_cache_arg_.sql_id_.assign_ptr(
sql_id_node->children_[0]->str_value_,
static_cast<ObString::obstr_size_t>(sql_id_node->children_[0]->str_len_));
stmt->flush_cache_arg_.is_fine_grained_ = true;
}
} else if (T_SCHEMA_ID == sql_id_node->type_) {
stmt->flush_cache_arg_.schema_id_ = sql_id_node->children_[0]->value_;
stmt->flush_cache_arg_.is_fine_grained_ = true;
} else {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", K(ret));
}
// retrive schema guard

3
src/sql/resolver/cmd/ob_call_procedure_resolver.cpp
View File

@ -240,6 +240,9 @@ int ObCallProcedureResolver::generate_pl_cache_ctx(pl::ObPLCacheCtx &pc_ctx)
pc_ctx.key_.sessid_ = 0;
pc_ctx.key_.key_id_ = OB_INVALID_ID;
pc_ctx.key_.name_ = params_.cur_sql_;
(void)ObSQLUtils::md5(pc_ctx.raw_sql_,
pc_ctx.sql_id_,
(int32_t)sizeof(pc_ctx.sql_id_));
}
return ret;
}