database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-01 06:46:55 +03:00
Code Activity

MCOL-641 Fixed group_concat for narrow-DECIMALs.

Browse Source
This commit is contained in:
Roman Nozdrin
2020-05-18 11:02:27 +00:00
parent f63611c422
commit a7fcf39f2a
3 changed files with 29 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
dbcon/joblist/groupconcat.cpp
View File

@ -457,17 +457,32 @@ void GroupConcator::outputRow(std::ostringstream& oss, const rowgroup::Row& row)
case CalpontSystemCatalog::UDECIMAL:
{
int scale = (int) row.getScale(*i);
//{
// long double dblVal = intVal / pow(10.0, (double)scale);
// oss << fixed << setprecision(scale) << dblVal;
//}
char buf[utils::MAXLENGTH16BYTES];
int128_t* dec = row.getBinaryField<int128_t>(*i);
dataconvert::DataConvert::decimalToString(dec,
static_cast<uint32_t>(scale), buf,
sizeof(buf), types[*i]);
oss << fixed << buf;
if (LIKELY(row.getColumnWidth(*i) == datatypes::MAXDECIMALWIDTH))
{
char buf[utils::MAXLENGTH16BYTES];
int128_t* dec = row.getBinaryField<int128_t>(*i);
dataconvert::DataConvert::decimalToString(dec,
static_cast<uint32_t>(scale), buf,
sizeof(buf), types[*i]);
oss << fixed << buf;
}
else
{
int64_t intVal = row.getIntField(*i);
if (scale == 0)
{
oss << intVal;
}
else
{
char buf[utils::MAXLENGTH8BYTES];
dataconvert::DataConvert::decimalToString(intVal,
scale, buf, sizeof(buf), types[*i]);
oss << fixed << buf;
}
}
break;
}