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

Fix row scn for uncommitted row with determined_state

Browse Source
This commit is contained in:
DengzhiLiu
2023-06-15 02:18:19 +00:00
committed by ob-robot
parent d00438b9c4
commit 282fe06116
1 changed files with 18 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/storage/blocksstable/ob_micro_block_row_scanner.cpp
View File

@ -1163,19 +1163,26 @@ int ObMultiVersionMicroBlockRowScanner::inner_inner_get_next_row(
}
}
if (OB_SUCC(ret) && version_fit) {
if (0 != context_->trans_version_range_.base_version_ && is_determined_state) {
// major read rows
LOG_DEBUG("success to set trans_version on uncommitted row", K(ret), K(trans_version));
row->storage_datums_[read_info_->get_schema_rowkey_count()].set_int(-trans_version);
if (OB_INVALID_INDEX != read_info_->get_trans_col_index() && is_determined_state) {
// only uncommitted row need to be set, committed row set in row reader
int64_t trans_idx = read_info_->get_trans_col_index();
if (OB_UNLIKELY(trans_idx >= row->count_ || 0 >= trans_version)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("Unexpected trans info", K(ret), K(trans_idx), K(trans_version), KPC(row), KPC_(read_info));
} else {
LOG_DEBUG("success to set trans_version on uncommitted row", K(ret), K(trans_version));
row->storage_datums_[trans_idx].set_int(-trans_version);
}
}
if (!row->mvcc_row_flag_.is_uncommitted_row() || is_determined_state) {
row->snapshot_version_ = 0;
row->trans_id_.reset();
} else { // uncommitted row
row->snapshot_version_ = INT64_MAX;
if (OB_SUCC(ret)) {
if (!row->mvcc_row_flag_.is_uncommitted_row() || is_determined_state) {
row->snapshot_version_ = 0;
row->trans_id_.reset();
} else { // uncommitted row
row->snapshot_version_ = INT64_MAX;
}
ret_row = row;
}
ret_row = row;
}
}
}