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

[CP] [to #2024081300104107288] fix bulk collect with null composite value

Browse Source
This commit is contained in:
obdev
2024-08-20 08:53:59 +00:00
committed by ob-robot
parent f5ddb04304
commit dce97deb2b
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/sql/ob_spi.cpp
View File

@ -7742,6 +7742,15 @@ int ObSPIService::store_result(ObPLExecCtx *ctx,
*(table->get_allocator()), *(table->get_allocator()),
into_record_type->get_record_member_type(k)->get_type(), into_record_type->get_record_member_type(k)->get_type(),
into_record_type->get_record_member_type(k)->get_user_type_id())); into_record_type->get_record_member_type(k)->get_user_type_id()));
} else if (obj_array.at(idx).is_null() && into_record_type->get_record_member_type(k)->is_composite_type()) {
const ObUserDefinedType *type = NULL;
int64_t ptr = 0;
int64_t init_size = OB_INVALID_SIZE;
OZ (ctx->get_user_type(into_record_type->get_record_member_type(k)->get_user_type_id(), type));
CK (OB_NOT_NULL(type));
OZ (type->newx(*(table->get_allocator()), ctx, ptr));
OZ (type->get_size(PL_TYPE_INIT_SIZE, init_size));
OX (tmp.set_extend(ptr, type->get_type(), init_size));
} else { } else {
OZ (deep_copy_obj(*table->get_allocator(), obj_array.at(idx), tmp)); OZ (deep_copy_obj(*table->get_allocator(), obj_array.at(idx), tmp));
} }
@ -7771,6 +7780,15 @@ int ObSPIService::store_result(ObPLExecCtx *ctx,
*(table->get_allocator()), *(table->get_allocator()),
table->get_element_desc().get_pl_type(), table->get_element_desc().get_pl_type(),
table->get_element_desc().get_udt_id())); table->get_element_desc().get_udt_id()));
} else if (current_obj.is_null() && !table->get_element_desc().is_obj_type()) {
const ObUserDefinedType *type = NULL;
int64_t ptr = 0;
int64_t init_size = OB_INVALID_SIZE;
OZ (ctx->get_user_type(table->get_element_desc().get_udt_id(), type));
CK (OB_NOT_NULL(type));
OZ (type->newx(*(table->get_allocator()), ctx, ptr));
OZ (type->get_size(PL_TYPE_INIT_SIZE, init_size));
OX (tmp.set_extend(ptr, type->get_type(), init_size));
} else { } else {
OZ (deep_copy_obj(*table->get_allocator(), current_obj, tmp)); OZ (deep_copy_obj(*table->get_allocator(), current_obj, tmp));
} }