diff --git a/include/dnode/mnode/mnode.h b/include/dnode/mnode/mnode.h
index 3bed77d682f14d3409b02bccd366bd99b3be2a94..0d43539629c170a2dcf22bee395cbc7caa93edc5 100644
--- a/include/dnode/mnode/mnode.h
+++ b/include/dnode/mnode/mnode.h
@@ -106,6 +106,8 @@ void    mndPostProcessQueryMsg(SRpcMsg *pMsg);
  */
 void mndGenerateMachineCode();
 
+void mndDumpSdb();
+
 #ifdef __cplusplus
 }
 #endif
diff --git a/source/dnode/mgmt/exe/dmMain.c b/source/dnode/mgmt/exe/dmMain.c
index 4030eaa6fe2fd32ec5718b6e4f7689f619747366..6406ae560f3619ca5b7019e309430e40246d4d54 100644
--- a/source/dnode/mgmt/exe/dmMain.c
+++ b/source/dnode/mgmt/exe/dmMain.c
@@ -16,10 +16,12 @@
 #define _DEFAULT_SOURCE
 #include "dmMgmt.h"
 #include "tconfig.h"
+#include "mnode.h"
 
 #define DM_APOLLO_URL    "The apollo string to use when configuring the server, such as: -a 'jsonFile:./tests/cfg.json', cfg.json text can be '{\"fqdn\":\"td1\"}'."
 #define DM_CFG_DIR       "Configuration directory."
 #define DM_DMP_CFG       "Dump configuration."
+#define DM_SDB_INFO      "Dump sdb info."
 #define DM_ENV_CMD       "The env cmd variable string to use when configuring the server, such as: -e 'TAOS_FQDN=td1'."
 #define DM_ENV_FILE      "The env variable file path to use when configuring the server, default is './.env', .env text can be 'TAOS_FQDN=td1'."
 #define DM_NODE_TYPE     "Startup type of the node, default is 0."
