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

[TABLELOCK] fix mysqltest about mysql lock function

Browse Source
This commit is contained in:
YangEfei
2024-05-11 04:15:46 +00:00
committed by ob-robot
parent afe7b912d6
commit b54eb60074
12 changed files with 108 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/sql/optimizer/ob_log_set.cpp
View File

@ -565,20 +565,9 @@ int ObLogSet::get_op_exprs(ObIArray<ObRawExpr*> &all_exprs)
LOG_WARN("failed to get exprs", K(ret));
} else if (is_recursive_union_ && get_stmt()->is_select_stmt()) {
const ObSelectStmt *select_stmt = static_cast<const ObSelectStmt *>(get_stmt());
uint64_t min_cluster_version = GET_MIN_CLUSTER_VERSION();
// 伪列的产生，search/cycle的伪列都要求在recursive union算子产生
if (lib::is_oracle_mode() && is_breadth_search_
&& ((min_cluster_version >= CLUSTER_VERSION_4_2_2_0
&& min_cluster_version < CLUSTER_VERSION_4_3_0_0)
|| (min_cluster_version >= CLUSTER_VERSION_4_3_1_0))) {
if (OB_ISNULL(identify_seq_expr_)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("identify seq exor is null", K(ret));
} else if (OB_FAIL(all_exprs.push_back(identify_seq_expr_))) {
LOG_WARN("failed to push back expr", K(ret));
}
}
if (OB_FAIL(ret)) {
if (NULL != identify_seq_expr_ && OB_FAIL(all_exprs.push_back(identify_seq_expr_))) {
LOG_WARN("failed to push back expr", K(ret));
} else if (OB_FAIL(append(all_exprs, select_stmt->get_cte_exprs()))) {
LOG_WARN("fail to add cte exprs", K(ret));
} else { /*do nothing*/ }