From 0ef5bf60f0bcc8e3160c737c74faff4aa4901934 Mon Sep 17 00:00:00 2001
From: wpan <wpan@taosdata.com>
Date: Mon, 30 Aug 2021 08:51:08 +0800
Subject: [PATCH] add rootObj for more cases

---
 src/client/src/tscSql.c    | 2 ++
 src/client/src/tscStream.c | 1 +
 src/client/src/tscSub.c    | 1 +
 src/client/src/tscUtil.c   | 1 +
 4 files changed, 5 insertions(+)

diff --git a/src/client/src/tscSql.c b/src/client/src/tscSql.c
index 026c65a595..e292db30fd 100644
--- a/src/client/src/tscSql.c
+++ b/src/client/src/tscSql.c
@@ -874,6 +874,7 @@ int taos_validate_sql(TAOS *taos, const char *sql) {
 
   pSql->pTscObj  = taos;
   pSql->signature = pSql;
+  pSql->rootObj = pSql;
   SSqlCmd *pCmd = &pSql->cmd;
   
   pCmd->resColumnId = TSDB_RES_COL_ID;
@@ -982,6 +983,7 @@ int taos_load_table_info(TAOS *taos, const char *tableNameList) {
 
   pSql->pTscObj   = taos;
   pSql->signature = pSql;
+  pSql->rootObj = pSql;
 
   int32_t code = (uint8_t) tscTransferTableNameList(pSql, str, length, plist);
   free(str);
diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index 2c4bc5f764..63459a5979 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -679,6 +679,7 @@ TAOS_STREAM *taos_open_stream_withname(TAOS *taos, const char* dstTable, const c
 
   pSql->signature = pSql;
   pSql->pTscObj = pObj;
+  pSql->rootObj = pSql;
 
   SSqlCmd *pCmd = &pSql->cmd;
   SSqlRes *pRes = &pSql->res;
diff --git a/src/client/src/tscSub.c b/src/client/src/tscSub.c
index 52ba424fa5..0c5eac66e2 100644
--- a/src/client/src/tscSub.c
+++ b/src/client/src/tscSub.c
@@ -127,6 +127,7 @@ static SSub* tscCreateSubscription(STscObj* pObj, const char* topic, const char*
   pSql->signature = pSql;
   pSql->pTscObj = pObj;
   pSql->pSubscription = pSub;
+  pSql->rootObj = pSql;
   pSub->pSql = pSql;
 
   SSqlCmd* pCmd = &pSql->cmd;
diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index 2098e9aa87..82f950020f 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -3458,6 +3458,7 @@ SSqlObj* createSimpleSubObj(SSqlObj* pSql, __async_cb_func_t fp, void* param, in
 
   pNew->pTscObj = pSql->pTscObj;
   pNew->signature = pNew;
+  pNew->rootObj = pSql->rootObj;
 
   SSqlCmd* pCmd = &pNew->cmd;
   pCmd->command = cmd;
-- 
GitLab