From d99e6be4c1934f6365228c26042a5c2ce9bbbeae Mon Sep 17 00:00:00 2001
From: Yaming Pei <sanwenyuv@sina.com>
Date: Wed, 14 Aug 2024 18:08:07 +0800
Subject: [PATCH] mod c sample code

---
 docs/examples/c/create_db_demo.c   |  4 +++-
 docs/examples/c/insert_data_demo.c |  4 +++-
 docs/examples/c/query_data_demo.c  | 11 ++++++++---
 docs/examples/c/sml_insert_demo.c  |  5 +++--
 docs/examples/c/tmq_demo.c         |  4 ----
 docs/examples/c/with_reqid_demo.c  | 11 ++++++++---
 6 files changed, 25 insertions(+), 14 deletions(-)

diff --git a/docs/examples/c/create_db_demo.c b/docs/examples/c/create_db_demo.c
index 7ac54041d8..44960defa5 100644
--- a/docs/examples/c/create_db_demo.c
+++ b/docs/examples/c/create_db_demo.c
@@ -73,4 +73,6 @@ static int DemoCreateDB() {
   // ANCHOR_END: create_db_and_table
 }
 
-int main(int argc, char *argv[]) { return DemoCreateDB(); }
+int main(int argc, char *argv[]) {
+  return DemoCreateDB();
+}
diff --git a/docs/examples/c/insert_data_demo.c b/docs/examples/c/insert_data_demo.c
index edc6b0b750..e880af0cd6 100644
--- a/docs/examples/c/insert_data_demo.c
+++ b/docs/examples/c/insert_data_demo.c
@@ -71,4 +71,6 @@ static int DemoInsertData() {
   // ANCHOR_END: insert_data
 }
 
-int main(int argc, char *argv[]) { return DemoInsertData(); }
+int main(int argc, char *argv[]) {
+  return DemoInsertData();
+}
diff --git a/docs/examples/c/query_data_demo.c b/docs/examples/c/query_data_demo.c
index f2c6662d9e..097a6b99b8 100644
--- a/docs/examples/c/query_data_demo.c
+++ b/docs/examples/c/query_data_demo.c
@@ -62,9 +62,12 @@ static int DemoQueryData() {
   // fetch the records row by row
   while ((row = taos_fetch_row(result))) {
     char temp[1024] = {0};
-    rows++;
-    taos_print_row(temp, row, fields, num_fields);
+    if (taos_print_row(temp, row, fields, num_fields) < 0) {
+      printf("Failed to print row\n");
+      break;
+    }
     printf("%s\n", temp);
+    rows++;
   }
   printf("total rows: %d\n", rows);
   taos_free_result(result);
@@ -76,4 +79,6 @@ static int DemoQueryData() {
   // ANCHOR_END: query_data
 }
 
-int main(int argc, char *argv[]) { return DemoQueryData(); }
+int main(int argc, char *argv[]) {
+  return DemoQueryData();
+}
diff --git a/docs/examples/c/sml_insert_demo.c b/docs/examples/c/sml_insert_demo.c
index 1107734c78..9adbb28f87 100644
--- a/docs/examples/c/sml_insert_demo.c
+++ b/docs/examples/c/sml_insert_demo.c
@@ -48,7 +48,6 @@ static int DemoSmlInsert() {
     return -1;
   }
   taos_free_result(result);
-  printf("Create database power successfully.\n");
 
   // use database
   result = taos_query(taos, "USE power");
@@ -136,4 +135,6 @@ static int DemoSmlInsert() {
   // ANCHOR_END: schemaless
 }
 
-int main(int argc, char *argv[]) { return DemoSmlInsert(); }
+int main(int argc, char *argv[]) {
+  return DemoSmlInsert();
+}
diff --git a/docs/examples/c/tmq_demo.c b/docs/examples/c/tmq_demo.c
index 55ec568dc5..e8e28e1df4 100644
--- a/docs/examples/c/tmq_demo.c
+++ b/docs/examples/c/tmq_demo.c
@@ -132,7 +132,6 @@ static int32_t init_env() {
 
   TAOS_RES* pRes;
   // drop database if exists
-  fprintf(stdout, "Create database.\n");
   pRes = taos_query(pConn, "DROP TOPIC IF EXISTS topic_meters");
   code = taos_errno(pRes);
   if (code != 0) {
@@ -157,7 +156,6 @@ static int32_t init_env() {
   taos_free_result(pRes);
 
   // create super table
-  fprintf(stdout, "Create super table.\n");
   pRes = taos_query(
       pConn,
       "CREATE STABLE IF NOT EXISTS power.meters (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT) TAGS "
@@ -179,7 +177,6 @@ END:
 }
 
 int32_t create_topic() {
-  fprintf(stdout, "Create topic.\n");
   TAOS_RES*   pRes;
   const char* host = "localhost";
   const char* user = "root";
@@ -382,7 +379,6 @@ void manual_commit(tmq_t* tmq) {
       totalRows += msg_process(tmqmsg);
       // commit the message
       int32_t code = tmq_commit_sync(tmq, tmqmsg);
-
       if (code) {
         fprintf(stderr, "Failed to commit message, ErrCode: 0x%x, ErrMessage: %s.\n", code, tmq_err2str(code));
         // free the message
diff --git a/docs/examples/c/with_reqid_demo.c b/docs/examples/c/with_reqid_demo.c
index b3e4e79e39..c6e87686e9 100644
--- a/docs/examples/c/with_reqid_demo.c
+++ b/docs/examples/c/with_reqid_demo.c
@@ -62,9 +62,12 @@ static int DemoWithReqId() {
   // fetch the records row by row
   while ((row = taos_fetch_row(result))) {
     char temp[1024] = {0};
-    rows++;
-    taos_print_row(temp, row, fields, num_fields);
+    if (taos_print_row(temp, row, fields, num_fields) < 0) {
+      printf("Failed to print row\n");
+      break;
+    }
     printf("%s\n", temp);
+    rows++;
   }
   printf("total rows: %d\n", rows);
   taos_free_result(result);
@@ -76,4 +79,6 @@ static int DemoWithReqId() {
   // ANCHOR_END: with_reqid
 }
 
-int main(int argc, char *argv[]) { return DemoWithReqId(); }
+int main(int argc, char *argv[]) {
+  return DemoWithReqId();
+}