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

[to #48781569]fixed delete record type deserialize core

Browse Source
This commit is contained in:
LiuYoung00 2023-04-04 05:11:04 +00:00 committed by ob-robot
parent ec33f21ef0
commit 9814fe9ac9
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/pl/ob_pl_user_type.cpp
View File

@ -1166,15 +1166,18 @@ int ObRecordType::deserialize(
ObPLRecord *record = reinterpret_cast<ObPLRecord *>(dst);
CK (OB_NOT_NULL(record));
int64_t count = OB_INVALID_COUNT;
OX (record->deserialize(src, src_len, src_pos));
OZ (serialization::decode(src, src_len, src_pos, count));
OX (record->set_count(count));
// when record be delete , type will be PL_INVALID_TYPE
if (OB_SUCC(ret) && record->get_type() != PL_INVALID_TYPE) {
OX (record->deserialize(src, src_len, src_pos));
OZ (serialization::decode(src, src_len, src_pos, count));
OX (record->set_count(count));
dst = reinterpret_cast<char*>(record->get_element());
for (int64_t i = 0; OB_SUCC(ret) && i < record_members_.count(); ++i) {
const ObPLDataType *type = get_record_member_type(i);
CK (OB_NOT_NULL(type));
OZ (type->deserialize(resolve_ctx, allocator, src, src_len, src_pos, dst));
dst = reinterpret_cast<char*>(record->get_element());
for (int64_t i = 0; OB_SUCC(ret) && i < record_members_.count(); ++i) {
const ObPLDataType *type = get_record_member_type(i);
CK (OB_NOT_NULL(type));
OZ (type->deserialize(resolve_ctx, allocator, src, src_len, src_pos, dst));
}
}
return ret;
}