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

return error when the decimal pricision is not match with datum len

Browse Source
This commit is contained in:
obdev 2024-02-07 10:55:37 +00:00 committed by ob-robot
parent ccfaab4833
commit c173c1713d
1 changed files with 18 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/storage/blocksstable/cs_encoding/ob_cs_encoding_util.cpp
View File

@ -107,11 +107,14 @@ int ObCSEncodingUtil::build_cs_column_encoding_ctx(ObEncodingHashTable *ht,
col_ctx.is_wide_int_ = false;
decint_cmp_fp cmp = wide::ObDecimalIntCmpSet::get_decint_decint_cmp_func(precision_bytes, sizeof(int64_t));
const int64_t row_count = ht->get_node_cnt();
for (int64_t i = 0; i < row_count; ++i) {
for (int64_t i = 0; OB_SUCC(ret) && i < row_count; ++i) {
const ObDatum &datum = *ht->get_node_list()[i].datum_;
if (!datum.is_null()) {
ob_assert(datum.len_ == precision_bytes);
if (cmp(datum.get_decimal_int(), (ObDecimalInt*)&int64_min) < 0 || cmp(datum.get_decimal_int(), (ObDecimalInt*)&int64_max) > 0) {
if (OB_UNLIKELY(datum.len_ != precision_bytes)) {
ret = OB_ERR_UNEXPECTED;
LOG_ERROR("datum len is not match with precision bytes",
K(ret), K(datum), K(precision_bytes), K(i), K(row_count));
} else if (cmp(datum.get_decimal_int(), (ObDecimalInt*)&int64_min) < 0 || cmp(datum.get_decimal_int(), (ObDecimalInt*)&int64_max) > 0) {
col_ctx.is_wide_int_ = true;
break;
} else { // value range is not over int64_t, store as integer
@ -130,17 +133,19 @@ int ObCSEncodingUtil::build_cs_column_encoding_ctx(ObEncodingHashTable *ht,
}
}
}
col_ctx.integer_min_ = static_cast<uint64_t>(int_min);
col_ctx.integer_max_ = static_cast<uint64_t>(int_max);
if (col_ctx.is_wide_int_) { // store as fixed len string
col_ctx.fix_data_size_ = precision_bytes;
FOREACH(l, *ht)
{
const int64_t len = l->header_->datum_->len_;
ob_assert(len == precision_bytes);
col_ctx.var_data_size_ += len * l->size_;
col_ctx.dict_var_data_size_ += len;
if (OB_SUCC(ret)) {
col_ctx.integer_min_ = static_cast<uint64_t>(int_min);
col_ctx.integer_max_ = static_cast<uint64_t>(int_max);
if (col_ctx.is_wide_int_) { // store as fixed len string
col_ctx.fix_data_size_ = precision_bytes;
FOREACH(l, *ht)
{
const int64_t len = l->header_->datum_->len_;
col_ctx.var_data_size_ += len * l->size_;
col_ctx.dict_var_data_size_ += len;
}
}
}
break;