提交 fb69bdfb 编写于 作者: G Ganlin Zhao

refactor code

上级 d326cfc6
...@@ -4350,31 +4350,16 @@ static void doCopyQueryResultToMsg(SQInfo *pQInfo, int32_t numOfRows, char *data ...@@ -4350,31 +4350,16 @@ static void doCopyQueryResultToMsg(SQInfo *pQInfo, int32_t numOfRows, char *data
compSizes = tcalloc(numOfCols, sizeof(int32_t)); compSizes = tcalloc(numOfCols, sizeof(int32_t));
} }
if (pQueryAttr->pExpr2 == NULL) { for (int32_t col = 0; col < numOfCols; ++col) {
for (int32_t col = 0; col < numOfCols; ++col) { SColumnInfoData* pColRes = taosArrayGet(pRes->pDataBlock, col);
SColumnInfoData* pColRes = taosArrayGet(pRes->pDataBlock, col); if (compressed) {
if (compressed) { compSizes[col] = compressQueryColData(pColRes, numOfRows, data, compressed);
compSizes[col] = compressQueryColData(pColRes, pRes->info.rows, data, compressed); data += compSizes[col];
data += compSizes[col]; *compLen += compSizes[col];
*compLen += compSizes[col]; compSizes[col] = htonl(compSizes[col]);
compSizes[col] = htonl(compSizes[col]); } else {
} else { memmove(data, pColRes->pData, pColRes->info.bytes * numOfRows);
memmove(data, pColRes->pData, pColRes->info.bytes * pRes->info.rows); data += pColRes->info.bytes * numOfRows;
data += pColRes->info.bytes * pRes->info.rows;
}
}
} else {
for (int32_t col = 0; col < numOfCols; ++col) {
SColumnInfoData* pColRes = taosArrayGet(pRes->pDataBlock, col);
if (compressed) {
compSizes[col] = htonl(compressQueryColData(pColRes, numOfRows, data, compressed));
data += compSizes[col];
*compLen += compSizes[col];
compSizes[col] = htonl(compSizes[col]);
} else {
memmove(data, pColRes->pData, pColRes->info.bytes * numOfRows);
data += pColRes->info.bytes * numOfRows;
}
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册