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

Fix non-continuous auto-increment values

Browse Source
This commit is contained in:
hezuojiao
2023-07-20 12:12:38 +00:00
committed by ob-robot
parent 66403c8310
commit 0f8747f94a
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/share/ob_global_autoinc_service.cpp
View File

@ -443,8 +443,12 @@ int ObGlobalAutoIncService::fetch_next_node_(const ObGAISNextAutoIncValReq &requ
end_inclusive, end_inclusive,
sync_value))) { sync_value))) {
LOG_WARN("fail to require autoinc value from inner table", K(ret)); LOG_WARN("fail to require autoinc value from inner table", K(ret));
} else if (OB_LIKELY(node.is_valid()) && OB_FAIL(node.update_available_value(end_inclusive))) { } else if (OB_LIKELY(node.is_valid() && node.last_available_value_ == start_inclusive - 1)) {
LOG_WARN("fail to update available value", K(ret), K(node), K(end_inclusive)); if (OB_FAIL(node.update_available_value(end_inclusive))) {
LOG_WARN("fail to update available value", K(ret), K(node), K(end_inclusive));
} else {
LOG_TRACE("fetch next node done", K(request), K(node));
}
} else if (OB_FAIL(node.init(start_inclusive, end_inclusive, sync_value, autoinc_version))){ } else if (OB_FAIL(node.init(start_inclusive, end_inclusive, sync_value, autoinc_version))){
LOG_WARN("fail to init node", K(ret), K(start_inclusive), K(end_inclusive), K(sync_value)); LOG_WARN("fail to init node", K(ret), K(start_inclusive), K(end_inclusive), K(sync_value));
} else { } else {