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

for update no need affect affected row

Browse Source
This commit is contained in:
yaojing624
2024-04-15 16:01:47 +00:00
committed by ob-robot
parent 7de9106ec9
commit 71c32f94b0
1 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/engine/dml/ob_table_lock_op.cpp
View File

@ -389,9 +389,6 @@ int ObTableLockOp::lock_row_to_das()
if (OB_FAIL(ObDMLService::process_lock_row(lock_ctdef, lock_rtdef, is_skipped, *this))) { if (OB_FAIL(ObDMLService::process_lock_row(lock_ctdef, lock_rtdef, is_skipped, *this))) {
LOG_WARN("process lock row failed", K(ret)); LOG_WARN("process lock row failed", K(ret));
} else if (OB_UNLIKELY(is_skipped)) { } else if (OB_UNLIKELY(is_skipped)) {
//this row has been skipped, so can not write to DAS buffer
//but need record into affected_rows
plan_ctx->add_affected_rows(1LL);
} else if (OB_FAIL(calc_tablet_loc(lock_ctdef, lock_rtdef, tablet_loc))) { } else if (OB_FAIL(calc_tablet_loc(lock_ctdef, lock_rtdef, tablet_loc))) {
LOG_WARN("calc partition key failed", K(ret)); LOG_WARN("calc partition key failed", K(ret));
} else if (OB_FAIL(ObDMLService::lock_row(lock_ctdef, lock_rtdef, tablet_loc, dml_rtctx_))) { } else if (OB_FAIL(ObDMLService::lock_row(lock_ctdef, lock_rtdef, tablet_loc, dml_rtctx_))) {
@ -402,8 +399,6 @@ int ObTableLockOp::lock_row_to_das()
} else if (MY_SPEC.is_nowait() && OB_ERR_EXCLUSIVE_LOCK_CONFLICT == ret) { } else if (MY_SPEC.is_nowait() && OB_ERR_EXCLUSIVE_LOCK_CONFLICT == ret) {
ret = OB_ERR_EXCLUSIVE_LOCK_CONFLICT_NOWAIT; ret = OB_ERR_EXCLUSIVE_LOCK_CONFLICT_NOWAIT;
} }
} else {
plan_ctx->add_affected_rows(1LL);
} }
} }
return ret; return ret;