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

feat:[TD-26056] add replay logic

This commit is contained in:
wangmm0220 2023-10-10 09:02:37 +08:00
parent b12c734f09
commit d42e819d2d
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
utils/test/c/replay_test.c
View File

@ -184,10 +184,9 @@ void test_case1(TAOS* pConn, int32_t* interval, int32_t len){
TAOS_FIELD* fields = taos_fetch_fields(tmqmessage);
int32_t numOfFields = taos_field_count(tmqmessage);
const char* tbName = tmq_get_table_name(tmqmessage);
taos_print_row(buf, row, fields, numOfFields);
printf("%lld tbname:%s, rows[%d]: %s\n", t, (tbName != NULL ? tbName : "null table"), totalRows, buf);
printf("time:%" PRId64 " rows[%d]: %s\n", t, totalRows, buf);
totalRows++;
taos_free_result(tmqmessage);
} else {
@ -259,10 +258,9 @@ void test_case2(TAOS* pConn, int32_t* interval, int32_t len, tsem_t* sem){
TAOS_FIELD* fields = taos_fetch_fields(tmqmessage);
int32_t numOfFields = taos_field_count(tmqmessage);
const char* tbName = tmq_get_table_name(tmqmessage);
taos_print_row(buf, row, fields, numOfFields);
printf("%lld tbname:%s, rows[%d]: %s\n", t, (tbName != NULL ? tbName : "null table"), totalRows, buf);
printf("time:%" PRId64 " rows[%d]: %s\n", t, totalRows, buf);
totalRows++;
}
@ -349,10 +347,9 @@ void test_case3(TAOS* pConn, int32_t* interval, int32_t len){
TAOS_FIELD* fields = taos_fetch_fields(tmqmessage);
int32_t numOfFields = taos_field_count(tmqmessage);
const char* tbName = tmq_get_table_name(tmqmessage);
taos_print_row(buf, row, fields, numOfFields);
printf("%lld tbname:%s, rows[%d]: %s\n", t, (tbName != NULL ? tbName : "null table"), totalRows, buf);
printf("time:%" PRId64 " rows[%d]: %s\n", t, totalRows, buf);
totalRows++;
}