add sql check

src/client/src/tscServer.c

@@ -42,6 +42,11 @@ static void tscCheckpSql(SSqlObj* pSql) {
   assert(parent->metaSubPtr == pSql && parent->self == pSql->parentRid && parent->metaSubRid == pSql->self);
 }
 
+static void tscCheckpSql2(SSqlObj* pSql, SSqlObj* parent) {
+  assert(parent->metaSubPtr == pSql && parent->self == pSql->parentRid && parent->metaSubRid == pSql->self);
+}
+
+
 static int32_t minMsgSize() { return tsRpcHeadSize + 100; }
 static int32_t getWaitingTimeInterval(int32_t count) {
   int32_t initial = 100; // 100 ms by default

src/client/src/tscSubquery.c

@@ -1336,6 +1336,8 @@ void tscJoinQueryCallback(void* param, TAOS_RES* tres, int code) {
   SJoinSupporter* pSupporter = (SJoinSupporter*)param;
   SSqlObj* pParentSql = pSupporter->pObj;
 
+  tscCheckpSql2(pSql, pParentSql);
+    
   // There is only one subquery and table for each subquery.
   SQueryInfo* pQueryInfo = tscGetQueryInfoDetail(&pSql->cmd, 0);
   assert(pQueryInfo->numOfTables == 1 && pSql->cmd.numOfClause == 1);

src/client/src/tscUtil.c

@@ -1997,6 +1997,7 @@ SSqlObj* createSubqueryObj(SSqlObj* pSql, int16_t tableIndex, void (*fp)(), void
   pNew->pTscObj   = pSql->pTscObj;
   pNew->signature = pNew;
   pNew->sqlstr    = strdup(pSql->sqlstr);
+  pNew->parentRid = pSql->self;
 
   SSqlCmd* pnCmd = &pNew->cmd;
   memcpy(pnCmd, pCmd, sizeof(SSqlCmd));
@@ -2145,6 +2146,10 @@ SSqlObj* createSubqueryObj(SSqlObj* pSql, int16_t tableIndex, void (*fp)(), void
   }
 
   registerSqlObj(pNew);
+
+  pSql->metaSubRid = pNew->self;
+  pSql->metaSubPtr = pNew;
+    
   return pNew;
 
 _error: