From 0d3a30049c685b68036370cf92c3db5cd1d99af3 Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Mon, 28 Mar 2022 09:50:00 +0000
Subject: [PATCH] more meta

---
 source/dnode/vnode/src/meta/metaTDBImpl.c | 64 +++++++++++++++++++++--
 1 file changed, 61 insertions(+), 3 deletions(-)

diff --git a/source/dnode/vnode/src/meta/metaTDBImpl.c b/source/dnode/vnode/src/meta/metaTDBImpl.c
index 61f62320c4..9940ae166d 100644
--- a/source/dnode/vnode/src/meta/metaTDBImpl.c
+++ b/source/dnode/vnode/src/meta/metaTDBImpl.c
@@ -96,12 +96,70 @@ int metaOpenDB(SMeta *pMeta) {
 }
 
 void metaCloseDB(SMeta *pMeta) {
-  // TODO
-  ASSERT(0);
+  if (pMeta->pDB) {
+    tdbDbClose(pMeta->pDB->pCtbIdx);
+    tdbDbClose(pMeta->pDB->pNtbIdx);
+    tdbDbClose(pMeta->pDB->pStbIdx);
+    tdbDbClose(pMeta->pDB->pNameIdx);
+    tdbDbClose(pMeta->pDB->pSchemaDB);
+    tdbDbClose(pMeta->pDB->pTbDB);
+    taosMemoryFree(pMeta->pDB);
+  }
 }
 
 int metaSaveTableToDB(SMeta *pMeta, STbCfg *pTbCfg) {
-  // TODO
+  tb_uid_t uid;
+  SMetaDB *pMetaDb;
+  void    *pKey;
+  void    *pVal;
+  int      kLen;
+  int      vLen;
+  int      ret;
+
+  pMetaDb = pMeta->pDB;
+
+  // TODO: make this operation pre-process
+  if (pTbCfg->type == META_SUPER_TABLE) {
+    uid = pTbCfg->stbCfg.suid;
+  } else {
+    uid = metaGenerateUid(pMeta);
+  }
+
+  // save to table.db
+  ret = tdbDbInsert(pMetaDb->pTbDB, pKey, kLen, pVal, vLen);
+  if (ret < 0) {
+    return -1;
+  }
+
+  // save to schema.db
+  ret = tdbDbInsert(pMetaDb->pSchemaDB, pKey, kLen, pVal, vLen);
+  if (ret < 0) {
+    return -1;
+  }
+
+  // update name.idx
+  ret = tdbDbInsert(pMetaDb->pNameIdx, pKey, kLen, NULL, 0);
+  if (ret < 0) {
+    return -1;
+  }
+
+  if (pTbCfg->type == META_SUPER_TABLE) {
+    ret = tdbDbInsert(pMetaDb->pStbIdx, pKey, kLen, NULL, 0);
+    if (ret < 0) {
+      return -1;
+    }
+  } else if (pTbCfg->type == META_CHILD_TABLE) {
+    ret = tdbDbInsert(pMetaDb->pCtbIdx, pKey, kLen, NULL, 0);
+    if (ret < 0) {
+      return -1;
+    }
+  } else if (pTbCfg->type == META_NORMAL_TABLE) {
+    ret = tdbDbInsert(pMetaDb->pNtbIdx, pKey, kLen, NULL, 0);
+    if (ret < 0) {
+      return -1;
+    }
+  }
+
   return 0;
 }