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

add some defensive check after write

Browse Source
This commit is contained in:
yishenglanlingzui
2023-01-28 20:13:20 +08:00
committed by ob-robot
parent 79a7164fbc
commit 3329d12085
3 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/das/ob_das_delete_op.cpp
View File

@ -59,6 +59,10 @@ int ObDASIndexDMLAdaptor<DAS_OP_TABLE_DELETE, ObDASDMLIterator>::write_rows(cons
if (OB_TRY_LOCK_ROW_CONFLICT != ret) { if (OB_TRY_LOCK_ROW_CONFLICT != ret) {
LOG_WARN("delete rows to access service failed", K(ret)); LOG_WARN("delete rows to access service failed", K(ret));
} }
} else if (!(ctdef.is_ignore_ || ctdef.table_param_.get_data_table().is_spatial_index())
&& 0 == affected_rows) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected affected_rows after do delete", K(affected_rows), K(ret));
} }
return ret; return ret;
} }

4
src/sql/das/ob_das_insert_op.cpp
View File

@ -63,6 +63,10 @@ int ObDASIndexDMLAdaptor<DAS_OP_TABLE_INSERT, ObDASDMLIterator>::write_rows(cons
if (OB_TRY_LOCK_ROW_CONFLICT != ret) { if (OB_TRY_LOCK_ROW_CONFLICT != ret) {
LOG_WARN("insert rows to access service failed", K(ret)); LOG_WARN("insert rows to access service failed", K(ret));
} }
} else if (!(ctdef.is_ignore_ || ctdef.table_param_.get_data_table().is_spatial_index())
&& 0 == affected_rows) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected affected_rows after do insert", K(affected_rows), K(ret));
} }
return ret; return ret;
} }

3
src/sql/das/ob_das_update_op.cpp
View File

@ -272,6 +272,9 @@ int ObDASIndexDMLAdaptor<DAS_OP_TABLE_UPDATE, ObDASUpdIterator>::write_rows(cons
if (OB_TRY_LOCK_ROW_CONFLICT != ret) { if (OB_TRY_LOCK_ROW_CONFLICT != ret) {
LOG_WARN("update row to partition storage failed", K(ret)); LOG_WARN("update row to partition storage failed", K(ret));
} }
} else if (!ctdef.is_ignore_ && 0 == affected_rows) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected affected_rows after do update", K(affected_rows), K(ret));
} }
return ret; return ret;
} }