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

[CP][BUGFIX] fix text substr len 0 error

Browse Source
This commit is contained in:
obdev
2024-02-08 03:18:13 +00:00
committed by ob-robot
parent 63825b1014
commit a73fbc69f4
3 changed files with 42 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/engine/expr/ob_expr_lob_utils.cpp
View File

@ -77,6 +77,10 @@ void ObTextStringDatumResult::set_result()
res_datum_->set_string(buffer_, pos_); res_datum_->set_string(buffer_, pos_);
} }
void ObTextStringDatumResult::set_result_null()
{
res_datum_->set_null();
}
int ObTextStringObObjResult::init(int64_t res_len, ObIAllocator *allocator) int ObTextStringObObjResult::init(int64_t res_len, ObIAllocator *allocator)
{ {

2
src/sql/engine/expr/ob_expr_lob_utils.h
View File

@ -41,7 +41,7 @@ public:
int init(int64_t res_len, ObIAllocator *allocator = NULL); int init(int64_t res_len, ObIAllocator *allocator = NULL);
int init_with_batch_idx(int64_t res_len, int64_t batch_idx); int init_with_batch_idx(int64_t res_len, int64_t batch_idx);
void set_result(); void set_result();
void set_result_null();
private: private:
char * buff_alloc (const int64_t size); char * buff_alloc (const int64_t size);

73
src/sql/engine/expr/ob_expr_substr.cpp
View File

@ -557,7 +557,9 @@ static int eval_substr_text(const ObCollationType &cs_type,
} else if (OB_FAIL(input_iter.get_char_len(total_char_len))) { } else if (OB_FAIL(input_iter.get_char_len(total_char_len))) {
LOG_WARN("get input char len failed", K(ret)); LOG_WARN("get input char len failed", K(ret));
} else if (FALSE_IT(result_byte_len = MIN((pos >= 0 ? total_byte_len - pos + 1 : -pos * mbmaxlen), (MIN((len), (total_char_len)) * mbmaxlen)))) { } else if (FALSE_IT(result_byte_len = MIN((pos >= 0 ? total_byte_len - pos + 1 : -pos * mbmaxlen), (MIN((len), (total_char_len)) * mbmaxlen)))) {
} else if (len < 0 || pos > total_char_len) { } else if (len <= 0 && lib::is_oracle_mode()) {
output_result.set_result_null();
} else if (pos > total_char_len || len <= 0) {
if (!is_batch) { if (!is_batch) {
ret = output_result.init(0); // fill empty lob result ret = output_result.init(0); // fill empty lob result
} else { } else {
@ -574,45 +576,44 @@ static int eval_substr_text(const ObCollationType &cs_type,
} else { } else {
ret = output_result.init_with_batch_idx(result_byte_len, batch_idx); ret = output_result.init_with_batch_idx(result_byte_len, batch_idx);
} }
} if (OB_FAIL(ret)) {
LOG_WARN("init stringtext result failed", K(ret));
if (OB_FAIL(ret)) {
LOG_WARN("init stringtext result failed", K(ret));
} else {
if (lib::is_oracle_mode() && 0 == pos) {
pos = 1;
}
// iter settings only effective to outrow lobs
uint64_t start_offset = (pos >= 0 ? pos - 1 : total_char_len + pos);
if (start_offset >= total_char_len) {
output_result.set_result();
} else { } else {
input_iter.set_start_offset((pos >= 0 ? pos - 1 : total_char_len + pos)); if (lib::is_oracle_mode() && 0 == pos) {
input_iter.set_access_len(len); pos = 1;
ObTextStringIterState state; }
ObString src_block_data; // iter settings only effective to outrow lobs
while (OB_SUCC(ret) uint64_t start_offset = (pos >= 0 ? pos - 1 : total_char_len + pos);
&& (state = input_iter.get_next_block(src_block_data)) == TEXTSTRING_ITER_NEXT) { if (start_offset >= total_char_len) {
if (!input_iter.is_outrow_lob()) { output_result.set_result();
ObString inrow_result; } else {
if (OB_FAIL(ObExprSubstr::substr(inrow_result, src_block_data, pos, len, input_iter.set_start_offset((pos >= 0 ? pos - 1 : total_char_len + pos));
cs_type, input_iter.set_access_len(len);
storage::can_do_ascii_optimize(cs_type)))) { ObTextStringIterState state;
LOG_WARN("get substr failed", K(ret)); ObString src_block_data;
} else if (OB_FAIL(output_result.append(inrow_result))) { while (OB_SUCC(ret)
&& (state = input_iter.get_next_block(src_block_data)) == TEXTSTRING_ITER_NEXT) {
if (!input_iter.is_outrow_lob()) {
ObString inrow_result;
if (OB_FAIL(ObExprSubstr::substr(inrow_result, src_block_data, pos, len,
cs_type,
storage::can_do_ascii_optimize(cs_type)))) {
LOG_WARN("get substr failed", K(ret));
} else if (OB_FAIL(output_result.append(inrow_result))) {
LOG_WARN("append result failed", K(ret), K(output_result), K(src_block_data));
}
} else if (OB_FAIL(output_result.append(src_block_data))) {
LOG_WARN("append result failed", K(ret), K(output_result), K(src_block_data)); LOG_WARN("append result failed", K(ret), K(output_result), K(src_block_data));
} }
} else if (OB_FAIL(output_result.append(src_block_data))) {
LOG_WARN("append result failed", K(ret), K(output_result), K(src_block_data));
} }
} if (OB_FAIL(ret)) {
if (OB_FAIL(ret)) { } else if (state != TEXTSTRING_ITER_NEXT && state != TEXTSTRING_ITER_END) {
} else if (state != TEXTSTRING_ITER_NEXT && state != TEXTSTRING_ITER_END) { ret = (input_iter.get_inner_ret() != OB_SUCCESS) ?
ret = (input_iter.get_inner_ret() != OB_SUCCESS) ? input_iter.get_inner_ret() : OB_INVALID_DATA;
input_iter.get_inner_ret() : OB_INVALID_DATA; LOG_WARN("iter state invalid", K(ret), K(state), K(input_iter));
LOG_WARN("iter state invalid", K(ret), K(state), K(input_iter)); } else {
} else { output_result.set_result();
output_result.set_result(); }
} }
} }
} }