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

feat:remove add schemaExt to SMqDataRsp

This commit is contained in:
wangmm0220 2025-02-28 16:53:28 +08:00 committed by wangjiaming0909
parent edae7a1f0b
commit e3e79f014b
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -38,13 +38,32 @@ static TAOS* use_db() {
return pConn; return pConn;
} }
static void checkData() {
TAOS* pConn = taos_connect("localhost", "root", "taosdata", NULL, 0);
ASSERT(pConn != NULL);
TAOS_RES* pRes = taos_query(pConn, "select * from db_taosx.ct0");
ASSERT (taos_errno(pRes) == 0);
TAOS_ROW row = NULL;
while ((row = taos_fetch_row(pRes))) {
int numFields = taos_num_fields(pRes);
TAOS_FIELD* fields = taos_fetch_fields(pRes);
for (int i = 0; i < numFields; ++i) {
if (IS_DECIMAL_TYPE(fields[i].type)) {
ASSERT(strcmp(row[i], "23.230") == 0 || strcmp(row[i], "43.530") == 0);
}
}
}
taos_free_result(pRes);
taos_close(pConn);
}
static void msg_process(TAOS_RES* msg) { static void msg_process(TAOS_RES* msg) {
printf("-----------topic-------------: %s\n", tmq_get_topic_name(msg)); printf("-----------topic-------------: %s\n", tmq_get_topic_name(msg));
printf("db: %s\n", tmq_get_db_name(msg)); printf("db: %s\n", tmq_get_db_name(msg));
printf("vg: %d\n", tmq_get_vgroup_id(msg)); printf("vg: %d\n", tmq_get_vgroup_id(msg));
if (strcmp(tmq_get_db_name(msg), "db_query") == 0){ if (strcmp(tmq_get_db_name(msg), "db_query") == 0){
TAOS_ROW row = NULL; TAOS_ROW row = NULL;
int32_t cnt = 0;
while ((row = taos_fetch_row(msg))) { while ((row = taos_fetch_row(msg))) {
int numFields = taos_num_fields(msg); int numFields = taos_num_fields(msg);
@ -356,4 +375,5 @@ int main(int argc, char* argv[]) {
tmq_list_t* topic_list = build_topic_list(); tmq_list_t* topic_list = build_topic_list();
basic_consume_loop(tmq, topic_list); basic_consume_loop(tmq, topic_list);
tmq_list_destroy(topic_list); tmq_list_destroy(topic_list);
checkData();
} }