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

test(stream): update a test case.

This commit is contained in:
Haojun Liao 2023-07-18 18:30:10 +08:00
parent 902f9d1f94
commit e5750e1219
1 changed files with 32 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
source/client/test/clientTests.cpp
View File

@ -899,13 +899,40 @@ TEST(clientCase, agg_query_tables) {
} }
taos_free_result(pRes); taos_free_result(pRes);
pRes = taos_query(pConn, "show table distributed tup"); int64_t st = 1685959293000;
if (taos_errno(pRes) != 0) { for (int32_t i = 0; i < 10000000; ++i) {
printf("failed to select from table, reason:%s\n", taos_errstr(pRes)); char s[256] = {0};
taos_free_result(pRes);
ASSERT_TRUE(false); while (1) {
sprintf(s, "insert into t1 values(%ld, %d)", st + i, i);
pRes = taos_query(pConn, s);
int32_t ret = taos_errno(pRes);
taos_free_result(pRes);
if (ret == 0) {
break;
}
}
while (1) {
sprintf(s, "insert into t2 values(%ld, %d)", st + i, i);
pRes = taos_query(pConn, s);
int32_t ret = taos_errno(pRes);
taos_free_result(pRes);
if (ret == 0) {
break;
}
}
} }
// pRes = taos_query(pConn, "show table distributed tup");
// if (taos_errno(pRes) != 0) {
// printf("failed to select from table, reason:%s\n", taos_errstr(pRes));
// taos_free_result(pRes);
// ASSERT_TRUE(false);
// }
printResult(pRes); printResult(pRes);
taos_free_result(pRes); taos_free_result(pRes);
taos_close(pConn); taos_close(pConn);