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

[CP] [#2024122600106652938]Fix: fast_parse do not report error when parse sql failed and memmove core.

Browse Source
This commit is contained in:
bit-dance 2025-01-02 14:45:50 +00:00 committed by ob-robot
parent f4c1486e2e
commit a4a7c5e9e8
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/pl/parser/ob_pl_parser.cpp
View File

@ -108,16 +108,24 @@ int ObPLParser::fast_parse(const ObString &query,
LOG_WARN("failed to parse pl stmt", K(ret));
}
} else {
memmove(parse_ctx.no_param_sql_ + parse_ctx.no_param_sql_len_,
int64_t buf_remain_len = parse_ctx.no_param_sql_buf_len_ - parse_ctx.no_param_sql_len_;
int64_t copy_len = parse_ctx.stmt_len_ - parse_ctx.copied_pos_;
if (buf_remain_len < copy_len) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("Can not memmove due to remain buf len less than copy len",
K(ret), K(buf_remain_len), K(copy_len));
} else {
memmove(parse_ctx.no_param_sql_ + parse_ctx.no_param_sql_len_,
parse_ctx.stmt_str_ + parse_ctx.copied_pos_,
parse_ctx.stmt_len_ - parse_ctx.copied_pos_);
parse_ctx.no_param_sql_len_ += parse_ctx.stmt_len_ - parse_ctx.copied_pos_;
parse_result.no_param_sql_ = parse_ctx.no_param_sql_;
parse_result.no_param_sql_len_ = parse_ctx.no_param_sql_len_;
parse_result.no_param_sql_buf_len_ = parse_ctx.no_param_sql_buf_len_;
parse_result.param_node_num_ = parse_ctx.param_node_num_;
parse_result.param_nodes_ = parse_ctx.param_nodes_;
parse_result.tail_param_node_ = parse_ctx.tail_param_node_;
copy_len);
parse_ctx.no_param_sql_len_ += copy_len;
parse_result.no_param_sql_ = parse_ctx.no_param_sql_;
parse_result.no_param_sql_len_ = parse_ctx.no_param_sql_len_;
parse_result.no_param_sql_buf_len_ = parse_ctx.no_param_sql_buf_len_;
parse_result.param_node_num_ = parse_ctx.param_node_num_;
parse_result.param_nodes_ = parse_ctx.param_nodes_;
parse_result.tail_param_node_ = parse_ctx.tail_param_node_;
}
}
}
return ret;