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

Fix: Asynchronous update of corner case, affected row not synchronized

Browse Source
This commit is contained in:
obdev
2024-02-09 03:36:29 +00:00
committed by ob-robot
parent 3adeed0f3a
commit b06ffa075e
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/observer/mysql/ob_async_cmd_driver.cpp
View File

@ -91,6 +91,12 @@ int ObAsyncCmdDriver::response_result(ObMySQLResultSet &result)
if (OB_UNLIKELY(!result.is_async_end_trans_submitted())) { if (OB_UNLIKELY(!result.is_async_end_trans_submitted())) {
ObOKPParam ok_param; ObOKPParam ok_param;
ok_param.affected_rows_ = 0; ok_param.affected_rows_ = 0;
// The commit asynchronous callback logic needs
// to trigger the update logic of affected row first.
if (session_.is_session_sync_support()) {
session_.set_affected_rows_is_changed(ok_param.affected_rows_);
}
session_.set_affected_rows(ok_param.affected_rows_);
ok_param.is_partition_hit_ = session_.partition_hit().get_bool(); ok_param.is_partition_hit_ = session_.partition_hit().get_bool();
ok_param.has_more_result_ = result.has_more_result(); ok_param.has_more_result_ = result.has_more_result();
if (OB_FAIL(sender_.send_ok_packet(session_, ok_param))) { if (OB_FAIL(sender_.send_ok_packet(session_, ok_param))) {