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

bugfix：return empty set whern limit 0

Browse Source
This commit is contained in:
wu-xingying 2024-10-12 06:38:41 +00:00 committed by ob-robot
parent 8b6d8ee30f
commit 228bfdcdc9
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/sql/das/ob_vector_index_lookup_op.cpp
View File

@ -393,7 +393,9 @@ int ObVectorIndexLookupOp::fetch_index_table_rowkey()
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObNewRow *row = nullptr; ObNewRow *row = nullptr;
if (OB_ISNULL(adaptor_vid_iter_)) { if (limit_param_.limit_ + limit_param_.offset_ == 0) {
ret = OB_ITER_END;
} else if (OB_ISNULL(adaptor_vid_iter_)) {
if (OB_FAIL(process_adaptor_state())) { if (OB_FAIL(process_adaptor_state())) {
LOG_WARN("failed to process_adaptor_state", K(ret)); LOG_WARN("failed to process_adaptor_state", K(ret));
} }
@ -424,7 +426,9 @@ int ObVectorIndexLookupOp::fetch_index_table_rowkeys(int64_t &count, const int64
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObNewRow *row = nullptr; ObNewRow *row = nullptr;
int64_t index_scan_row_cnt = 0; int64_t index_scan_row_cnt = 0;
if (OB_ISNULL(adaptor_vid_iter_)) { if (limit_param_.limit_ + limit_param_.offset_ == 0) {
ret = OB_ITER_END;
} else if (OB_ISNULL(adaptor_vid_iter_)) {
if (OB_FAIL(process_adaptor_state())) { if (OB_FAIL(process_adaptor_state())) {
LOG_WARN("failed to process_adaptor_state", K(ret)); LOG_WARN("failed to process_adaptor_state", K(ret));
} }