@@ -31,6 +33,7 @@ static struct {
   bool         winServiceMode;
 #endif
   bool         dumpConfig;
+  bool         dumpSdb;
   bool         generateGrant;
   bool         printAuth;
   bool         printVersion;
@@ -82,6 +85,8 @@ static int32_t dmParseArgs(int32_t argc, char const *argv[]) {
       }
     } else if (strcmp(argv[i], "-a") == 0) {
       tstrncpy(global.apolloUrl, argv[++i], PATH_MAX);
+    } else if (strcmp(argv[i], "-s") == 0) {
+      global.dumpSdb = true;
     } else if (strcmp(argv[i], "-E") == 0) {
       tstrncpy(global.envFile, argv[++i], PATH_MAX);
     } else if (strcmp(argv[i], "-n") == 0) {
@@ -131,6 +136,7 @@ static void dmPrintHelp() {
   printf("Usage: taosd [OPTION...] \n\n");
   printf("%s%s%s%s\n", indent, "-a,", indent, DM_APOLLO_URL);
   printf("%s%s%s%s\n", indent, "-c,", indent, DM_CFG_DIR);
+  printf("%s%s%s%s\n", indent, "-s,", indent, DM_SDB_INFO);
   printf("%s%s%s%s\n", indent, "-C,", indent, DM_DMP_CFG);
   printf("%s%s%s%s\n", indent, "-e,", indent, DM_ENV_CMD);
   printf("%s%s%s%s\n", indent, "-E,", indent, DM_ENV_FILE);
@@ -229,6 +235,14 @@ int mainWindows(int argc,char** argv) {
     return 0;
   }
 
+  if (global.dumpSdb) {
+    mndDumpSdb();
+    taosCleanupCfg();
+    taosCloseLog();
+    taosCleanupArgs();
+    return 0;
+  }
+
   dmSetProcInfo(argc, (char **)argv);
   taosCleanupArgs();
 
diff --git a/source/dnode/mnode/impl/inc/mndStb.h b/source/dnode/mnode/impl/inc/mndStb.h
index 8f0d55e10061ce4517c4305ae7450a7439b91cfd..ba9acdbd8fb7bc7762e26f6580f7eecee49a961c 100644
--- a/source/dnode/mnode/impl/inc/mndStb.h
+++ b/source/dnode/mnode/impl/inc/mndStb.h
@@ -40,6 +40,8 @@ int32_t mndBuildSMCreateStbRsp(SMnode *pMnode, char* dbFName, char* stbFName, vo
 void mndExtractDbNameFromStbFullName(const char *stbFullName, char *dst);
 void mndExtractTbNameFromStbFullName(const char *stbFullName, char *dst, int32_t dstSize);
 
+const char *mndGetStbStr(const char *src);
+
 #ifdef __cplusplus
 }
 #endif
diff --git a/source/dnode/mnode/impl/src/mndConsumer.c b/source/dnode/mnode/impl/src/mndConsumer.c
index e0dbc26122dae92cf371834cedeb83f4fc536036..12bf23bb219d3987a1b77ec3c34e9aaa8982de82 100644
--- a/source/dnode/mnode/impl/src/mndConsumer.c
+++ b/source/dnode/mnode/impl/src/mndConsumer.c
@@ -54,13 +54,15 @@ static int32_t mndProcessConsumerLostMsg(SRpcMsg *pMsg);
 static int32_t mndProcessConsumerRecoverMsg(SRpcMsg *pMsg);
 
 int32_t mndInitConsumer(SMnode *pMnode) {
-  SSdbTable table = {.sdbType = SDB_CONSUMER,
-                     .keyType = SDB_KEY_INT64,
-                     .encodeFp = (SdbEncodeFp)mndConsumerActionEncode,
-                     .decodeFp = (SdbDecodeFp)mndConsumerActionDecode,
-                     .insertFp = (SdbInsertFp)mndConsumerActionInsert,
-                     .updateFp = (SdbUpdateFp)mndConsumerActionUpdate,
-                     .deleteFp = (SdbDeleteFp)mndConsumerActionDelete};
+  SSdbTable table = {
+      .sdbType = SDB_CONSUMER,
+      .keyType = SDB_KEY_INT64,
+      .encodeFp = (SdbEncodeFp)mndConsumerActionEncode,
+      .decodeFp = (SdbDecodeFp)mndConsumerActionDecode,
+      .insertFp = (SdbInsertFp)mndConsumerActionInsert,
+      .updateFp = (SdbUpdateFp)mndConsumerActionUpdate,
+      .deleteFp = (SdbDeleteFp)mndConsumerActionDelete,
+  };
 
   mndSetMsgHandle(pMnode, TDMT_MND_SUBSCRIBE, mndProcessSubscribeReq);
   mndSetMsgHandle(pMnode, TDMT_MND_MQ_HB, mndProcessMqHbReq);
diff --git a/source/dnode/mnode/impl/src/mndDump.c b/source/dnode/mnode/impl/src/mndDump.c
new file mode 100644
index 0000000000000000000000000000000000000000..881ebbbf9de161018a3d0965bd61f2ab92666094
--- /dev/null
+++ b/source/dnode/mnode/impl/src/mndDump.c
@@ -0,0 +1,645 @@
+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#define _DEFAULT_SOURCE
+#include "mndDb.h"
+#include "mndInt.h"
+#include "mndStb.h"
+#include "sdb.h"
+#include "tconfig.h"
+#include "tjson.h"
+#include "ttypes.h"
+
+#pragma GCC diagnostic push
+#pragma GCC diagnostic ignored "-Wunused-result"
+
+void reportStartup(const char *name, const char *desc) {}
+void sendRsp(SRpcMsg *pMsg) { rpcFreeCont(pMsg->pCont); }
+
+int32_t sendReq(const SEpSet *pEpSet, SRpcMsg *pMsg) {
+  terrno = TSDB_CODE_INVALID_PTR;
+  return -1;
+}
+
+char *i642str(int64_t val) {
+  static char str[24] = {0};
+  snprintf(str, sizeof(str), "%" PRId64, val);
+  return str;
+}
+
+void dumpFunc(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "funcs");
+
+  while (1) {
+    SFuncObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_FUNC, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "name", pObj->name);
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "funcType", i642str(pObj->funcType));
+    tjsonAddStringToObject(item, "scriptType", i642str(pObj->scriptType));
+    tjsonAddStringToObject(item, "align", i642str(pObj->align));
+    tjsonAddStringToObject(item, "outputType", i642str(pObj->outputType));
+    tjsonAddStringToObject(item, "outputLen", i642str(pObj->outputLen));
+    tjsonAddStringToObject(item, "bufSize", i642str(pObj->bufSize));
+    tjsonAddStringToObject(item, "signature", i642str(pObj->signature));
+    tjsonAddStringToObject(item, "commentSize", i642str(pObj->commentSize));
+    tjsonAddStringToObject(item, "codeSize", i642str(pObj->codeSize));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpDb(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonCreateObject();
+  tjsonAddItemToObject(json, "dbs", items);
+
+  while (1) {
+    SDbObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_DB, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToObject(items, "db", item);
+
+    tjsonAddStringToObject(item, "name", mndGetDbStr(pObj->name));
+    tjsonAddStringToObject(item, "acct", pObj->acct);
+    tjsonAddStringToObject(item, "createUser", pObj->createUser);
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "uid", i642str(pObj->uid));
+    tjsonAddStringToObject(item, "cfgVersion", i642str(pObj->cfgVersion));
+    tjsonAddStringToObject(item, "vgVersion", i642str(pObj->vgVersion));
+    tjsonAddStringToObject(item, "numOfVgroups", i642str(pObj->cfg.numOfVgroups));
+    tjsonAddStringToObject(item, "numOfStables", i642str(pObj->cfg.numOfStables));
+    tjsonAddStringToObject(item, "buffer", i642str(pObj->cfg.buffer));
+    tjsonAddStringToObject(item, "pageSize", i642str(pObj->cfg.pageSize));
+    tjsonAddStringToObject(item, "pages", i642str(pObj->cfg.pages));
+    tjsonAddStringToObject(item, "cacheLastSize", i642str(pObj->cfg.cacheLastSize));
+    tjsonAddStringToObject(item, "daysPerFile", i642str(pObj->cfg.daysPerFile));
+    tjsonAddStringToObject(item, "daysToKeep0", i642str(pObj->cfg.daysToKeep0));
+    tjsonAddStringToObject(item, "daysToKeep1", i642str(pObj->cfg.daysToKeep1));
+    tjsonAddStringToObject(item, "daysToKeep2", i642str(pObj->cfg.daysToKeep2));
+    tjsonAddStringToObject(item, "minRows", i642str(pObj->cfg.minRows));
+    tjsonAddStringToObject(item, "maxRows", i642str(pObj->cfg.maxRows));
+    tjsonAddStringToObject(item, "precision", i642str(pObj->cfg.precision));
+    tjsonAddStringToObject(item, "compression", i642str(pObj->cfg.compression));
+    tjsonAddStringToObject(item, "replications", i642str(pObj->cfg.replications));
+    tjsonAddStringToObject(item, "strict", i642str(pObj->cfg.strict));
+    tjsonAddStringToObject(item, "cacheLast",i642str( pObj->cfg.cacheLast));
+    tjsonAddStringToObject(item, "hashMethod", i642str(pObj->cfg.hashMethod));
+    tjsonAddStringToObject(item, "hashPrefix", i642str(pObj->cfg.hashPrefix));
+    tjsonAddStringToObject(item, "hashSuffix", i642str(pObj->cfg.hashSuffix));
+    tjsonAddStringToObject(item, "sstTrigger", i642str(pObj->cfg.sstTrigger));
+    tjsonAddStringToObject(item, "tsdbPageSize",i642str( pObj->cfg.tsdbPageSize));
+    tjsonAddStringToObject(item, "schemaless", i642str(pObj->cfg.schemaless));
+    tjsonAddStringToObject(item, "walLevel",i642str( pObj->cfg.walLevel));
+    tjsonAddStringToObject(item, "walFsyncPeriod", i642str(pObj->cfg.walFsyncPeriod));
+    tjsonAddStringToObject(item, "walRetentionPeriod", i642str(pObj->cfg.walRetentionPeriod));
+    tjsonAddStringToObject(item, "walRetentionSize",i642str( pObj->cfg.walRetentionSize));
+    tjsonAddStringToObject(item, "walRollPeriod", i642str(pObj->cfg.walRollPeriod));
+    tjsonAddStringToObject(item, "walSegmentSize", i642str(pObj->cfg.walSegmentSize));
+
+    tjsonAddStringToObject(item, "numOfRetensions",i642str( pObj->cfg.numOfRetensions));
+    for (int32_t i = 0; i < pObj->cfg.numOfRetensions; ++i) {
+      SJson *rentensions = tjsonAddArrayToObject(item, "rentensions");
+      SJson *rentension = tjsonCreateObject();
+      tjsonAddItemToArray(rentensions, rentension);
+
+      SRetention *pRetension = taosArrayGet(pObj->cfg.pRetensions, i);
+      tjsonAddStringToObject(item, "freq", i642str(pRetension->freq));
+      tjsonAddStringToObject(item, "freqUnit", i642str(pRetension->freqUnit));
+      tjsonAddStringToObject(item, "keep", i642str(pRetension->keep));
+      tjsonAddStringToObject(item, "keepUnit",i642str( pRetension->keepUnit));
+    }
+
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpStb(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "stbs");
+
+  while (1) {
+    SStbObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_STB, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "name", mndGetStbStr(pObj->name));
+    tjsonAddStringToObject(item, "db", mndGetDbStr(pObj->db));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "uid", i642str(pObj->uid));
+    tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid));
+    tjsonAddStringToObject(item, "tagVer",i642str( pObj->tagVer));
+    tjsonAddStringToObject(item, "colVer", i642str(pObj->colVer));
+    tjsonAddStringToObject(item, "smaVer", i642str(pObj->smaVer));
+    tjsonAddStringToObject(item, "nextColId", i642str(pObj->nextColId));
+    tjsonAddStringToObject(item, "watermark1", i642str(pObj->watermark[0]));
+    tjsonAddStringToObject(item, "watermark2", i642str(pObj->watermark[1]));
+    tjsonAddStringToObject(item, "maxdelay0",i642str( pObj->maxdelay[0]));
+    tjsonAddStringToObject(item, "maxdelay1",i642str( pObj->maxdelay[1]));
+    tjsonAddStringToObject(item, "ttl",i642str( pObj->ttl));
+    tjsonAddStringToObject(item, "numOfFuncs",i642str( pObj->numOfFuncs));
+    tjsonAddStringToObject(item, "commentLen", i642str(pObj->commentLen));
+    tjsonAddStringToObject(item, "ast1Len", i642str(pObj->ast1Len));
+    tjsonAddStringToObject(item, "ast2Len",i642str( pObj->ast2Len));
+
+    tjsonAddStringToObject(item, "numOfColumns",i642str( pObj->numOfColumns));
+    SJson *columns = tjsonAddArrayToObject(item, "columns");
+    for (int32_t i = 0; i < pObj->numOfColumns; ++i) {
+      SJson *column = tjsonCreateObject();
+      tjsonAddItemToArray(columns, column);
+
+      SSchema *pColumn = &pObj->pColumns[i];
+      tjsonAddStringToObject(column, "type", i642str(pColumn->type));
+      tjsonAddStringToObject(column, "typestr", tDataTypes[pColumn->type].name);
+      tjsonAddStringToObject(column, "flags", i642str(pColumn->flags));
+      tjsonAddStringToObject(column, "colId", i642str(pColumn->colId));
+      tjsonAddStringToObject(column, "bytes", i642str(pColumn->bytes));
+      tjsonAddStringToObject(column, "name", pColumn->name);
+    }
+
+    tjsonAddStringToObject(item, "numOfTags", i642str(pObj->numOfTags));
+    SJson *tags = tjsonAddArrayToObject(item, "tags");
+    for (int32_t i = 0; i < pObj->numOfTags; ++i) {
+      SJson *tag = tjsonCreateObject();
+      tjsonAddItemToArray(tags, tag);
+
+      SSchema *pTag = &pObj->pTags[i];
+      tjsonAddStringToObject(tag, "type", i642str(pTag->type));
+      tjsonAddStringToObject(tag, "typestr", tDataTypes[pTag->type].name);
+      tjsonAddStringToObject(tag, "flags",i642str( pTag->flags));
+      tjsonAddStringToObject(tag, "colId", i642str(pTag->colId));
+      tjsonAddStringToObject(tag, "bytes", i642str(pTag->bytes));
+      tjsonAddStringToObject(tag, "name", pTag->name);
+    }
+
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpSma(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "smas");
+
+  while (1) {
+    SSmaObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_SMA, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "name", mndGetStbStr(pObj->name));
+    tjsonAddStringToObject(item, "stb", mndGetStbStr(pObj->stb));
+    tjsonAddStringToObject(item, "db", mndGetDbStr(pObj->db));
+    tjsonAddStringToObject(item, "dstTbName", mndGetStbStr(pObj->dstTbName));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "uid", i642str(pObj->uid));
+    tjsonAddStringToObject(item, "stbUid", i642str(pObj->stbUid));
+    tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid));
+    tjsonAddStringToObject(item, "dstTbUid", i642str(pObj->dstTbUid));
+    tjsonAddStringToObject(item, "intervalUnit", i642str(pObj->intervalUnit));
+    tjsonAddStringToObject(item, "slidingUnit",i642str( pObj->slidingUnit));
+    tjsonAddStringToObject(item, "timezone", i642str(pObj->timezone));
+    tjsonAddStringToObject(item, "dstVgId",i642str( pObj->dstVgId));
+    tjsonAddStringToObject(item, "interval", i642str(pObj->interval));
+    tjsonAddStringToObject(item, "offset", i642str(pObj->offset));
+    tjsonAddStringToObject(item, "sliding", i642str(pObj->sliding));
+    tjsonAddStringToObject(item, "exprLen",i642str( pObj->exprLen));
+    tjsonAddStringToObject(item, "tagsFilterLen", i642str(pObj->tagsFilterLen));
+    tjsonAddStringToObject(item, "sqlLen",i642str( pObj->sqlLen));
+    tjsonAddStringToObject(item, "astLen",i642str( pObj->astLen));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpVgroup(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "vgroups");
+
+  while (1) {
+    SVgObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_VGROUP, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "vgId", i642str(pObj->vgId));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "version",i642str(pObj->version));
+    tjsonAddStringToObject(item, "hashBegin", i642str(pObj->hashBegin));
+    tjsonAddStringToObject(item, "hashEnd", i642str(pObj->hashEnd));
+    tjsonAddStringToObject(item, "db", mndGetDbStr(pObj->dbName));
+    tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid));
+    tjsonAddStringToObject(item, "isTsma", i642str(pObj->isTsma));
+    tjsonAddStringToObject(item, "replica",i642str( pObj->replica));
+    for (int32_t i = 0; i < pObj->replica; ++i) {
+      SJson *replicas = tjsonAddArrayToObject(item, "replicas");
+      SJson *replica = tjsonCreateObject();
+      tjsonAddItemToArray(replicas, replica);
+      tjsonAddStringToObject(replica, "dnodeId", i642str(pObj->vnodeGid[i].dnodeId));
+    }
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpTopic(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "topics");
+
+  while (1) {
+    SMqTopicObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_TOPIC, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "name", mndGetDbStr(pObj->name));
+    tjsonAddStringToObject(item, "name", mndGetDbStr(pObj->db));
+    tjsonAddStringToObject(item, "createTime", i642str(pObj->createTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "uid", i642str(pObj->uid));
+    tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid));
+    tjsonAddStringToObject(item, "version",i642str( pObj->version));
+    tjsonAddStringToObject(item, "subType",i642str( pObj->subType));
+    tjsonAddStringToObject(item, "withMeta", i642str(pObj->withMeta));
+    tjsonAddStringToObject(item, "stbUid", i642str(pObj->stbUid));
+    tjsonAddStringToObject(item, "sqlLen", i642str(pObj->sqlLen));
+    tjsonAddStringToObject(item, "astLen",i642str( pObj->astLen));
+    tjsonAddStringToObject(item, "sqlLen",i642str( pObj->sqlLen));
+    tjsonAddStringToObject(item, "ntbUid", i642str(pObj->ntbUid));
+    tjsonAddStringToObject(item, "ctbStbUid", i642str(pObj->ctbStbUid));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpConsumer(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "consumers");
+
+  while (1) {
+    SMqConsumerObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_CONSUMER, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "consumerId", i642str(pObj->consumerId));
+    tjsonAddStringToObject(item, "cgroup", pObj->cgroup);
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpSubscribe(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "subscribes");
+
+  while (1) {
+    SMqSubscribeObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_SUBSCRIBE, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "key", pObj->key);
+    tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid));
+    tjsonAddStringToObject(item, "stbUid", i642str(pObj->stbUid));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpOffset(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "offsets");
+
+  while (1) {
+    SMqOffsetObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_OFFSET, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "key", pObj->key);
+    tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid));
+    tjsonAddStringToObject(item, "offset", i642str(pObj->offset));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpStream(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "streams");
+
+  while (1) {
+    SStreamObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_STREAM, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "name", mndGetDbStr(pObj->name));
+    tjsonAddStringToObject(item, "createTime", i642str(pObj->createTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "version", i642str(pObj->version));
+    tjsonAddStringToObject(item, "totalLevel", i642str(pObj->totalLevel));
+    tjsonAddStringToObject(item, "smaId", i642str(pObj->smaId));
+    tjsonAddStringToObject(item, "uid", i642str(pObj->uid));
+    tjsonAddStringToObject(item, "status",i642str( pObj->status));
+    tjsonAddStringToObject(item, "igExpired",i642str( pObj->igExpired));
+    tjsonAddStringToObject(item, "trigger",i642str( pObj->trigger));
+    tjsonAddStringToObject(item, "triggerParam", i642str(pObj->triggerParam));
+    tjsonAddStringToObject(item, "watermark", i642str(pObj->watermark));
+    tjsonAddStringToObject(item, "sourceDbUid", i642str(pObj->sourceDbUid));
+    tjsonAddStringToObject(item, "targetDbUid", i642str(pObj->targetDbUid));
+    tjsonAddStringToObject(item, "sourceDb", mndGetDbStr(pObj->sourceDb));
+    tjsonAddStringToObject(item, "targetDb", mndGetDbStr(pObj->targetDb));
+    tjsonAddStringToObject(item, "targetSTbName", mndGetStbStr(pObj->targetSTbName));
+    tjsonAddStringToObject(item, "targetStbUid", i642str(pObj->targetStbUid));
+    tjsonAddStringToObject(item, "fixedSinkVgId", i642str(pObj->fixedSinkVgId));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpAcct(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "accts");
+
+  while (1) {
+    SAcctObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_ACCT, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "acct", pObj->acct);
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "acctId", i642str(pObj->acctId));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpAuth(SSdb *pSdb, SJson *json) {
+  // todo
+}
+
+void dumpUser(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "users");
+
+  while (1) {
+    SUserObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_USER, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "name", pObj->user);
+    tjsonAddStringToObject(item, "acct", pObj->acct);
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "superUser",i642str( pObj->superUser));
+    tjsonAddStringToObject(item, "authVersion", i642str(pObj->authVersion));
+    tjsonAddStringToObject(item, "numOfReadDbs",i642str( taosHashGetSize(pObj->readDbs)));
+    tjsonAddStringToObject(item, "numOfWriteDbs", i642str(taosHashGetSize(pObj->writeDbs)));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpDnode(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "dnodes");
+
+  while (1) {
+    SDnodeObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_DNODE, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "id",i642str( pObj->id));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "port",i642str( pObj->port));
+    tjsonAddStringToObject(item, "fqdn", pObj->fqdn);
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpBnode(SSdb *pSdb, SJson *json) {
+  // not implemented yet
+}
+
+void dumpSnode(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "snodes");
+
+  while (1) {
+    SSnodeObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_QNODE, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "id",i642str( pObj->id));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpQnode(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "qnodes");
+
+  while (1) {
+    SQnodeObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_QNODE, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "id", i642str(pObj->id));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpMnode(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "mnodes");
+
+  while (1) {
+    SMnodeObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_MNODE, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "id", i642str(pObj->id));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpCluster(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "clusters");
+
+  while (1) {
+    SClusterObj *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_CLUSTER, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "id", i642str(pObj->id));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
+    tjsonAddStringToObject(item, "name", pObj->name);
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpTrans(SSdb *pSdb, SJson *json) {
+  void  *pIter = NULL;
+  SJson *items = tjsonAddArrayToObject(json, "transactions");
+
+  while (1) {
+    STrans *pObj = NULL;
+    pIter = sdbFetch(pSdb, SDB_TRANS, pIter, (void **)&pObj);
+    if (pIter == NULL) break;
+
+    SJson *item = tjsonCreateObject();
+    tjsonAddItemToArray(items, item);
+    tjsonAddStringToObject(item, "id", i642str(pObj->id));
+    tjsonAddStringToObject(item, "stage", i642str(pObj->stage));
+    tjsonAddStringToObject(item, "policy", i642str(pObj->policy));
+    tjsonAddStringToObject(item, "conflict",i642str( pObj->conflict));
+    tjsonAddStringToObject(item, "exec", i642str(pObj->exec));
+    tjsonAddStringToObject(item, "oper", i642str(pObj->oper));
+    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
+    tjsonAddStringToObject(item, "dbname", pObj->dbname);
+    tjsonAddStringToObject(item, "stbname", pObj->stbname);
+    tjsonAddStringToObject(item, "opername", pObj->opername);
+    tjsonAddStringToObject(item, "commitLogNum",i642str( taosArrayGetSize(pObj->commitActions)));
+    tjsonAddStringToObject(item, "redoActionNum",i642str(taosArrayGetSize(pObj->redoActions)));
+    tjsonAddStringToObject(item, "undoActionNum", i642str(taosArrayGetSize(pObj->undoActions)));
+    sdbRelease(pSdb, pObj);
+  }
+}
+
+void dumpHeader(SSdb *pSdb, SJson *json) {
+  tjsonAddStringToObject(json, "sver", i642str(1));
+  tjsonAddStringToObject(json, "applyIndex", i642str(pSdb->applyIndex));
+  tjsonAddStringToObject(json, "applyTerm", i642str(pSdb->applyTerm));
+  tjsonAddStringToObject(json, "applyConfig", i642str(pSdb->applyConfig));
+
+  SJson *maxIdsJson = tjsonCreateObject();
+  tjsonAddItemToObject(json, "maxIds", maxIdsJson);
+  for (int32_t i = 0; i < SDB_MAX; ++i) {
+    int64_t maxId = 0;
+    if (i < SDB_MAX) {
+      maxId = pSdb->maxId[i];
+    }
+    tjsonAddStringToObject(maxIdsJson, sdbTableName(i), i642str(maxId));
+  }
+
+  SJson *tableVersJson = tjsonCreateObject();
+  tjsonAddItemToObject(json, "tableVers", tableVersJson);
+  for (int32_t i = 0; i < SDB_MAX; ++i) {
+    int64_t tableVer = 0;
+    if (i < SDB_MAX) {
+      tableVer = pSdb->tableVer[i];
+    }
+    tjsonAddStringToObject(tableVersJson, sdbTableName(i), i642str(tableVer));
+  }
+}
+
+void mndDumpSdb() {
+  mInfo("start to dump sdb info to sdb.json");
+
+  char path[PATH_MAX * 2] = {0};
+  snprintf(path, sizeof(path), "%s%smnode", tsDataDir, TD_DIRSEP);
+
+  SMsgCb msgCb = {0};
+  msgCb.reportStartupFp = reportStartup;
+  msgCb.sendReqFp = sendReq;
+  msgCb.sendRspFp = sendRsp;
+  msgCb.mgmt = (SMgmtWrapper *)(&msgCb);  // hack
+  tmsgSetDefault(&msgCb);
+
+  walInit();
+  syncInit();
+
+  SMnodeOpt opt = {.msgCb = msgCb};
+  SMnode   *pMnode = mndOpen(path, &opt);
+  if (pMnode == NULL) return;
+
+  SSdb  *pSdb = pMnode->pSdb;
+  SJson *json = tjsonCreateObject();
+  dumpHeader(pSdb, json);
+  dumpFunc(pSdb, json);
+  dumpDb(pSdb, json);
+  dumpStb(pSdb, json);
+  dumpSma(pSdb, json);
+  dumpVgroup(pSdb, json);
+  dumpTopic(pSdb, json);
+  dumpConsumer(pSdb, json);
+  dumpSubscribe(pSdb, json);
+  dumpOffset(pSdb, json);
+  dumpStream(pSdb, json);
+  dumpAcct(pSdb, json);
+  dumpAuth(pSdb, json);
+  dumpUser(pSdb, json);
+  dumpDnode(pSdb, json);
+  dumpBnode(pSdb, json);
+  dumpSnode(pSdb, json);
+  dumpQnode(pSdb, json);
+  dumpMnode(pSdb, json);
+  dumpCluster(pSdb, json);
+  dumpTrans(pSdb, json);
+
+  char     *pCont = tjsonToString(json);
+  int32_t   contLen = strlen(pCont);
+  char      file[] = "sdb.json";
+  TdFilePtr pFile = taosOpenFile(file, TD_FILE_CREATE | TD_FILE_WRITE | TD_FILE_TRUNC);
+  if (pFile == NULL) {
+    terrno = TAOS_SYSTEM_ERROR(errno);
+    mError("failed to write %s since %s", file, terrstr());
+    return;
+  }
+  taosWriteFile(pFile, pCont, contLen);
+  taosWriteFile(pFile, "\n", 1);
+  taosFsyncFile(pFile);
+  taosCloseFile(&pFile);
+  tjsonDelete(json);
+  taosMemoryFree(pCont);
+
+  mInfo("dump sdb info success");
+}
+
+#pragma GCC diagnostic pop
diff --git a/source/dnode/mnode/impl/src/mndFunc.c b/source/dnode/mnode/impl/src/mndFunc.c
index 48ab485a2c3077ce6f8db401ec2ca5db0e884117..727f7b0cc90f42d6d560fb1f34a5c9a82f70de22 100644
--- a/source/dnode/mnode/impl/src/mndFunc.c
+++ b/source/dnode/mnode/impl/src/mndFunc.c
@@ -38,13 +38,15 @@ static int32_t  mndRetrieveFuncs(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock *pB
 static void     mndCancelGetNextFunc(SMnode *pMnode, void *pIter);
 
 int32_t mndInitFunc(SMnode *pMnode) {
-  SSdbTable table = {.sdbType = SDB_FUNC,
-                     .keyType = SDB_KEY_BINARY,
-                     .encodeFp = (SdbEncodeFp)mndFuncActionEncode,
-                     .decodeFp = (SdbDecodeFp)mndFuncActionDecode,
-                     .insertFp = (SdbInsertFp)mndFuncActionInsert,
-                     .updateFp = (SdbUpdateFp)mndFuncActionUpdate,
-                     .deleteFp = (SdbDeleteFp)mndFuncActionDelete};
+  SSdbTable table = {
+      .sdbType = SDB_FUNC,
+      .keyType = SDB_KEY_BINARY,
+      .encodeFp = (SdbEncodeFp)mndFuncActionEncode,
+      .decodeFp = (SdbDecodeFp)mndFuncActionDecode,
+      .insertFp = (SdbInsertFp)mndFuncActionInsert,
+      .updateFp = (SdbUpdateFp)mndFuncActionUpdate,
+      .deleteFp = (SdbDeleteFp)mndFuncActionDelete,
+  };
 
   mndSetMsgHandle(pMnode, TDMT_MND_CREATE_FUNC, mndProcessCreateFuncReq);
   mndSetMsgHandle(pMnode, TDMT_MND_DROP_FUNC, mndProcessDropFuncReq);
diff --git a/source/dnode/mnode/impl/src/mndStb.c b/source/dnode/mnode/impl/src/mndStb.c
index e0b5bb1abf652dfd39f56b6100ad785ae3add516..0c2cd41605eb093353a12833302684329e4377d0 100644
--- a/source/dnode/mnode/impl/src/mndStb.c
+++ b/source/dnode/mnode/impl/src/mndStb.c
@@ -2579,3 +2579,14 @@ static void mndCancelGetNextStb(SMnode *pMnode, void *pIter) {
   SSdb *pSdb = pMnode->pSdb;
   sdbCancelFetch(pSdb, pIter);
 }
+
+const char *mndGetStbStr(const char *src) {
+  char *posDb = strstr(src, TS_PATH_DELIMITER);
+  if (posDb != NULL) ++posDb;
+  if (posDb == NULL) return src;
+
+  char *posStb = strstr(posDb, TS_PATH_DELIMITER);
+  if (posStb != NULL) ++posStb;
+  if (posStb == NULL) return posDb;
+  return posStb;
+}
\ No newline at end of file
diff --git a/source/dnode/mnode/sdb/src/sdbHash.c b/source/dnode/mnode/sdb/src/sdbHash.c
index a102541aca28222bbd48eac0dd1b0a597f795c21..7ff46709975641784cace6d185f1750ef75237d6 100644
--- a/source/dnode/mnode/sdb/src/sdbHash.c
+++ b/source/dnode/mnode/sdb/src/sdbHash.c
@@ -40,6 +40,8 @@ const char *sdbTableName(ESdbType type) {
       return "auth";
     case SDB_ACCT:
       return "acct";
+    case SDB_STREAM_CK:
+      return "stream_ck";
     case SDB_STREAM:
       return "stream";
     case SDB_OFFSET:
diff --git a/utils/test/c/CMakeLists.txt b/utils/test/c/CMakeLists.txt
index 839c65b633b17872051075be33ce291fbeaefd5a..b048b79e9b71058faaccdadeb723c1e0f46dce58 100644
--- a/utils/test/c/CMakeLists.txt
+++ b/utils/test/c/CMakeLists.txt
@@ -40,20 +40,3 @@ target_link_libraries(
     PUBLIC common
     PUBLIC os
 )
-
-add_executable(sdbDump sdbDump.c)
-target_link_libraries(
-    sdbDump
-    PUBLIC dnode
-    PUBLIC mnode
-    PUBLIC stream
-    PUBLIC sdb
-    PUBLIC os
-)
-target_include_directories(
-    sdbDump
-    PUBLIC "${TD_SOURCE_DIR}/include/dnode/mnode"
-    PRIVATE "${TD_SOURCE_DIR}/source/dnode/mnode/impl/inc"
-    PRIVATE "${TD_SOURCE_DIR}/source/dnode/mnode/sdb/inc"
-    PRIVATE "${TD_SOURCE_DIR}/source/dnode/mgmt/node_mgmt/inc"
-)
diff --git a/utils/test/c/sdbDump.c b/utils/test/c/sdbDump.c
deleted file mode 100644
index b056fe58a3a245cea470262816544f05a2c0f880..0000000000000000000000000000000000000000
--- a/utils/test/c/sdbDump.c
+++ /dev/null
@@ -1,475 +0,0 @@
-/*
- * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
- *
- * This program is free software: you can use, redistribute, and/or modify
- * it under the terms of the GNU Affero General Public License, version 3
- * or later ("AGPL"), as published by the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE.
- *
- * You should have received a copy of the GNU Affero General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-
-#define _DEFAULT_SOURCE
-#include "dmMgmt.h"
-#include "mndInt.h"
-#include "sdb.h"
-#include "tconfig.h"
-#include "tjson.h"
-
-#pragma GCC diagnostic push
-#pragma GCC diagnostic ignored "-Wunused-result"
-
-#define TMP_DNODE_DIR           TD_TMP_DIR_PATH "dumpsdb"
-#define TMP_MNODE_DIR           TD_TMP_DIR_PATH "dumpsdb" TD_DIRSEP "mnode"
-#define TMP_SDB_DATA_DIR        TD_TMP_DIR_PATH "dumpsdb" TD_DIRSEP "mnode" TD_DIRSEP "data"
-#define TMP_SDB_SYNC_DIR        TD_TMP_DIR_PATH "dumpsdb" TD_DIRSEP "mnode" TD_DIRSEP "sync"
-#define TMP_SDB_MNODE_JSON      TD_TMP_DIR_PATH "dumpsdb" TD_DIRSEP "mnode" TD_DIRSEP "mnode.json"
-#define TMP_SDB_DATA_FILE       TD_TMP_DIR_PATH "dumpsdb" TD_DIRSEP "mnode" TD_DIRSEP "data" TD_DIRSEP "sdb.data"
-#define TMP_SDB_RAFT_CFG_FILE   TD_TMP_DIR_PATH "dumpsdb" TD_DIRSEP "mnode" TD_DIRSEP "sync" TD_DIRSEP "raft_config.json"
-#define TMP_SDB_RAFT_STORE_FILE TD_TMP_DIR_PATH "dumpsdb" TD_DIRSEP "mnode" TD_DIRSEP "sync" TD_DIRSEP "raft_store.json"
-
-void reportStartup(const char *name, const char *desc) {}
-
-void sendRsp(SRpcMsg *pMsg) { rpcFreeCont(pMsg->pCont); }
-
-int32_t sendReq(const SEpSet *pEpSet, SRpcMsg *pMsg) {
-  terrno = TSDB_CODE_INVALID_PTR;
-  return -1;
-}
-
-char *i642str(int64_t val) {
-  static char str[24] = {0};
-  snprintf(str, sizeof(str), "%" PRId64, val);
-  return str;
-}
-
-void dumpFunc(SSdb *pSdb, SJson *json) {}
-
-void dumpDb(SSdb *pSdb, SJson *json) {
-  void  *pIter = NULL;
-  SJson *items = tjsonCreateObject();
-  tjsonAddItemToObject(json, "dbs", items);
-
-  while (1) {
-    SDbObj *pObj = NULL;
-    pIter = sdbFetch(pSdb, SDB_DB, pIter, (void **)&pObj);
-    if (pIter == NULL) break;
-
-    SJson *item = tjsonCreateObject();
-    tjsonAddItemToObject(items, "db", item);
-
-    tjsonAddStringToObject(item, "name", pObj->name);
-    tjsonAddStringToObject(item, "acct", pObj->acct);
-    tjsonAddStringToObject(item, "createUser", pObj->createUser);
-    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
-    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
-    tjsonAddStringToObject(item, "uid", i642str(pObj->uid));
-    tjsonAddIntegerToObject(item, "cfgVersion", pObj->cfgVersion);
-    tjsonAddIntegerToObject(item, "vgVersion", pObj->vgVersion);
-    tjsonAddIntegerToObject(item, "numOfVgroups", pObj->cfg.numOfVgroups);
-    tjsonAddIntegerToObject(item, "numOfStables", pObj->cfg.numOfStables);
-    tjsonAddIntegerToObject(item, "buffer", pObj->cfg.buffer);
-    tjsonAddIntegerToObject(item, "pageSize", pObj->cfg.pageSize);
-    tjsonAddIntegerToObject(item, "pages", pObj->cfg.pages);
-    tjsonAddIntegerToObject(item, "cacheLastSize", pObj->cfg.cacheLastSize);
-    tjsonAddIntegerToObject(item, "daysPerFile", pObj->cfg.daysPerFile);
-    tjsonAddIntegerToObject(item, "daysToKeep0", pObj->cfg.daysToKeep0);
-    tjsonAddIntegerToObject(item, "daysToKeep1", pObj->cfg.daysToKeep1);
-    tjsonAddIntegerToObject(item, "daysToKeep2", pObj->cfg.daysToKeep2);
-    tjsonAddIntegerToObject(item, "minRows", pObj->cfg.minRows);
-    tjsonAddIntegerToObject(item, "maxRows", pObj->cfg.maxRows);
-    tjsonAddIntegerToObject(item, "precision", pObj->cfg.precision);
-    tjsonAddIntegerToObject(item, "compression", pObj->cfg.compression);
-    tjsonAddIntegerToObject(item, "replications", pObj->cfg.replications);
-    tjsonAddIntegerToObject(item, "strict", pObj->cfg.strict);
-    tjsonAddIntegerToObject(item, "cacheLast", pObj->cfg.cacheLast);
-    tjsonAddIntegerToObject(item, "hashMethod", pObj->cfg.hashMethod);
-    tjsonAddIntegerToObject(item, "numOfRetensions", pObj->cfg.numOfRetensions);
-    tjsonAddIntegerToObject(item, "schemaless", pObj->cfg.schemaless);
-    tjsonAddIntegerToObject(item, "walLevel", pObj->cfg.walLevel);
-    tjsonAddIntegerToObject(item, "walFsyncPeriod", pObj->cfg.walFsyncPeriod);
-    tjsonAddIntegerToObject(item, "walRetentionPeriod", pObj->cfg.walRetentionPeriod);
-    tjsonAddIntegerToObject(item, "walRetentionSize", pObj->cfg.walRetentionSize);
-    tjsonAddIntegerToObject(item, "walRollPeriod", pObj->cfg.walRollPeriod);
-    tjsonAddIntegerToObject(item, "walSegmentSize", pObj->cfg.walSegmentSize);
-    
-    sdbRelease(pSdb, pObj);
-  }
-}
-
-void dumpStb(SSdb *pSdb, SJson *json) {
-  void  *pIter = NULL;
-  SJson *items = tjsonCreateObject();
-  tjsonAddItemToObject(json, "stbs", items);
-
-  while (1) {
-    SStbObj *pObj = NULL;
-    pIter = sdbFetch(pSdb, SDB_STB, pIter, (void **)&pObj);
-    if (pIter == NULL) break;
-
-    SJson *item = tjsonCreateObject();
-    tjsonAddItemToObject(items, "stb", item);
-
-    tjsonAddStringToObject(item, "name", pObj->name);
-    tjsonAddStringToObject(item, "db", pObj->db);
-    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
-    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
-    tjsonAddStringToObject(item, "uid", i642str(pObj->uid));
-    tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid));
-    tjsonAddIntegerToObject(item, "tagVer", pObj->tagVer);
-    tjsonAddIntegerToObject(item, "colVer", pObj->colVer);
-    tjsonAddIntegerToObject(item, "nextColId", pObj->nextColId);
-    tjsonAddIntegerToObject(item, "watermark1", pObj->watermark[0]);
-    tjsonAddIntegerToObject(item, "watermark2", pObj->watermark[1]);
-    tjsonAddIntegerToObject(item, "maxdelay1", pObj->maxdelay[0]);
-    tjsonAddIntegerToObject(item, "maxdelay2", pObj->maxdelay[1]);
-    tjsonAddIntegerToObject(item, "ttl", pObj->ttl);
-    tjsonAddIntegerToObject(item, "numOfColumns", pObj->numOfColumns);
-    tjsonAddIntegerToObject(item, "numOfTags", pObj->numOfTags);
-    tjsonAddIntegerToObject(item, "commentLen", pObj->commentLen);
-    tjsonAddIntegerToObject(item, "ast1Len", pObj->ast1Len);
-    tjsonAddIntegerToObject(item, "ast2Len", pObj->ast2Len);
-
-    sdbRelease(pSdb, pObj);
-  }
-}
-
-void dumpSma(SSdb *pSdb, SJson *json) {}
-
-void dumpVgroup(SSdb *pSdb, SJson *json) {}
-
-void dumpTopic(SSdb *pSdb, SJson *json) {}
-
-void dumpConsumber(SSdb *pSdb, SJson *json) {}
-
-void dumpSubscribe(SSdb *pSdb, SJson *json) {}
-
-void dumpOffset(SSdb *pSdb, SJson *json) {}
-
-void dumpStream(SSdb *pSdb, SJson *json) {}
-
-void dumpAcct(SSdb *pSdb, SJson *json) {
-  void  *pIter = NULL;
-  SJson *items = tjsonCreateObject();
-  tjsonAddItemToObject(json, "accts", items);
-
-  while (1) {
-    SAcctObj *pObj = NULL;
-    pIter = sdbFetch(pSdb, SDB_ACCT, pIter, (void **)&pObj);
-    if (pIter == NULL) break;
-
-    SJson *item = tjsonCreateObject();
-    tjsonAddItemToObject(items, "acct", item);
-
-    tjsonAddStringToObject(item, "acct", pObj->acct);
-    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
-    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
-    tjsonAddIntegerToObject(item, "acctId", pObj->acctId);
-
-    sdbRelease(pSdb, pObj);
-  }
-}
-
-void dumpAuth(SSdb *pSdb, SJson *json) {}
-
-void dumpUser(SSdb *pSdb, SJson *json) {
-  void  *pIter = NULL;
-  SJson *items = tjsonCreateObject();
-  tjsonAddItemToObject(json, "users", items);
-
-  while (1) {
-    SUserObj *pObj = NULL;
-    pIter = sdbFetch(pSdb, SDB_USER, pIter, (void **)&pObj);
-    if (pIter == NULL) break;
-
-    SJson *item = tjsonCreateObject();
-    tjsonAddItemToObject(items, "user", item);
-
-    tjsonAddStringToObject(item, "name", pObj->user);
-    tjsonAddStringToObject(item, "pass", pObj->pass);
-    tjsonAddStringToObject(item, "acct", pObj->acct);
-    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
-    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
-    tjsonAddIntegerToObject(item, "superUser", pObj->superUser);
-    tjsonAddIntegerToObject(item, "authVersion", pObj->authVersion);
-    tjsonAddIntegerToObject(item, "numOfReadDbs", taosHashGetSize(pObj->readDbs));
-    tjsonAddIntegerToObject(item, "numOfWriteDbs", taosHashGetSize(pObj->writeDbs));
-
-    sdbRelease(pSdb, pObj);
-  }
-}
-
-void dumpDnode(SSdb *pSdb, SJson *json) {
-  void  *pIter = NULL;
-  SJson *items = tjsonCreateObject();
-  tjsonAddItemToObject(json, "dnodes", items);
-
-  while (1) {
-    SDnodeObj *pObj = NULL;
-    pIter = sdbFetch(pSdb, SDB_DNODE, pIter, (void **)&pObj);
-    if (pIter == NULL) break;
-
-    SJson *item = tjsonCreateObject();
-    tjsonAddItemToObject(items, "dnode", item);
-
-    tjsonAddIntegerToObject(item, "id", pObj->id);
-    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
-    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
-    tjsonAddIntegerToObject(item, "port", pObj->port);
-    tjsonAddStringToObject(item, "fqdn", pObj->fqdn);
-
-    sdbRelease(pSdb, pObj);
-  }
-}
-
-void dumpBnode(SSdb *pSdb, SJson *json) {}
-
-void dumpSnode(SSdb *pSdb, SJson *json) {}
-
-void dumpQnode(SSdb *pSdb, SJson *json) {}
-
-void dumpMnode(SSdb *pSdb, SJson *json) {
-  void  *pIter = NULL;
-  SJson *items = tjsonCreateObject();
-  tjsonAddItemToObject(json, "mnodes", items);
-
-  while (1) {
-    SMnodeObj *pObj = NULL;
-    pIter = sdbFetch(pSdb, SDB_MNODE, pIter, (void **)&pObj);
-    if (pIter == NULL) break;
-
-    SJson *item = tjsonCreateObject();
-    tjsonAddItemToObject(items, "mnode", item);
-
-    tjsonAddIntegerToObject(item, "id", pObj->id);
-    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
-    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
-
-    sdbRelease(pSdb, pObj);
-  }
-}
-
-void dumpCluster(SSdb *pSdb, SJson *json) {
-  void  *pIter = NULL;
-  SJson *items = tjsonCreateObject();
-  tjsonAddItemToObject(json, "clusters", items);
-
-  while (1) {
-    SClusterObj *pObj = NULL;
-    pIter = sdbFetch(pSdb, SDB_CLUSTER, pIter, (void **)&pObj);
-    if (pIter == NULL) break;
-
-    SJson *item = tjsonCreateObject();
-    tjsonAddItemToObject(items, "cluster", item);
-
-    tjsonAddStringToObject(item, "id", i642str(pObj->id));
-    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
-    tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime));
-    tjsonAddStringToObject(item, "name", pObj->name);
-
-    sdbRelease(pSdb, pObj);
-  }
-}
-
-void dumpTrans(SSdb *pSdb, SJson *json) {
-  void  *pIter = NULL;
-  SJson *items = tjsonCreateObject();
-  tjsonAddItemToObject(json, "transactions", items);
-
-  while (1) {
-    STrans *pObj = NULL;
-    pIter = sdbFetch(pSdb, SDB_TRANS, pIter, (void **)&pObj);
-    if (pIter == NULL) break;
-
-    SJson *item = tjsonCreateObject();
-    tjsonAddItemToObject(items, "trans", item);
-
-    tjsonAddIntegerToObject(item, "id", pObj->id);
-    tjsonAddIntegerToObject(item, "stage", pObj->stage);
-    tjsonAddIntegerToObject(item, "policy", pObj->policy);
-    tjsonAddIntegerToObject(item, "conflict", pObj->conflict);
-    tjsonAddIntegerToObject(item, "exec", pObj->exec);
-    tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime));
-    tjsonAddStringToObject(item, "dbname", pObj->dbname);
-    tjsonAddStringToObject(item, "stbname", pObj->stbname);
-    tjsonAddIntegerToObject(item, "commitLogNum", taosArrayGetSize(pObj->commitActions));
-    tjsonAddIntegerToObject(item, "redoActionNum", taosArrayGetSize(pObj->redoActions));
-    tjsonAddIntegerToObject(item, "undoActionNum", taosArrayGetSize(pObj->undoActions));
-
-    sdbRelease(pSdb, pObj);
-  }
-}
-
-void dumpHeader(SSdb *pSdb, SJson *json) {
-  tjsonAddIntegerToObject(json, "sver", 1);
-  tjsonAddStringToObject(json, "applyIndex", i642str(pSdb->applyIndex));
-  tjsonAddStringToObject(json, "applyTerm", i642str(pSdb->applyTerm));
-  tjsonAddStringToObject(json, "applyConfig", i642str(pSdb->applyConfig));
-
-  SJson *maxIdsJson = tjsonCreateObject();
-  tjsonAddItemToObject(json, "maxIds", maxIdsJson);
-  for (int32_t i = 0; i < SDB_MAX; ++i) {
-    int64_t maxId = 0;
-    if (i < SDB_MAX) {
-      maxId = pSdb->maxId[i];
-    }
-    tjsonAddStringToObject(maxIdsJson, sdbTableName(i), i642str(maxId));
-  }
-
-  SJson *tableVersJson = tjsonCreateObject();
-  tjsonAddItemToObject(json, "tableVers", tableVersJson);
-  for (int32_t i = 0; i < SDB_MAX; ++i) {
-    int64_t tableVer = 0;
-    if (i < SDB_MAX) {
-      tableVer = pSdb->tableVer[i];
-    }
-    tjsonAddStringToObject(tableVersJson, sdbTableName(i), i642str(tableVer));
-  }
-}
-
-int32_t dumpSdb() {
-  wDebugFlag = 0;
-  mDebugFlag = 0;
-  sDebugFlag = 0;
-
-  SMsgCb msgCb = {0};
-  msgCb.reportStartupFp = reportStartup;
-  msgCb.sendReqFp = sendReq;
-  msgCb.sendRspFp = sendRsp;
-  msgCb.mgmt = (SMgmtWrapper *)(&msgCb);  // hack
-  tmsgSetDefault(&msgCb);
-  walInit();
-  syncInit();
-
-  SMnodeOpt opt = {.msgCb = msgCb};
-  SMnode   *pMnode = mndOpen(TMP_MNODE_DIR, &opt);
-  if (pMnode == NULL) return -1;
-
-  SSdb  *pSdb = pMnode->pSdb;
-  SJson *json = tjsonCreateObject();
-  dumpHeader(pSdb, json);
-  dumpFunc(pSdb, json);
-  dumpDb(pSdb, json);
-  dumpStb(pSdb, json);
-  dumpSma(pSdb, json);
-  dumpVgroup(pSdb, json);
-  dumpTopic(pSdb, json);
-  dumpConsumber(pSdb, json);
-  dumpSubscribe(pSdb, json);
-  dumpOffset(pSdb, json);
-  dumpStream(pSdb, json);
-  dumpAcct(pSdb, json);
-  dumpAuth(pSdb, json);
-  dumpUser(pSdb, json);
-  dumpDnode(pSdb, json);
-  dumpBnode(pSdb, json);
-  dumpSnode(pSdb, json);
-  dumpQnode(pSdb, json);
-  dumpMnode(pSdb, json);
-  dumpCluster(pSdb, json);
-  dumpTrans(pSdb, json);
-
-  char     *pCont = tjsonToString(json);
-  int32_t   contLen = strlen(pCont);
-  char      file[] = "sdb.json";
-  TdFilePtr pFile = taosOpenFile(file, TD_FILE_CREATE | TD_FILE_WRITE | TD_FILE_TRUNC);
-  if (pFile == NULL) {
-    terrno = TAOS_SYSTEM_ERROR(errno);
-    dError("failed to write %s since %s", file, terrstr());
-    return -1;
-  }
-  taosWriteFile(pFile, pCont, contLen);
-  taosWriteFile(pFile, "\n", 1);
-  taosFsyncFile(pFile);
-  taosCloseFile(&pFile);
-  tjsonDelete(json);
-  taosMemoryFree(pCont);
-  taosRemoveDir(TMP_DNODE_DIR);
-  return 0;
-}
-
-int32_t parseArgs(int32_t argc, char *argv[]) {
-  for (int32_t i = 1; i < argc; ++i) {
-    if (strcmp(argv[i], "-c") == 0) {
-      if (i < argc - 1) {
-        if (strlen(argv[++i]) >= PATH_MAX) {
-          printf("config file path overflow");
-          return -1;
-        }
-        tstrncpy(configDir, argv[i], PATH_MAX);
-      } else {
-        printf("'-c' requires a parameter, default is %s\n", configDir);
-        return -1;
-      }
-    } else {
-      printf("-c Configuration directory. \n");
-      return -1;
-    }
-  }
-
-  if (taosCreateLog("dumplog", 1, configDir, NULL, NULL, NULL, NULL, 1) != 0) {
-    printf("failed to dump since init log error\n");
-    return -1;
-  }
-
-  if (taosInitCfg(configDir, NULL, NULL, NULL, NULL, 0) != 0) {
-    printf("failed to dump since read config error\n");
-    return -1;
-  }
-
-  char mnodeJson[PATH_MAX] = {0};
-  char dataFile[PATH_MAX] = {0};
-  char raftCfgFile[PATH_MAX] = {0};
-  char raftStoreFile[PATH_MAX] = {0};
-  snprintf(mnodeJson, PATH_MAX, "%s" TD_DIRSEP "mnode" TD_DIRSEP "mnode.json", tsDataDir);
-  snprintf(dataFile, PATH_MAX, "%s" TD_DIRSEP "mnode" TD_DIRSEP "data" TD_DIRSEP "sdb.data", tsDataDir);
-  snprintf(raftCfgFile, PATH_MAX, "%s" TD_DIRSEP "mnode" TD_DIRSEP "sync" TD_DIRSEP "raft_config.json", tsDataDir);
-  snprintf(raftStoreFile, PATH_MAX, "%s" TD_DIRSEP "mnode" TD_DIRSEP "sync" TD_DIRSEP "raft_store.json", tsDataDir);
-
-  char cmd[PATH_MAX * 2] = {0};
-  snprintf(cmd, sizeof(cmd), "rm -rf %s", TMP_DNODE_DIR);
-  
-  system(cmd);
-#ifdef WINDOWS
-  taosMulMkDir(TMP_SDB_DATA_DIR);
-  taosMulMkDir(TMP_SDB_SYNC_DIR);
-  snprintf(cmd, sizeof(cmd), "cp %s %s 2>nul", mnodeJson, TMP_SDB_MNODE_JSON);
-  system(cmd);
-  snprintf(cmd, sizeof(cmd), "cp %s %s 2>nul", dataFile, TMP_SDB_DATA_FILE);
-  system(cmd);
-  snprintf(cmd, sizeof(cmd), "cp %s %s 2>nul", raftCfgFile, TMP_SDB_RAFT_CFG_FILE);
-  system(cmd);
-  snprintf(cmd, sizeof(cmd), "cp %s %s 2>nul", raftStoreFile, TMP_SDB_RAFT_STORE_FILE);
-  system(cmd);
-#else
-  snprintf(cmd, sizeof(cmd), "mkdir -p %s", TMP_SDB_DATA_DIR);
-  system(cmd);
-  snprintf(cmd, sizeof(cmd), "mkdir -p %s", TMP_SDB_SYNC_DIR);
-  system(cmd);
-  snprintf(cmd, sizeof(cmd), "cp %s %s 2>/dev/null", mnodeJson, TMP_SDB_MNODE_JSON);
-  system(cmd);
-  snprintf(cmd, sizeof(cmd), "cp %s %s 2>/dev/null", dataFile, TMP_SDB_DATA_FILE);
-  system(cmd);
-  snprintf(cmd, sizeof(cmd), "cp %s %s 2>/dev/null", raftCfgFile, TMP_SDB_RAFT_CFG_FILE);
-  system(cmd);
-  snprintf(cmd, sizeof(cmd), "cp %s %s 2>/dev/null", raftStoreFile, TMP_SDB_RAFT_STORE_FILE);
-  system(cmd);
-#endif
-
-  strcpy(tsDataDir, TMP_DNODE_DIR);
-  return 0;
-}
-
-int32_t main(int32_t argc, char *argv[]) {
-  if (parseArgs(argc, argv) != 0) {
-    return -1;
-  }
-
-  return dumpSdb();
-}
-
-#pragma GCC diagnostic pop
\ No newline at end of file