tsdbTests.cpp 998 字节
Newer Older
H
hzcheng 已提交
1 2 3
#include <gtest/gtest.h>
#include <stdlib.h>

H
hzcheng 已提交
4
#include "tsdb.h"
H
hzcheng 已提交
5
#include "dataformat.h"
H
hzcheng 已提交
6

H
hzcheng 已提交
7
TEST(TsdbTest, createRepo) {
H
hzcheng 已提交
8
  STsdbCfg config;
H
hzcheng 已提交
9

H
hzcheng 已提交
10
  // 1. Create a tsdb repository
H
hzcheng 已提交
11 12
  tsdbSetDefaultCfg(&config);
  tsdb_repo_t *pRepo = tsdbCreateRepo("/home/ubuntu/work/ttest/vnode0", &config, NULL);
H
hzcheng 已提交
13 14
  ASSERT_NE(pRepo, nullptr);

H
hzcheng 已提交
15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30
  // 2. Create a normal table
  STableCfg tCfg;
  ASSERT_EQ(tsdbInitTableCfg(&tCfg, TSDB_SUPER_TABLE, 987607499877672L, 0), -1);
  ASSERT_EQ(tsdbInitTableCfg(&tCfg, TSDB_NTABLE, 987607499877672L, 0), 0);

  int nCols = 5;
  STSchema *schema = tdNewSchema(nCols);

  for (int i = 0; i < nCols; i++)
  {
    if (i == 0) {
      tdSchemaAppendCol(schema, TSDB_DATA_TYPE_TIMESTAMP, i, -1);
    } else {
      tdSchemaAppendCol(schema, TSDB_DATA_TYPE_INT, i, -1);
    }
  }
H
hzcheng 已提交
31

H
hzcheng 已提交
32
  tsdbTableSetSchema(&tCfg, schema, true);
H
hzcheng 已提交
33

H
hzcheng 已提交
34
  tsdbCreateTable(pRepo, &tCfg);
H
hzcheng 已提交
35

H
hzcheng 已提交
36
  // 3. Loop to write some simple data
H
hzcheng 已提交
37 38 39
  SDataRow row = tdNewDataRowFromSchema(schema);
  for (int i = 0; i < nCols; i++) {
  }
H
hzcheng 已提交
40 41
}