From 5316ca3281c053e46f6c9156a3600ffba9aa2f0e Mon Sep 17 00:00:00 2001 From: hjxilinx Date: Mon, 6 Apr 2020 00:57:56 +0800 Subject: [PATCH] [TD-98] --- tests/examples/c/demo.c | 52 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 52 insertions(+) diff --git a/tests/examples/c/demo.c b/tests/examples/c/demo.c index 853a949162..d92eabab49 100644 --- a/tests/examples/c/demo.c +++ b/tests/examples/c/demo.c @@ -24,17 +24,43 @@ void taosMsleep(int mseconds); +static int32_t doQuery(TAOS* taos, const char* sql) { + int32_t code = taos_query(taos, sql); + if (code != 0) { + printf("failed to execute query, reason:%s\n", taos_errstr(taos)); + return -1; + } + + TAOS_RES* res = taos_use_result(taos); + TAOS_ROW row = NULL; + char buf[512] = {0}; + + int32_t numOfFields = taos_num_fields(res); + TAOS_FIELD* pFields = taos_fetch_fields(res); + + while((row = taos_fetch_row(res)) != NULL) { + taos_print_row(buf, row, pFields, numOfFields); + printf("%s\n", buf); + memset(buf, 0, 512); + } + + taos_free_result(res); +} + int main(int argc, char *argv[]) { TAOS * taos; char qstr[1024]; TAOS_RES *result; + // connect to server if (argc < 2) { printf("please input server-ip \n"); return 0; } + taos_options(TSDB_OPTION_CONFIGDIR, "~/sec/cfg"); + // init TAOS taos_init(); @@ -45,6 +71,22 @@ int main(int argc, char *argv[]) { } printf("success to connect to server\n"); + doQuery(taos, "create database if not exists test"); + doQuery(taos, "use test"); + doQuery(taos, "create table if not exists tm0 (ts timestamp, k int);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:1', 1);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:2', 2);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:3', 3);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:4', 4);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:5', 5);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:6', 6);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:7', 7);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:8', 8);"); + doQuery(taos, "insert into tm0 values('2020-1-1 1:1:9', 9);"); + doQuery(taos, "select * from tm0;"); + + taos_close(taos); + return 0; taos_query(taos, "drop database demo"); if (taos_query(taos, "create database demo") != 0) { @@ -53,8 +95,10 @@ int main(int argc, char *argv[]) { } printf("success to create database\n"); + taos_query(taos, "use demo"); + // create table if (taos_query(taos, "create table m1 (ts timestamp, speed int)") != 0) { printf("failed to create table, reason:%s\n", taos_errstr(taos)); @@ -62,9 +106,11 @@ int main(int argc, char *argv[]) { } printf("success to create table\n"); + // sleep for one second to make sure table is created on data node // taosMsleep(1000); + // insert 10 records int i = 0; for (i = 0; i < 10; ++i) { @@ -76,6 +122,7 @@ int main(int argc, char *argv[]) { } printf("success to insert rows, total %d rows\n", i); + // query the records sprintf(qstr, "SELECT * FROM m1"); if (taos_query(taos, qstr) != 0) { @@ -83,12 +130,16 @@ int main(int argc, char *argv[]) { exit(1); } + result = taos_use_result(taos); + if (result == NULL) { printf("failed to get result, reason:%s\n", taos_errstr(taos)); exit(1); } + +// TAOS_ROW row; TAOS_ROW row; int rows = 0; @@ -96,6 +147,7 @@ int main(int argc, char *argv[]) { TAOS_FIELD *fields = taos_fetch_fields(result); char temp[256]; + printf("select * from table, result:\n"); // fetch the records row by row while ((row = taos_fetch_row(result))) {