From ef1a92ba2fa856f7f03ba457388a639242cf5594 Mon Sep 17 00:00:00 2001 From: LiuYoung00 Date: Mon, 14 Aug 2023 12:18:22 +0000 Subject: [PATCH] [CP] [to #46639322]refcursor fetch last_row flag set --- src/observer/mysql/obmp_stmt_fetch.cpp | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/observer/mysql/obmp_stmt_fetch.cpp b/src/observer/mysql/obmp_stmt_fetch.cpp index b5a601eac..40e40d90d 100644 --- a/src/observer/mysql/obmp_stmt_fetch.cpp +++ b/src/observer/mysql/obmp_stmt_fetch.cpp @@ -531,7 +531,6 @@ int ObMPStmtFetch::response_result(pl::ObPLCursorInfo &cursor, flags.status_flags_.OB_SERVER_MORE_RESULTS_EXISTS = has_ok_packet() ? true : false; /*no more result*/ flags.status_flags_.OB_SERVER_STATUS_CURSOR_EXISTS = !last_row ? 1 : 0; if ((!cursor.is_streaming() - && cursor.is_ps_cursor() && max_count == cursor.get_current_position() + 1) || last_row) { flags.status_flags_.OB_SERVER_STATUS_LAST_ROW_SENT = 1; @@ -570,8 +569,7 @@ int ObMPStmtFetch::response_result(pl::ObPLCursorInfo &cursor, ok_param.affected_rows_ = 0; } if ((!cursor.is_streaming() - && cursor.is_ps_cursor() - && max_count == cursor.get_current_position() + 1 ) + && max_count == cursor.get_current_position() + 1) || last_row) { ok_param.send_last_row_ = true; } else {