From 91aa6eb969f17d9c0558c710bcac8566a0325c4d Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Mon, 28 Nov 2022 17:45:07 +0800
Subject: [PATCH] more code

---
 source/dnode/vnode/src/vnd/vnodeSvr.c | 42 ++++++++++++++++++++++-----
 1 file changed, 35 insertions(+), 7 deletions(-)

diff --git a/source/dnode/vnode/src/vnd/vnodeSvr.c b/source/dnode/vnode/src/vnd/vnodeSvr.c
index 69f041d322..2618e45e53 100644
--- a/source/dnode/vnode/src/vnd/vnodeSvr.c
+++ b/source/dnode/vnode/src/vnd/vnodeSvr.c
@@ -841,26 +841,54 @@ static int32_t vnodeDebugPrintSubmitMsg(SVnode *pVnode, SSubmitReq *pMsg, const
 
 static int32_t vnodeProcessSubmitReq(SVnode *pVnode, int64_t version, void *pReq, int32_t len, SRpcMsg *pRsp) {
 #if 1
+  int32_t code = 0;
+
   SDecoder     dc = {0};
+  SSubmitRsp   submitRsp = {0};
   SSubmitReq2 *pSubmitReq = NULL;
+  SArray      *newTbUids = NULL;
 
   tDecoderInit(&dc, (char *)pReq + sizeof(SMsgHead), len - sizeof(SMsgHead));
-  tDecodeSSubmitReq2(&dc, &pSubmitReq);
+  if (tDecodeSSubmitReq2(&dc, &pSubmitReq) < 0) {
+    code = TSDB_CODE_INVALID_MSG;
+    goto _exit;
+  }
+
+  submitRsp.pArray = taosArrayInit(1, sizeof(SSubmitBlkRsp));
+  if (submitRsp.pArray == NULL) {
+    terrno = TSDB_CODE_TDB_OUT_OF_MEMORY;
+    goto _exit;
+  }
 
+  // auto create table
   if (pSubmitReq->flag & SUBMIT_REQ_AUTO_CREATE_TABLE) {
-    // todo
-    ASSERT(0);
+    for (int32_t iCreateTbReq = 0; iCreateTbReq < taosArrayGetSize(pSubmitReq->aCreateTbReq); iCreateTbReq++) {
+      SVCreateTbReq *pCreateTbReq = taosArrayGet(pSubmitReq->aCreateTbReq, iCreateTbReq);
+
+      if (metaCreateTable(pVnode->pMeta, version, pCreateTbReq, NULL /* todo */) < 0) {
+        if (terrno != TSDB_CODE_TDB_TABLE_ALREADY_EXIST) {
+          // todo
+        }
+      } else {
+      }
+    }
   }
 
+  // insert table data
   for (int32_t iSubmitTbData = 0; iSubmitTbData < taosArrayGetSize(pSubmitReq->aSubmitTbData); iSubmitTbData++) {
     SSubmitTbData *pSubmitTbData = taosArrayGet(pSubmitReq->aSubmitTbData, iSubmitTbData);
 
-    int32_t code = tsdbInsertTableData(pVnode->pTsdb, version, pSubmitTbData, NULL /*todo*/);
-    if (code) {
-      // todo
-    }
+    SSubmitBlkRsp submitBlkRsp = {0};
+
+    tsdbInsertTableData(pVnode->pTsdb, version, pSubmitTbData, &submitBlkRsp);
   }
 
+_exit:
+  if (code) {
+  } else {
+  }
+  return code;
+
 #else
   SSubmitReq    *pSubmitReq = (SSubmitReq *)pReq;
   SSubmitRsp     submitRsp = {0};
-- 
GitLab