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

[to #51362102] fix affected rows in PL

Browse Source
This commit is contained in:
0xacc
2023-08-09 09:18:41 +00:00
committed by ob-robot
parent 3b3ec369be
commit f5d4e78343
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/ob_result_set.cpp
View File

@ -557,7 +557,10 @@ OB_INLINE void ObResultSet::store_affected_rows(ObPhysicalPlanCtx &plan_ctx)
&& (lib::is_oracle_mode() || !is_pl_stmt(get_stmt_type()))) { && (lib::is_oracle_mode() || !is_pl_stmt(get_stmt_type()))) {
affected_row = 0; affected_row = 0;
} else if (stmt::T_SELECT == get_stmt_type()) { } else if (stmt::T_SELECT == get_stmt_type()) {
affected_row = lib::is_oracle_mode() ? plan_ctx.get_affected_rows() : -1; affected_row = plan_ctx.get_affected_rows();
if (lib::is_mysql_mode() && 0 == affected_row) {
affected_row = -1;
}
} else { } else {
affected_row = get_affected_rows(); affected_row = get_affected_rows();
} }

2
src/sql/ob_spi.cpp
View File

@ -6199,6 +6199,8 @@ int ObSPIService::get_result(ObPLExecCtx *ctx,
true, true,
can_retry)); can_retry));
OZ (query_sender->send_eof_packet(true)); OZ (query_sender->send_eof_packet(true));
OX(implicit_cursor->set_rowcount(into_count > 0 ? 1 : 0));
} }
} else if (stmt::T_ANONYMOUS_BLOCK != ob_result_set->get_stmt_type()) { } else if (stmt::T_ANONYMOUS_BLOCK != ob_result_set->get_stmt_type()) {
// 不带Returing的INSERT，DELETE，UPDATE // 不带Returing的INSERT，DELETE，UPDATE