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

[BUGFIX] fix insert on dup update process lob col

Browse Source
This commit is contained in:
obdev
2024-02-10 04:07:44 +00:00
committed by ob-robot
parent d5bacaa15f
commit 6f4a546f01
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/storage/lob/ob_lob_manager.cpp
View File

@ -1347,7 +1347,7 @@ int ObLobManager::append(
}
// prepare write buffer
ObString write_buffer;
int64_t buf_len = OB_MIN(ObLobMetaUtil::LOB_OPER_PIECE_DATA_SIZE, append_lob_len);
int64_t buf_len = OB_MIN(ObLobMetaUtil::LOB_OPER_PIECE_DATA_SIZE, param.byte_size_ + append_lob_len);
char *buf = nullptr;
if (OB_SUCC(ret)) {
buf = reinterpret_cast<char*>(param.allocator_->alloc(buf_len));
@ -2679,7 +2679,7 @@ int ObLobManager::write_outrow(ObLobAccessParam& param, ObLobLocatorV2& lob, uin
} else {
// prepare read buffer
ObString read_buffer;
uint64_t read_buff_size = OB_MIN(LOB_READ_BUFFER_LEN, read_param.byte_size_);;
uint64_t read_buff_size = OB_MIN(LOB_READ_BUFFER_LEN, read_param.byte_size_);
char *read_buff = static_cast<char*>(param.allocator_->alloc(read_buff_size));
if (OB_ISNULL(read_buff)) {
ret = OB_ALLOCATE_MEMORY_FAILED;
@ -3578,6 +3578,10 @@ int ObLobManager::build_lob_param(ObLobAccessParam& param,
param.snapshot_.source_ = transaction::ObTxReadSnapshot::SRC::LS;
param.snapshot_.snapshot_lsid_ = share::ObLSID(location_info->ls_id_);
param.read_latest_ = retry_info->read_latest_;
if (param.read_latest_ && OB_NOT_NULL(param.tx_desc_)) {
// tx_info->snapshot_seq_ is seq_abs when read_latest is true
param.snapshot_.core_.scn_ = param.tx_desc_->get_tx_seq(tx_info->snapshot_seq_);
}
} else {
// When param for write, param.tx_desc_ should not be null
// If tx indfo from lob locator is old, produce new read snapshot directly