diff --git a/src/vnode/CMakeLists.txt b/src/vnode/CMakeLists.txt
index 92270a886f4cae4363e8c774bfa2622c3989b23b..5acf0483ec67c3d23573d7ac2dd42604e001276c 100644
--- a/src/vnode/CMakeLists.txt
+++ b/src/vnode/CMakeLists.txt
@@ -4,4 +4,8 @@ project(tsdb)
 
 add_subdirectory(common)
 
-add_subdirectory(tsdb)
\ No newline at end of file
+add_subdirectory(tsdb)
+
+enable_testing()
+
+add_subdirectory(tests)
\ No newline at end of file
diff --git a/src/vnode/common/inc/dataformat.h b/src/vnode/common/inc/dataformat.h
index dd8766f96ace09cb4ce69bd2c7eaa68d3151ad8a..b0389955fb18cbac8af4fa280166390d3ce6aead 100644
--- a/src/vnode/common/inc/dataformat.h
+++ b/src/vnode/common/inc/dataformat.h
@@ -46,6 +46,7 @@ typedef char * SDataCols;
 // ----------------- Data column structure
 
 // ---- operation on SDataRow;
+#define TD_DATA_ROW_HEADER_SIZE  sizeof(int32_t)
 #define TD_DATAROW_LEN(pDataRow) (*(int32_t *)(pDataRow))
 #define TD_DATAROW_DATA(pDataRow) ((pDataRow) + sizeof(int32_t))
 
@@ -63,5 +64,9 @@ typedef char * SDataCols;
 #define TD_DATACOLS_NPOINTS(pDataCols) (*(int32_t *)(pDataCols + sizeof(int32_t)))
 
 // ----
+/**
+ * Get the maximum
+ */
+int32_t tdGetMaxDataRowSize(SSchema *pSchema);
 
 #endif // _TD_DATA_FORMAT_H_
diff --git a/src/vnode/common/src/dataformat.c b/src/vnode/common/src/dataformat.c
index f0a2cefc218a5b9bd38c9eec3e2d6edf9e9a5f29..f09ea1445b089cdf2944a902c0c744ed73f6deef 100644
--- a/src/vnode/common/src/dataformat.c
+++ b/src/vnode/common/src/dataformat.c
@@ -1,3 +1,32 @@
 #include <stdlib.h>
 
 #include "dataformat.h"
