From bddcc6fa7786c756c3d070f43e0393b14c65fc8d Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Mon, 1 Jun 2020 08:18:16 +0000
Subject: [PATCH] refactor code

---
 src/vnode/src/vnodeWrite.c | 64 --------------------------------------
 1 file changed, 64 deletions(-)

diff --git a/src/vnode/src/vnodeWrite.c b/src/vnode/src/vnodeWrite.c
index 5a3da2447f..90e2a482e9 100644
--- a/src/vnode/src/vnodeWrite.c
+++ b/src/vnode/src/vnodeWrite.c
@@ -112,70 +112,6 @@ static int32_t vnodeProcessCreateTableMsg(SVnodeObj *pVnode, void *pCont, SRspRe
   tsdbClearTableCfg(pCfg);
   free(pCfg);
   return code;
-
-  #if 0
-  SMDCreateTableMsg *pTable = pCont;
-  int32_t code = 0;
-  
-  vTrace("vgId:%d, table:%s, start to create", pVnode->vgId, pTable->tableId);
-  int16_t   numOfColumns = htons(pTable->numOfColumns);
-  int16_t   numOfTags = htons(pTable->numOfTags);
-  int32_t   sid = htonl(pTable->sid);
-  uint64_t  uid = htobe64(pTable->uid);
-  SSchema * pSchema = (SSchema *)pTable->data;
-  STSchema *pDestTagSchema = NULL;
-  SDataRow  dataRow = NULL;
-
-  int32_t totalCols = numOfColumns + numOfTags;
-  
-  STableCfg tCfg;
-  tsdbInitTableCfg(&tCfg, pTable->tableType, uid, sid);
-
-  STSchema *pDestSchema = tdNewSchema(numOfColumns);
-  for (int i = 0; i < numOfColumns; i++) {
-    tdSchemaAddCol(pDestSchema, pSchema[i].type, htons(pSchema[i].colId), htons(pSchema[i].bytes));
-  }
-  tsdbTableSetSchema(&tCfg, pDestSchema, false);
-  tsdbTableSetName(&tCfg, pTable->tableId, false);
-
-  if (numOfTags != 0) {
-    pDestTagSchema = tdNewSchema(numOfTags);
-    for (int i = numOfColumns; i < totalCols; i++) {
-      tdSchemaAddCol(pDestTagSchema, pSchema[i].type, htons(pSchema[i].colId), htons(pSchema[i].bytes));
-    }
-    tsdbTableSetTagSchema(&tCfg, pDestTagSchema, false);
-    tsdbTableSetSName(&tCfg, pTable->superTableId, false);
-    tsdbTableSetSuperUid(&tCfg, htobe64(pTable->superTableUid));
-    
-    char *pTagData = pTable->data + totalCols * sizeof(SSchema);
-    int accumBytes = 0;
-
-    SKVRowBuilder kvRowBuilder;
-    tdInitKVRowBuilder(&kvRowBuilder);
-    for (int i = 0; i < numOfTags; i++) {
-      STColumn *pTCol = schemaColAt(pDestTagSchema, i);
-      tdAddColToKVRow(&kvRowBuilder, pTCol->colId, pTCol->type, pTagData + accumBytes);
-      accumBytes += htons(pSchema[i + numOfColumns].bytes);
-    }
-    tsdbTableSetTagValue(&tCfg, tdGetKVRowFromBuilder(&kvRowBuilder), false);
-    tdDestroyKVRowBuilder(&kvRowBuilder);
-  }
-
-  // only normal has sql string
-  if (pTable->tableType == TSDB_STREAM_TABLE) {
-    char *sql = pTable->data + totalCols * sizeof(SSchema);
-    vTrace("vgId:%d, table:%s is creating, sql:%s", pVnode->vgId, pTable->tableId, sql);
-    tsdbTableSetStreamSql(&tCfg, sql, false);
-  }
-
-  code = tsdbCreateTable(pVnode->tsdb, &tCfg);
-  tdFreeDataRow(dataRow);
-  tfree(pDestTagSchema);
-  tfree(pDestSchema);
-
-  vTrace("vgId:%d, table:%s is created, result:%x", pVnode->vgId, pTable->tableId, code);
-  return code; 
-  #endif
 }
 
 static int32_t vnodeProcessDropTableMsg(SVnodeObj *pVnode, void *pCont, SRspRet *pRet) {
-- 
GitLab