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

[CP] [to #47499273] fix bulk collect table which may modified by sql

Browse Source
This commit is contained in:
obdev
2023-02-09 16:01:02 +00:00
committed by ob-robot
parent 1a7bd7edfc
commit 4b1f26e4eb
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/sql/ob_spi.cpp
View File

@ -5697,6 +5697,22 @@ int ObSPIService::get_result(ObPLExecCtx *ctx,
LOG_WARN("read result error", K(ret));
}
}
if (OB_SUCC(ret)) {
for (int64_t i = 0; OB_SUCC(ret) && i < bulk_tables.count(); ++i) {
ObPLCollection *table = bulk_tables.at(i);
CK (OB_NOT_NULL(table));
if (OB_SUCC(ret) && table->get_count() > 0) {
if (implicit_cursor == NULL || !implicit_cursor->get_in_forall()) {
// only clear table data, do not reset collection allocator,
// because fetch rows already copy to collection allocator, in store_result only do shadow copy.
table->set_count(0);
table->set_first(OB_INVALID_INDEX);
table->set_last(OB_INVALID_INDEX);
table->set_data(NULL);
}
}
}
}
if (OB_SUCC(ret) && row_count > 0) { // 累积存储在pl table里
OZ (store_result(bulk_tables, row_count, type_count, tmp_result,
NULL == implicit_cursor ? false : implicit_cursor->get_in_forall()));