+
+int32_t tdGetMaxDataRowSize(SSchema *pSchema) {
+    int32_t nbytes = 0;
+
+    for (int32_t i = 0; i < TD_SCHEMA_NCOLS(pSchema); i++)
+    {
+        SColumn *pCol = TD_SCHEMA_COLUMN_AT(pSchema, i);
+        td_datatype_t type = TD_COLUMN_TYPE(pCol);
+
+        nbytes += rowDataLen[type];
+
+        switch (type)
+        {
+        case TD_DATATYPE_VARCHAR:
+            nbytes += TD_COLUMN_BYTES(pCol);
+            break;
+        case TD_DATATYPE_NCHAR:
+            nbytes += 4 * TD_COLUMN_BYTES(pCol);
+            break;
+        case TD_DATATYPE_BINARY:
+            nbytes += TD_COLUMN_BYTES(pCol);
+            break;
+        }
+    }
+
+    nbytes += TD_DATA_ROW_HEADER_SIZE;
+
+    return nbytes;
+}
\ No newline at end of file
diff --git a/src/vnode/tests/CMakeLists.txt b/src/vnode/tests/CMakeLists.txt
new file mode 100644
index 0000000000000000000000000000000000000000..786fa9a66f8959ca6faa1278f59c903939218e05
--- /dev/null
+++ b/src/vnode/tests/CMakeLists.txt
@@ -0,0 +1,3 @@
+add_subdirectory(common)
+
+add_subdirectory(tsdb)
\ No newline at end of file
diff --git a/src/vnode/tests/common/CMakeLists.txt b/src/vnode/tests/common/CMakeLists.txt
new file mode 100644
index 0000000000000000000000000000000000000000..093768be1a1398932d66825f2f2dcf4151ae1d65
--- /dev/null
+++ b/src/vnode/tests/common/CMakeLists.txt
@@ -0,0 +1,14 @@
+aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR} SOURCE_LIST)
+
+message(STATUS "COMMON: ${SOURCE_LIST}")
+
+add_executable(commonTests ${SOURCE_LIST})
+
+target_link_libraries(commonTests gtest gtest_main pthread common)
+
+add_test(
+    NAME
+      unit   
+    COMMAND
+      ${CMAKE_CURRENT_BINARY_DIR}/commonTests
+)
\ No newline at end of file
diff --git a/src/vnode/tests/common/commonDataTests.cpp b/src/vnode/tests/common/commonDataTests.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..7becb8699c117d50e19d4f5a8ed8944a82da794e
--- /dev/null
+++ b/src/vnode/tests/common/commonDataTests.cpp
@@ -0,0 +1,7 @@
+#include <gtest/gtest.h>
+
+#include "dataformat.h"
+
+TEST(commonDataTests, createDataRow) {
+    EXPECT_EQ(1, 2/2);
+}
\ No newline at end of file
diff --git a/src/vnode/tests/common/commonSChemaTests.cpp b/src/vnode/tests/common/commonSChemaTests.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..44fd384b61c567487477b3c60e24630c4b4e935c
--- /dev/null
+++ b/src/vnode/tests/common/commonSChemaTests.cpp
@@ -0,0 +1,9 @@
+#include <gtest/gtest.h>
+#include <stdlib.h>
+#include <stdio.h>
+
+#include "schema.h"
+
+TEST(commonSchemaTests, createSchema) {
+    EXPECT_EQ(1, 2/2);
+}
\ No newline at end of file
diff --git a/src/vnode/tests/tsdb/CMakeLists.txt b/src/vnode/tests/tsdb/CMakeLists.txt
new file mode 100644
index 0000000000000000000000000000000000000000..a942dd917e7cb52c9c41162dffe7206d7f16e69c
--- /dev/null
+++ b/src/vnode/tests/tsdb/CMakeLists.txt
@@ -0,0 +1,13 @@
+aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR} SOURCE_LIST)
+
+message(STATUS "TSDB: ${SOURCE_LIST}")
+
+add_executable(tsdbTests ${SOURCE_LIST})
+target_link_libraries(tsdbTests gtest gtest_main pthread tsdb)
+
+add_test(
+    NAME
+      unit   
+    COMMAND
+      ${CMAKE_CURRENT_BINARY_DIR}/tsdbTests
+)
\ No newline at end of file
diff --git a/src/vnode/tests/tsdb/tsdbTests.cpp b/src/vnode/tests/tsdb/tsdbTests.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..b3e6e22dada9035f841fe3211d70c026f72a39ef
--- /dev/null
+++ b/src/vnode/tests/tsdb/tsdbTests.cpp
@@ -0,0 +1,15 @@
+#include <gtest/gtest.h>
+#include <stdlib.h>
+
+#include "tsdb.h"
+
+TEST(TsdbTest, createTsdbRepo) {
+    STSDBCfg *pCfg = (STSDBCfg *)malloc(sizeof(STSDBCfg));
+
+    pCfg->rootDir = "/var/lib/taos/";
+
+    int32_t err_num = 0;
+    
+    tsdb_repo_t *pRepo = tsdbCreateRepo(pCfg, &err_num);
+    ASSERT_EQ(pRepo, NULL);
+}
\ No newline at end of file
diff --git a/src/vnode/tsdb/inc/tsdbCache.h b/src/vnode/tsdb/inc/tsdbCache.h
index 049cdc0847d8da27f46fbf77d30d9d24fc3bc67a..b439be08aa34cfe3a0497458a66e10ca43c8138a 100644
--- a/src/vnode/tsdb/inc/tsdbCache.h
+++ b/src/vnode/tsdb/inc/tsdbCache.h
@@ -10,7 +10,7 @@
 typedef struct {
   int64_t skey;     // start key
   int64_t ekey;     // end key
-  int32_t numOfRows // numOfRows
+  int32_t numOfRows; // numOfRows
 } STableCacheInfo;
 
 typedef struct _tsdb_cache_block {
diff --git a/src/vnode/tsdb/src/tsdb.c b/src/vnode/tsdb/src/tsdb.c
index 7e13e3183ad8ab33e9f975356359fd7d247f069c..031dd135c667403b5e500a34f729b221dbdf4eb6 100644
--- a/src/vnode/tsdb/src/tsdb.c
+++ b/src/vnode/tsdb/src/tsdb.c
@@ -1,9 +1,14 @@
 #include <pthread.h>
 #include <stdint.h>
 #include <stdlib.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
 
 // #include "taosdef.h"
 // #include "disk.h"
+#include "tsdbFile.h"
 #include "tsdb.h"
 #include "tsdbCache.h"
 #include "tsdbMeta.h"
@@ -33,6 +38,11 @@ typedef struct STSDBRepo {
 
 // Check the correctness of the TSDB configuration
 static int32_t tsdbCheckCfg(STSDBCfg *pCfg) {
+  if (pCfg->rootDir == NULL) return -1;
+
+  if (access(pCfg->rootDir, F_OK|R_OK|W_OK) == -1) {
+    return -1;
+  }
   // TODO
   return 0;
 }
@@ -42,6 +52,7 @@ tsdb_repo_t *tsdbCreateRepo(STSDBCfg *pCfg, int32_t *error) {
   err = tsdbCheckCfg(pCfg);
   if (err != 0) {
     // TODO: deal with the error here
+    return NULL;
   }
 
   STSDBRepo *pRepo = (STSDBRepo *)malloc(sizeof(STSDBRepo));
@@ -65,6 +76,12 @@ tsdb_repo_t *tsdbCreateRepo(STSDBCfg *pCfg, int32_t *error) {
     return NULL;
   }
 
+  // Create the Meta data file and data directory
+
+  char *pTsdbMetaFName = tsdbGetFileName(pCfg->rootDir, "tsdb", TSDB_FILE_TYPE_META);
+  // int fd = open(pTsdbMetaFName, )
+  // if (open)
+
   return (tsdb_repo_t *)pRepo;
 }