xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

feat:support decimal in raw block

This commit is contained in:
wangmm0220 2025-02-28 09:20:53 +08:00 committed by wangjiaming0909
parent 16979f9dc8
commit d5510a047d
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/parser/src/parTranslater.c
View File

@ -14152,7 +14152,7 @@ static int32_t extractQueryResultSchema(const SNodeList* pProjections, int32_t*
return terrno; return terrno;
} }
if (ppExtSchemas) *ppExtSchemas = taosMemoryCalloc(*numOfCols, sizeof(SExtSchema)); if (ppExtSchemas) *ppExtSchemas = taosMemoryCalloc(*numOfCols, sizeof(SExtSchema));
if (!ppExtSchemas) { if (ppExtSchemas && *ppExtSchemas == NULL) {
taosMemoryFreeClear(*pSchema); taosMemoryFreeClear(*pSchema);
return terrno; return terrno;
} }

7
utils/test/c/tmq_write_raw_test.c
View File

@ -213,6 +213,13 @@ int32_t init_env() {
buildDatabase(pConn, pRes); buildDatabase(pConn, pRes);
pRes = taos_query(pConn, "drop topic if exists topic_query");
if (taos_errno(pRes) != 0) {
printf("error in drop topic, reason:%s\n", taos_errstr(pRes));
return -1;
}
taos_free_result(pRes);
pRes = taos_query(pConn, "drop database if exists db_query"); pRes = taos_query(pConn, "drop database if exists db_query");
if (taos_errno(pRes) != 0) { if (taos_errno(pRes) != 0) {
printf("error in drop db_taosx, reason:%s\n", taos_errstr(pRes)); printf("error in drop db_taosx, reason:%s\n", taos_errstr(pRes));