database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[feature-wip](array-type) support array<decimal128> in mysql_result_writer (#9998)

Browse Source
This commit is contained in:
yinzhijian
2022-06-09 15:15:26 +08:00
committed by GitHub
parent 6fab1cbf3c
commit dc874709d7
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
be/src/vec/sink/mysql_result_writer.cpp
View File

@ -283,6 +283,12 @@ int VMysqlResultWriter::_add_one_cell(const ColumnPtr& column_ptr, size_t row_id
char buf[64];
char* pos = datetime.to_string(buf);
return buffer.push_string(buf, pos - buf - 1);
} else if (which.is_decimal128()) {
auto& column_data =
static_cast<const ColumnDecimal<vectorized::Decimal128>&>(*column).get_data();
DecimalV2Value decimal_val(column_data[row_idx]);
auto decimal_str = decimal_val.to_string();
return buffer.push_string(decimal_str.c_str(), decimal_str.length());
} else if (which.is_array()) {
auto& column_array = assert_cast<const ColumnArray&>(*column);
auto& offsets = column_array.get_offsets();