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

[CP] [to #46639322]refcursor fetch last_row flag set

Browse Source
This commit is contained in:
LiuYoung00
2023-08-14 12:18:22 +00:00
committed by ob-robot
parent d541d23b95
commit ef1a92ba2f
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/observer/mysql/obmp_stmt_fetch.cpp
View File

@ -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_MORE_RESULTS_EXISTS = has_ok_packet() ? true : false; /*no more result*/
flags.status_flags_.OB_SERVER_STATUS_CURSOR_EXISTS = !last_row ? 1 : 0; flags.status_flags_.OB_SERVER_STATUS_CURSOR_EXISTS = !last_row ? 1 : 0;
if ((!cursor.is_streaming() if ((!cursor.is_streaming()
&& cursor.is_ps_cursor()
&& max_count == cursor.get_current_position() + 1) && max_count == cursor.get_current_position() + 1)
|| last_row) { || last_row) {
flags.status_flags_.OB_SERVER_STATUS_LAST_ROW_SENT = 1; flags.status_flags_.OB_SERVER_STATUS_LAST_ROW_SENT = 1;
@ -570,7 +569,6 @@ int ObMPStmtFetch::response_result(pl::ObPLCursorInfo &cursor,
ok_param.affected_rows_ = 0; ok_param.affected_rows_ = 0;
} }
if ((!cursor.is_streaming() if ((!cursor.is_streaming()
&& cursor.is_ps_cursor()
&& max_count == cursor.get_current_position() + 1) && max_count == cursor.get_current_position() + 1)
|| last_row) { || last_row) {
ok_param.send_last_row_ = true; ok_param.send_last_row_ = true;