test: [TS-6100] Reopen stream ut (#32396)

source/libs/nodes/src/nodesCodeFuncs.c

@@ -5858,7 +5858,7 @@ static int32_t jsonToStreamNode(const SJson* pJson, void* pObj) {
 
 static const char* jkStreamTagDefTagName = "TagName";
 static const char* jkStreamTagDefDataType = "DataType";
-static const char* jkStreamTagDefTagExpr = "DataType";
+static const char* jkStreamTagDefTagExpr = "TagExpr";
 static const char* jkStreamTagDefComment = "Comment";
 
 static int32_t streamTagDefNodeToJson(const void* pObj, SJson* pJson) {
@@ -7407,7 +7407,7 @@ static int32_t createMountStmtToJson(const void* pObj, SJson* pJson) {
     code = tjsonAddIntegerToObject(pJson, jkMountStmtDnode, pNode->dnodeId);
   }
   if (TSDB_CODE_SUCCESS == code) {
-    tjsonAddStringToObject(pJson, jkMountStmtMountPath, pNode->mountPath);
+    code = tjsonAddStringToObject(pJson, jkMountStmtMountPath, pNode->mountPath);
   }
 
   return code;

source/libs/parser/test/mockCatalogService.cpp

@@ -242,6 +242,9 @@ class MockCatalogServiceImpl {
     if (TSDB_CODE_SUCCESS == code) {
       code = getAllViewMeta(pCatalogReq->pView, &pMetaData->pView);
     }
+    if (TSDB_CODE_SUCCESS == code) {
+      code = getAllVstbRefDbs(pCatalogReq->pVStbRefDbs, &pMetaData->pVStbRefDbs);
+    }
     return code;
   }
 
@@ -790,6 +793,27 @@ class MockCatalogServiceImpl {
     return TSDB_CODE_SUCCESS;
   }
 
+  int32_t getAllVstbRefDbs(SArray* pVstbRefDbsReq, SArray** pVstbRefDbsMetaData) const {
+    if (NULL != pVstbRefDbsReq) {
+      int32_t nRefs = taosArrayGetSize(pVstbRefDbsReq);
+      *pVstbRefDbsMetaData = taosArrayInit(nRefs, sizeof(SMetaRes));
+      if (!*pVstbRefDbsMetaData) {
+        return TSDB_CODE_OUT_OF_MEMORY;
+      }
+      for (int32_t i = 0; i < nRefs; ++i) {
+        SMetaRes res = {0};
+        res.pRes = nullptr;
+        res.code = TSDB_CODE_PAR_TABLE_NOT_EXIST;
+        if (nullptr == taosArrayPush(*pVstbRefDbsMetaData, &res)) {
+          taosArrayDestroyEx(*pVstbRefDbsMetaData, MockCatalogService::destoryMetaRes);
+          *pVstbRefDbsMetaData = nullptr;
+          return TSDB_CODE_OUT_OF_MEMORY;
+        }
+      }
+    }
+    return TSDB_CODE_SUCCESS;
+  }
+
   int32_t getAllDnodeList(SArray** pDnodes) const {
     SMetaRes res = {0};
     int32_t code = catalogGetDnodeList((SArray**)&res.pRes);