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

[CP] Fix: affected row sync

Browse Source
This commit is contained in:
obdev
2024-02-06 17:43:38 +00:00
committed by ob-robot
parent c492fbfe51
commit 33e94551f4
4 changed files with 21 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/sql/session/ob_basic_session_info.cpp
View File

@ -2673,6 +2673,18 @@ OB_INLINE int ObBasicSessionInfo::process_session_variable(ObSysVarClassType var
OX (sys_vars_cache_.set_default_lob_inrow_threshold(int_val));
break;
}
case SYS_VAR__AFFECTED_ROWS: {
int64_t affect_rows = 0;
OZ (val.get_int(affect_rows), val);
set_affected_rows(affect_rows);
break;
}
case SYS_VAR__FOUND_ROWS: {
int64_t found_rows = 0;
OZ (val.get_int(found_rows), val);
set_found_rows(found_rows);
break;
}
default: {
//do nothing
}