tsdbSmaTest.cpp 20.0 KB
Newer Older
C
Cary Xu 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#include <gtest/gtest.h>
C
Cary Xu 已提交
17
#include <tsdbDef.h>
C
Cary Xu 已提交
18

C
Cary Xu 已提交
19 20 21 22
#include <taoserror.h>
#include <tglobal.h>
#include <iostream>

C
Cary Xu 已提交
23
#include <metaDef.h>
C
Cary Xu 已提交
24 25
#include <tmsg.h>

C
Cary Xu 已提交
26 27 28 29 30 31
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wwrite-strings"
#pragma GCC diagnostic ignored "-Wunused-function"
#pragma GCC diagnostic ignored "-Wunused-variable"
#pragma GCC diagnostic ignored "-Wsign-compare"

C
Cary Xu 已提交
32 33 34 35 36
int main(int argc, char **argv) {
  testing::InitGoogleTest(&argc, argv);
  return RUN_ALL_TESTS();
}

C
Cary Xu 已提交
37 38 39 40 41 42 43 44 45 46
TEST(testCase, unionEncodeDecodeTest) {
  typedef struct {
    union {
      uint8_t info;
      struct {
        uint8_t rollup : 1;  // 1 means rollup sma
        uint8_t type : 7;
      };
    };
    col_id_t  nBSmaCols;
C
Cary Xu 已提交
47
    col_id_t *pBSmaCols;
C
Cary Xu 已提交
48 49 50 51 52 53 54
  } SUnionTest;

  SUnionTest sut = {0};
  sut.rollup = 1;
  sut.type = 1;

  sut.nBSmaCols = 2;
C
Cary Xu 已提交
55
  sut.pBSmaCols = (col_id_t *)taosMemoryMalloc(sut.nBSmaCols * sizeof(col_id_t));
C
Cary Xu 已提交
56 57 58 59
  for (col_id_t i = 0; i < sut.nBSmaCols; ++i) {
    sut.pBSmaCols[i] = i + 100;
  }

C
Cary Xu 已提交
60 61
  void   *buf = taosMemoryMalloc(1024);
  void   *pBuf = buf;
C
Cary Xu 已提交
62 63 64 65 66 67 68 69 70 71
  int32_t tlen = 0;
  tlen += taosEncodeFixedU8(&buf, sut.info);
  tlen += taosEncodeFixedI16(&buf, sut.nBSmaCols);
  for (col_id_t i = 0; i < sut.nBSmaCols; ++i) {
    tlen += taosEncodeFixedI16(&buf, sut.pBSmaCols[i]);
  }

  SUnionTest dut = {0};
  pBuf = taosDecodeFixedU8(pBuf, &dut.info);
  pBuf = taosDecodeFixedI16(pBuf, &dut.nBSmaCols);
C
Cary Xu 已提交
72 73 74
  if (dut.nBSmaCols > 0) {
    dut.pBSmaCols = (col_id_t *)taosMemoryMalloc(dut.nBSmaCols * sizeof(col_id_t));
    for (col_id_t i = 0; i < dut.nBSmaCols; ++i) {
C
Cary Xu 已提交
75 76 77 78 79 80 81 82 83 84 85 86
      pBuf = taosDecodeFixedI16(pBuf, dut.pBSmaCols + i);
    }
  } else {
    dut.pBSmaCols = NULL;
  }

  printf("sut.rollup=%" PRIu8 ", type=%" PRIu8 ", info=%" PRIu8 "\n", sut.rollup, sut.type, sut.info);
  printf("dut.rollup=%" PRIu8 ", type=%" PRIu8 ", info=%" PRIu8 "\n", dut.rollup, dut.type, dut.info);

  ASSERT_EQ(sut.rollup, dut.rollup);
  ASSERT_EQ(sut.type, dut.type);
  ASSERT_EQ(sut.nBSmaCols, dut.nBSmaCols);
C
Cary Xu 已提交
87 88 89
  for (col_id_t i = 0; i < sut.nBSmaCols; ++i) {
    ASSERT_EQ(*(col_id_t *)(sut.pBSmaCols + i), sut.pBSmaCols[i]);
    ASSERT_EQ(*(col_id_t *)(sut.pBSmaCols + i), dut.pBSmaCols[i]);
C
Cary Xu 已提交
90 91
  }
}
92
#if 1
C
Cary Xu 已提交
93
TEST(testCase, tSma_Meta_Encode_Decode_Test) {
C
Cary Xu 已提交
94 95 96
  // encode
  STSma tSma = {0};
  tSma.version = 0;
C
Cary Xu 已提交
97
  tSma.intervalUnit = TIME_UNIT_DAY;
C
Cary Xu 已提交
98
  tSma.interval = 1;
C
Cary Xu 已提交
99
  tSma.slidingUnit = TIME_UNIT_HOUR;
C
Cary Xu 已提交
100 101
  tSma.sliding = 0;
  tstrncpy(tSma.indexName, "sma_index_test", TSDB_INDEX_NAME_LEN);
C
Cary Xu 已提交
102
  tSma.timezoneInt = 8;
C
Cary Xu 已提交
103
  tSma.indexUid = 2345678910;
C
Cary Xu 已提交
104
  tSma.tableUid = 1234567890;
C
Cary Xu 已提交
105

C
Cary Xu 已提交
106 107
  STSmaWrapper tSmaWrapper = {.number = 1, .tSma = &tSma};
  uint32_t     bufLen = tEncodeTSmaWrapper(NULL, &tSmaWrapper);
C
Cary Xu 已提交
108

wafwerar's avatar
wafwerar 已提交
109
  void *buf = taosMemoryCalloc(1, bufLen);
C
Cary Xu 已提交
110
  ASSERT_NE(buf, nullptr);
C
Cary Xu 已提交
111 112 113 114

  STSmaWrapper *pSW = (STSmaWrapper *)buf;
  uint32_t      len = tEncodeTSmaWrapper(&buf, &tSmaWrapper);

C
Cary Xu 已提交
115
  ASSERT_EQ(len, bufLen);
C
Cary Xu 已提交
116 117 118

  // decode
  STSmaWrapper dstTSmaWrapper = {0};
C
Cary Xu 已提交
119
  void        *result = tDecodeTSmaWrapper(pSW, &dstTSmaWrapper);
C
Cary Xu 已提交
120
  ASSERT_NE(result, nullptr);
C
Cary Xu 已提交
121

C
Cary Xu 已提交
122
  ASSERT_EQ(tSmaWrapper.number, dstTSmaWrapper.number);
C
Cary Xu 已提交
123 124 125 126 127

  for (int i = 0; i < tSmaWrapper.number; ++i) {
    STSma *pSma = tSmaWrapper.tSma + i;
    STSma *qSma = dstTSmaWrapper.tSma + i;

C
Cary Xu 已提交
128 129 130 131
    ASSERT_EQ(pSma->version, qSma->version);
    ASSERT_EQ(pSma->intervalUnit, qSma->intervalUnit);
    ASSERT_EQ(pSma->slidingUnit, qSma->slidingUnit);
    ASSERT_STRCASEEQ(pSma->indexName, qSma->indexName);
C
Cary Xu 已提交
132
    ASSERT_EQ(pSma->timezoneInt, qSma->timezoneInt);
C
Cary Xu 已提交
133 134 135 136 137 138 139 140
    ASSERT_EQ(pSma->indexUid, qSma->indexUid);
    ASSERT_EQ(pSma->tableUid, qSma->tableUid);
    ASSERT_EQ(pSma->interval, qSma->interval);
    ASSERT_EQ(pSma->sliding, qSma->sliding);
    ASSERT_EQ(pSma->exprLen, qSma->exprLen);
    ASSERT_STRCASEEQ(pSma->expr, qSma->expr);
    ASSERT_EQ(pSma->tagsFilterLen, qSma->tagsFilterLen);
    ASSERT_STRCASEEQ(pSma->tagsFilter, qSma->tagsFilter);
C
Cary Xu 已提交
141 142 143
  }

  // resource release
wafwerar's avatar
wafwerar 已提交
144
  taosMemoryFreeClear(pSW);
C
Cary Xu 已提交
145 146
  tdDestroyTSma(&tSma);
  tdDestroyTSmaWrapper(&dstTSmaWrapper);
C
Cary Xu 已提交
147
}
148
#endif
C
Cary Xu 已提交
149

C
Cary Xu 已提交
150
#if 1
C
Cary Xu 已提交
151
TEST(testCase, tSma_metaDB_Put_Get_Del_Test) {
C
Cary Xu 已提交
152 153
  const char    *smaIndexName1 = "sma_index_test_1";
  const char    *smaIndexName2 = "sma_index_test_2";
C
Cary Xu 已提交
154
  int8_t         timezone = 8;
C
Cary Xu 已提交
155 156 157
  const char    *expr = "select count(a,b, top 20), from table interval 1d, sliding 1h;";
  const char    *tagsFilter = "I'm tags filter";
  const char    *smaTestDir = "./smaTest";
C
Cary Xu 已提交
158 159 160
  const tb_uid_t tbUid = 1234567890;
  const int64_t  indexUid1 = 2000000001;
  const int64_t  indexUid2 = 2000000002;
C
Cary Xu 已提交
161
  const uint32_t nCntTSma = 2;
C
Cary Xu 已提交
162 163 164
  // encode
  STSma tSma = {0};
  tSma.version = 0;
C
Cary Xu 已提交
165
  tSma.intervalUnit = TIME_UNIT_DAY;
C
Cary Xu 已提交
166
  tSma.interval = 1;
C
Cary Xu 已提交
167
  tSma.slidingUnit = TIME_UNIT_HOUR;
C
Cary Xu 已提交
168
  tSma.sliding = 0;
C
Cary Xu 已提交
169
  tSma.indexUid = indexUid1;
C
Cary Xu 已提交
170
  tstrncpy(tSma.indexName, smaIndexName1, TSDB_INDEX_NAME_LEN);
C
Cary Xu 已提交
171
  tSma.timezoneInt = 8;
C
Cary Xu 已提交
172
  tSma.tableUid = tbUid;
C
Cary Xu 已提交
173 174

  tSma.exprLen = strlen(expr);
wafwerar's avatar
wafwerar 已提交
175
  tSma.expr = (char *)taosMemoryCalloc(1, tSma.exprLen + 1);
C
Cary Xu 已提交
176
  ASSERT_NE(tSma.expr, nullptr);
C
Cary Xu 已提交
177 178
  tstrncpy(tSma.expr, expr, tSma.exprLen + 1);

C
Cary Xu 已提交
179
  tSma.tagsFilterLen = strlen(tagsFilter);
wafwerar's avatar
wafwerar 已提交
180
  tSma.tagsFilter = (char *)taosMemoryCalloc(tSma.tagsFilterLen + 1, 1);
C
Cary Xu 已提交
181
  ASSERT_NE(tSma.tagsFilter, nullptr);
C
Cary Xu 已提交
182
  tstrncpy(tSma.tagsFilter, tagsFilter, tSma.tagsFilterLen + 1);
C
Cary Xu 已提交
183

C
Cary Xu 已提交
184 185
  SMeta          *pMeta = NULL;
  STSma          *pSmaCfg = &tSma;
C
Cary Xu 已提交
186 187 188 189 190 191 192
  const SMetaCfg *pMetaCfg = &defaultMetaOptions;

  taosRemoveDir(smaTestDir);

  pMeta = metaOpen(smaTestDir, pMetaCfg, NULL);
  assert(pMeta != NULL);
  // save index 1
C
Cary Xu 已提交
193
  ASSERT_EQ(metaSaveSmaToDB(pMeta, pSmaCfg), 0);
C
Cary Xu 已提交
194

C
Cary Xu 已提交
195
  pSmaCfg->indexUid = indexUid2;
C
Cary Xu 已提交
196 197
  tstrncpy(pSmaCfg->indexName, smaIndexName2, TSDB_INDEX_NAME_LEN);
  pSmaCfg->version = 1;
C
Cary Xu 已提交
198
  pSmaCfg->intervalUnit = TIME_UNIT_HOUR;
C
Cary Xu 已提交
199
  pSmaCfg->interval = 1;
C
Cary Xu 已提交
200
  pSmaCfg->slidingUnit = TIME_UNIT_MINUTE;
C
Cary Xu 已提交
201 202 203
  pSmaCfg->sliding = 5;

  // save index 2
C
Cary Xu 已提交
204
  ASSERT_EQ(metaSaveSmaToDB(pMeta, pSmaCfg), 0);
C
Cary Xu 已提交
205 206

  // get value by indexName
C
Cary Xu 已提交
207
  STSma *qSmaCfg = NULL;
C
Cary Xu 已提交
208
  qSmaCfg = metaGetSmaInfoByIndex(pMeta, indexUid1);
C
Cary Xu 已提交
209 210
  assert(qSmaCfg != NULL);
  printf("name1 = %s\n", qSmaCfg->indexName);
C
Cary Xu 已提交
211
  printf("timezone1 = %" PRIi8 "\n", qSmaCfg->timezoneInt);
C
Cary Xu 已提交
212
  printf("expr1 = %s\n", qSmaCfg->expr != NULL ? qSmaCfg->expr : "");
C
Cary Xu 已提交
213
  printf("tagsFilter1 = %s\n", qSmaCfg->tagsFilter != NULL ? qSmaCfg->tagsFilter : "");
C
Cary Xu 已提交
214 215
  ASSERT_STRCASEEQ(qSmaCfg->indexName, smaIndexName1);
  ASSERT_EQ(qSmaCfg->tableUid, tSma.tableUid);
C
Cary Xu 已提交
216
  tdDestroyTSma(qSmaCfg);
wafwerar's avatar
wafwerar 已提交
217
  taosMemoryFreeClear(qSmaCfg);
C
Cary Xu 已提交
218

C
Cary Xu 已提交
219
  qSmaCfg = metaGetSmaInfoByIndex(pMeta, indexUid2);
C
Cary Xu 已提交
220 221
  assert(qSmaCfg != NULL);
  printf("name2 = %s\n", qSmaCfg->indexName);
C
Cary Xu 已提交
222
  printf("timezone2 = %" PRIi8 "\n", qSmaCfg->timezoneInt);
C
Cary Xu 已提交
223
  printf("expr2 = %s\n", qSmaCfg->expr != NULL ? qSmaCfg->expr : "");
C
Cary Xu 已提交
224
  printf("tagsFilter2 = %s\n", qSmaCfg->tagsFilter != NULL ? qSmaCfg->tagsFilter : "");
C
Cary Xu 已提交
225 226
  ASSERT_STRCASEEQ(qSmaCfg->indexName, smaIndexName2);
  ASSERT_EQ(qSmaCfg->interval, tSma.interval);
C
Cary Xu 已提交
227
  tdDestroyTSma(qSmaCfg);
wafwerar's avatar
wafwerar 已提交
228
  taosMemoryFreeClear(qSmaCfg);
C
Cary Xu 已提交
229

C
Cary Xu 已提交
230
  // get index name by table uid
C
Cary Xu 已提交
231 232 233 234
  SMSmaCursor *pSmaCur = metaOpenSmaCursor(pMeta, tbUid);
  assert(pSmaCur != NULL);
  uint32_t indexCnt = 0;
  while (1) {
C
Cary Xu 已提交
235
    const char *indexName = metaSmaCursorNext(pSmaCur);
C
Cary Xu 已提交
236 237 238 239 240 241
    if (indexName == NULL) {
      break;
    }
    printf("indexName = %s\n", indexName);
    ++indexCnt;
  }
C
Cary Xu 已提交
242
  ASSERT_EQ(indexCnt, nCntTSma);
C
Cary Xu 已提交
243 244
  metaCloseSmaCurosr(pSmaCur);

C
Cary Xu 已提交
245
  // get wrapper by table uid
C
Cary Xu 已提交
246
  STSmaWrapper *pSW = metaGetSmaInfoByTable(pMeta, tbUid);
C
Cary Xu 已提交
247
  assert(pSW != NULL);
C
Cary Xu 已提交
248 249
  ASSERT_EQ(pSW->number, nCntTSma);
  ASSERT_STRCASEEQ(pSW->tSma->indexName, smaIndexName1);
C
Cary Xu 已提交
250
  ASSERT_EQ(pSW->tSma->timezoneInt, timezone);
C
Cary Xu 已提交
251 252 253 254 255
  ASSERT_STRCASEEQ(pSW->tSma->expr, expr);
  ASSERT_STRCASEEQ(pSW->tSma->tagsFilter, tagsFilter);
  ASSERT_EQ(pSW->tSma->indexUid, indexUid1);
  ASSERT_EQ(pSW->tSma->tableUid, tbUid);
  ASSERT_STRCASEEQ((pSW->tSma + 1)->indexName, smaIndexName2);
C
Cary Xu 已提交
256
  ASSERT_EQ((pSW->tSma + 1)->timezoneInt, timezone);
C
Cary Xu 已提交
257 258 259 260
  ASSERT_STRCASEEQ((pSW->tSma + 1)->expr, expr);
  ASSERT_STRCASEEQ((pSW->tSma + 1)->tagsFilter, tagsFilter);
  ASSERT_EQ((pSW->tSma + 1)->indexUid, indexUid2);
  ASSERT_EQ((pSW->tSma + 1)->tableUid, tbUid);
C
Cary Xu 已提交
261

C
Cary Xu 已提交
262
  tdDestroyTSmaWrapper(pSW);
wafwerar's avatar
wafwerar 已提交
263
  taosMemoryFreeClear(pSW);
C
Cary Xu 已提交
264 265 266 267 268 269 270 271

  // get all sma table uids
  SArray *pUids = metaGetSmaTbUids(pMeta, false);
  assert(pUids != NULL);
  for (uint32_t i = 0; i < taosArrayGetSize(pUids); ++i) {
    printf("metaGetSmaTbUids: uid[%" PRIu32 "] = %" PRIi64 "\n", i, *(tb_uid_t *)taosArrayGet(pUids, i));
    // printf("metaGetSmaTbUids: index[%" PRIu32 "] = %s", i, (char *)taosArrayGet(pUids, i));
  }
C
Cary Xu 已提交
272
  ASSERT_EQ(taosArrayGetSize(pUids), 1);
C
Cary Xu 已提交
273
  taosArrayDestroy(pUids);
C
Cary Xu 已提交
274

C
Cary Xu 已提交
275
  // resource release
C
Cary Xu 已提交
276 277
  metaRemoveSmaFromDb(pMeta, indexUid1);
  metaRemoveSmaFromDb(pMeta, indexUid2);
C
Cary Xu 已提交
278

C
Cary Xu 已提交
279
  tdDestroyTSma(&tSma);
C
Cary Xu 已提交
280
  metaClose(pMeta);
C
Cary Xu 已提交
281
}
C
Cary Xu 已提交
282
#endif
C
Cary Xu 已提交
283

C
Cary Xu 已提交
284
#if 1
C
Cary Xu 已提交
285 286
TEST(testCase, tSma_Data_Insert_Query_Test) {
  // step 1: prepare meta
C
Cary Xu 已提交
287
  const char    *smaIndexName1 = "sma_index_test_1";
C
Cary Xu 已提交
288
  const int8_t   timezone = 8;
C
Cary Xu 已提交
289 290 291
  const char    *expr = "select count(a,b, top 20), from table interval 1d, sliding 1h;";
  const char    *tagsFilter = "where tags.location='Beijing' and tags.district='ChaoYang'";
  const char    *smaTestDir = "./smaTest";
C
Cary Xu 已提交
292 293
  const tb_uid_t tbUid = 1234567890;
  const int64_t  indexUid1 = 2000000001;
C
Cary Xu 已提交
294
  const int64_t  interval1 = 1;
C
Cary Xu 已提交
295
  const int8_t   intervalUnit1 = TIME_UNIT_DAY;
C
Cary Xu 已提交
296
  const uint32_t nCntTSma = 2;
C
Cary Xu 已提交
297 298 299
  TSKEY          skey1 = 1646987196;
  const int64_t  testSmaData1 = 100;
  const int64_t  testSmaData2 = 200;
C
Cary Xu 已提交
300 301 302
  // encode
  STSma tSma = {0};
  tSma.version = 0;
C
Cary Xu 已提交
303
  tSma.intervalUnit = TIME_UNIT_MINUTE;
C
Cary Xu 已提交
304
  tSma.interval = 1;
C
Cary Xu 已提交
305
  tSma.slidingUnit = TIME_UNIT_MINUTE;
C
Cary Xu 已提交
306
  tSma.sliding = 1;  // sliding = interval when it's convert window
C
Cary Xu 已提交
307 308
  tSma.indexUid = indexUid1;
  tstrncpy(tSma.indexName, smaIndexName1, TSDB_INDEX_NAME_LEN);
C
Cary Xu 已提交
309
  tSma.timezoneInt = timezone;
C
Cary Xu 已提交
310 311 312
  tSma.tableUid = tbUid;

  tSma.exprLen = strlen(expr);
wafwerar's avatar
wafwerar 已提交
313
  tSma.expr = (char *)taosMemoryCalloc(1, tSma.exprLen + 1);
C
Cary Xu 已提交
314
  ASSERT_NE(tSma.expr, nullptr);
C
Cary Xu 已提交
315 316 317
  tstrncpy(tSma.expr, expr, tSma.exprLen + 1);

  tSma.tagsFilterLen = strlen(tagsFilter);
wafwerar's avatar
wafwerar 已提交
318
  tSma.tagsFilter = (char *)taosMemoryCalloc(1, tSma.tagsFilterLen + 1);
C
Cary Xu 已提交
319
  ASSERT_NE(tSma.tagsFilter, nullptr);
C
Cary Xu 已提交
320 321
  tstrncpy(tSma.tagsFilter, tagsFilter, tSma.tagsFilterLen + 1);

C
Cary Xu 已提交
322 323
  SMeta          *pMeta = NULL;
  STSma          *pSmaCfg = &tSma;
C
Cary Xu 已提交
324 325 326 327 328 329 330
  const SMetaCfg *pMetaCfg = &defaultMetaOptions;

  taosRemoveDir(smaTestDir);

  pMeta = metaOpen(smaTestDir, pMetaCfg, NULL);
  assert(pMeta != NULL);
  // save index 1
C
Cary Xu 已提交
331
  ASSERT_EQ(metaSaveSmaToDB(pMeta, pSmaCfg), 0);
C
Cary Xu 已提交
332

C
Cary Xu 已提交
333
  // step 2: insert data
C
Cary Xu 已提交
334 335
  STsdb    *pTsdb = (STsdb *)taosMemoryCalloc(1, sizeof(STsdb));
  STsdbCfg *pCfg = &pTsdb->config;
336 337 338 339 340 341 342 343 344 345 346 347

  pTsdb->pMeta = pMeta;
  pTsdb->vgId = 2;
  pTsdb->config.daysPerFile = 10;  // default days is 10
  pTsdb->config.keep1 = 30;
  pTsdb->config.keep2 = 90;
  pTsdb->config.keep = 365;
  pTsdb->config.precision = TSDB_TIME_PRECISION_MILLI;
  pTsdb->config.update = TD_ROW_OVERWRITE_UPDATE;
  pTsdb->config.compression = TWO_STAGE_COMP;

  switch (pTsdb->config.precision) {
C
Cary Xu 已提交
348 349 350 351 352 353 354 355 356 357 358 359 360 361
    case TSDB_TIME_PRECISION_MILLI:
      skey1 *= 1e3;
      break;
    case TSDB_TIME_PRECISION_MICRO:
      skey1 *= 1e6;
      break;
    case TSDB_TIME_PRECISION_NANO:
      skey1 *= 1e9;
      break;
    default:  // ms
      skey1 *= 1e3;
      break;
  }

H
Haojun Liao 已提交
362 363 364
  SDiskCfg pDisks = {0};
  pDisks.level = 0;
  pDisks.primary = 1;
C
Cary Xu 已提交
365 366
  strncpy(pDisks.dir, "/var/lib/taos", TSDB_FILENAME_LEN);
  int32_t numOfDisks = 1;
367 368
  pTsdb->pTfs = tfsOpen(&pDisks, numOfDisks);
  ASSERT_NE(pTsdb->pTfs, nullptr);
C
Cary Xu 已提交
369

C
Cary Xu 已提交
370 371 372 373 374 375 376
  // generate SSubmitReq msg and update expired window
  int16_t  schemaVer = 0;
  uint32_t mockRowLen = sizeof(STSRow);
  uint32_t mockRowNum = 2;
  uint32_t mockBlkNum = 2;
  uint32_t msgLen = sizeof(SSubmitReq) + mockBlkNum * sizeof(SSubmitBlk) + mockBlkNum * mockRowNum * mockRowLen;

C
Cary Xu 已提交
377
  SSubmitReq *pMsg = (SSubmitReq *)taosMemoryCalloc(1, msgLen);
C
Cary Xu 已提交
378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406
  ASSERT_NE(pMsg, nullptr);
  pMsg->version = htobe64(schemaVer);
  pMsg->numOfBlocks = htonl(mockBlkNum);
  pMsg->length = htonl(msgLen);

  SSubmitBlk *pBlk = NULL;
  STSRow     *pRow = NULL;
  TSKEY       now = taosGetTimestamp(pTsdb->config.precision);

  for (uint32_t b = 0; b < mockBlkNum; ++b) {
    pBlk = (SSubmitBlk *)POINTER_SHIFT(pMsg, sizeof(SSubmitReq) + b * (sizeof(SSubmitBlk) + mockRowNum * mockRowLen));
    pBlk->uid = htobe64(tbUid);
    pBlk->suid = htobe64(tbUid);
    pBlk->sversion = htonl(schemaVer);
    pBlk->padding = htonl(0);
    pBlk->schemaLen = htonl(0);
    pBlk->numOfRows = htons(mockRowNum);
    pBlk->dataLen = htonl(mockRowNum * mockRowLen);
    for (uint32_t r = 0; r < mockRowNum; ++r) {
      pRow = (STSRow *)POINTER_SHIFT(pBlk, sizeof(SSubmitBlk) + r * mockRowLen);
      pRow->len = mockRowLen;
      pRow->ts = now + b * 1000 + r * 1000;
      pRow->sver = schemaVer;
    }
  }

  ASSERT_EQ(tdScanAndConvertSubmitMsg(pMsg), TSDB_CODE_SUCCESS);

  ASSERT_EQ(tsdbUpdateSmaWindow(pTsdb, (const char *)pMsg), 0);
C
Cary Xu 已提交
407 408

  // init
C
Cary Xu 已提交
409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496
  const int32_t  tSmaGroupSize = 4;
  const int32_t  tSmaNumOfTags = 2;
  const int64_t  tSmaGroupId = 12345670;
  const col_id_t tSmaNumOfCols = 9;  // binary/nchar/varbinary/varchar are only used for tags for group by conditions.
  const int32_t  tSmaNumOfRows = 2;

  SArray *pDataBlocks = taosArrayInit(tSmaGroupSize, sizeof(SSDataBlock *));
  ASSERT_NE(pDataBlocks, nullptr);
  int32_t tSmaTypeArray[tSmaNumOfCols] = {TSDB_DATA_TYPE_TIMESTAMP, TSDB_DATA_TYPE_BOOL,     TSDB_DATA_TYPE_INT,
                                          TSDB_DATA_TYPE_UBIGINT,   TSDB_DATA_TYPE_SMALLINT, TSDB_DATA_TYPE_FLOAT,
                                          TSDB_DATA_TYPE_DOUBLE,    TSDB_DATA_TYPE_VARCHAR,  TSDB_DATA_TYPE_NCHAR};
  // last 2 columns for group by tags
  // int32_t tSmaTypeArray[tSmaNumOfCols] = {TSDB_DATA_TYPE_TIMESTAMP, TSDB_DATA_TYPE_BOOL};
  const char *tSmaGroupbyTags[tSmaGroupSize * tSmaNumOfTags] = {"BeiJing",  "HaiDian", "BeiJing",   "ChaoYang",
                                                                "ShangHai", "PuDong",  "ShangHai", "MinHang"};
  TSKEY       tSmaSKeyMs = (int64_t)1648535332 * 1000;
  int64_t     tSmaIntervalMs = tSma.interval * 60 * 1000;
  int64_t     tSmaInitVal = 0;

  for (int32_t g = 0; g < tSmaGroupSize; ++g) {
    SSDataBlock *pDataBlock = (SSDataBlock *)taosMemoryCalloc(1, sizeof(SSDataBlock));
    ASSERT_NE(pDataBlock, nullptr);
    pDataBlock->pBlockAgg = NULL;
    pDataBlock->info.numOfCols = tSmaNumOfCols;
    pDataBlock->info.rows = tSmaNumOfRows;
    pDataBlock->info.groupId = tSmaGroupId + g;

    pDataBlock->pDataBlock = taosArrayInit(tSmaNumOfCols, sizeof(SColumnInfoData *));
    ASSERT_NE(pDataBlock->pDataBlock, nullptr);
    for (int32_t c = 0; c < tSmaNumOfCols; ++c) {
      
      SColumnInfoData *pColInfoData = (SColumnInfoData *)taosMemoryCalloc(1, sizeof(SColumnInfoData));
      ASSERT_NE(pColInfoData, nullptr);

      pColInfoData->info.type = tSmaTypeArray[c];
      if (IS_VAR_DATA_TYPE(pColInfoData->info.type)) {
        pColInfoData->info.bytes = 100;  // update accordingly
      } else {
        pColInfoData->info.bytes = TYPE_BYTES[pColInfoData->info.type];
      }
      pColInfoData->pData = (char *)taosMemoryCalloc(1, tSmaNumOfRows * pColInfoData->info.bytes);

      for (int32_t r = 0; r < tSmaNumOfRows; ++r) {
        void *pCellData = pColInfoData->pData + r * pColInfoData->info.bytes;
        switch (pColInfoData->info.type) {
          case TSDB_DATA_TYPE_TIMESTAMP:
            *(TSKEY *)pCellData = tSmaSKeyMs + tSmaIntervalMs * r;
            break;
          case TSDB_DATA_TYPE_BOOL:
            *(bool *)pCellData = (bool)tSmaInitVal++;
            break;
          case TSDB_DATA_TYPE_INT:
            *(int *)pCellData = (int)tSmaInitVal++;
            break;
          case TSDB_DATA_TYPE_UBIGINT:
            *(uint64_t *)pCellData = (uint64_t)tSmaInitVal++;
            break;
          case TSDB_DATA_TYPE_SMALLINT:
            *(int16_t *)pCellData = (int16_t)tSmaInitVal++;
            break;
          case TSDB_DATA_TYPE_FLOAT:
            *(float *)pCellData = (float)tSmaInitVal++;
            break;
          case TSDB_DATA_TYPE_DOUBLE:
            *(double *)pCellData = (double)tSmaInitVal++;
            break;
          case TSDB_DATA_TYPE_VARCHAR:  // city
            varDataSetLen(pCellData, strlen(tSmaGroupbyTags[g * 2]));
            memcpy(varDataVal(pCellData), tSmaGroupbyTags[g * 2], varDataLen(pCellData));
            break;
          case TSDB_DATA_TYPE_NCHAR:  // district
            varDataSetLen(pCellData, strlen(tSmaGroupbyTags[g * 2 + 1]));
            memcpy(varDataVal(pCellData), tSmaGroupbyTags[g * 2 + 1], varDataLen(pCellData));
            break;
          default:
            ASSERT_EQ(0, 1);  // add definition
            break;
        }
      }
      // push SColumnInfoData
      taosArrayPush(pDataBlock->pDataBlock, &pColInfoData);
    }
    // push SSDataBlock
    taosArrayPush(pDataBlocks, &pDataBlock);
  }

  // execute
  ASSERT_EQ(tsdbInsertTSmaData(pTsdb, tSma.indexUid, (const char *)pDataBlocks), TSDB_CODE_SUCCESS);
C
Cary Xu 已提交
497

C
Cary Xu 已提交
498 499
#if 0
  STSmaDataWrapper *pSmaData = NULL;
C
Cary Xu 已提交
500 501
  pSmaData = (STSmaDataWrapper *)buf;
  printf(">> allocate [%d] time to %d and addr is %p\n", ++allocCnt, bufSize, pSmaData);
C
Cary Xu 已提交
502 503 504
  pSmaData->skey = skey1;
  pSmaData->interval = interval1;
  pSmaData->intervalUnit = intervalUnit1;
505
  pSmaData->indexUid = indexUid1;
C
Cary Xu 已提交
506 507 508 509

  int32_t len = sizeof(STSmaDataWrapper);
  for (int32_t t = 0; t < numOfTables; ++t) {
    STSmaTbData *pTbData = (STSmaTbData *)POINTER_SHIFT(pSmaData, len);
C
Cary Xu 已提交
510
    pTbData->tableUid = tbUid + t;
C
Cary Xu 已提交
511 512 513 514

    int32_t tableDataLen = sizeof(STSmaTbData);
    for (col_id_t c = 0; c < numOfCols; ++c) {
      if (bufSize - len - tableDataLen < buffer) {
C
Cary Xu 已提交
515
        ASSERT_EQ(tsdbMakeRoom(&buf, bufSize + allocStep), 0);
C
Cary Xu 已提交
516 517 518 519 520 521 522
        pSmaData = (STSmaDataWrapper *)buf;
        pTbData = (STSmaTbData *)POINTER_SHIFT(pSmaData, len);
        bufSize = taosTSizeof(buf);
        printf(">> allocate [%d] time to %d and addr is %p\n", ++allocCnt, bufSize, pSmaData);
      }
      STSmaColData *pColData = (STSmaColData *)POINTER_SHIFT(pSmaData, len + tableDataLen);
      pColData->colId = c + PRIMARYKEY_TIMESTAMP_COL_ID;
C
Cary Xu 已提交
523

C
Cary Xu 已提交
524
      // TODO: fill col data
C
Cary Xu 已提交
525 526 527 528 529 530 531 532 533
      if ((c & 1) == 0) {
        pColData->blockSize = 8;
        memcpy(pColData->data, &testSmaData1, 8);
      } else {
        pColData->blockSize = 16;
        memcpy(pColData->data, &testSmaData1, 8);
        memcpy(POINTER_SHIFT(pColData->data, 8), &testSmaData2, 8);
      }

C
Cary Xu 已提交
534 535 536 537 538
      tableDataLen += (sizeof(STSmaColData) + pColData->blockSize);
    }
    pTbData->dataLen = (tableDataLen - sizeof(STSmaTbData));
    len += tableDataLen;
    // printf("bufSize=%d, len=%d, len of table[%d]=%d\n", bufSize, len, t, tableDataLen);
C
Cary Xu 已提交
539
  }
C
Cary Xu 已提交
540 541
  pSmaData->dataLen = (len - sizeof(STSmaDataWrapper));

C
Cary Xu 已提交
542
  ASSERT_GE(bufSize, pSmaData->dataLen);
C
Cary Xu 已提交
543
  // execute
544
  ASSERT_EQ(tsdbInsertTSmaData(pTsdb, (char *)pSmaData), TSDB_CODE_SUCCESS);
C
Cary Xu 已提交
545 546
#endif

C
Cary Xu 已提交
547 548
  // step 3: query
  uint32_t checkDataCnt = 0;
C
Cary Xu 已提交
549 550
  ASSERT_EQ(tsdbGetTSmaData(pTsdb, NULL, indexUid1, skey1, 1), TSDB_CODE_SUCCESS);
  ++checkDataCnt;
C
Cary Xu 已提交
551

C
Cary Xu 已提交
552 553
  printf("%s:%d The sma data check count for insert and query is %" PRIu32 "\n", __FILE__, __LINE__, checkDataCnt);

C
Cary Xu 已提交
554
  // release data
C
Cary Xu 已提交
555
  taosMemoryFreeClear(pMsg);
C
Cary Xu 已提交
556 557 558 559 560 561 562 563 564 565 566 567 568 569 570

  for (int32_t i = 0; i < taosArrayGetSize(pDataBlocks); ++i) {
    SSDataBlock *pDataBlock = (SSDataBlock *)taosArrayGet(pDataBlocks, i);
    int32_t      numOfOutput = taosArrayGetSize(pDataBlock->pDataBlock);
    for (int32_t j = 0; j < numOfOutput; ++j) {
      SColumnInfoData *pColInfoData = (SColumnInfoData *)taosArrayGet(pDataBlock->pDataBlock, j);
      colDataDestroy(pColInfoData);
    }

    taosArrayDestroy(pDataBlock->pDataBlock);
    taosMemoryFreeClear(pDataBlock->pBlockAgg);
    taosMemoryFreeClear(pDataBlock);
  }
  taosArrayDestroy(pDataBlocks);

C
Cary Xu 已提交
571 572
  // release meta
  tdDestroyTSma(&tSma);
573 574
  tfsClose(pTsdb->pTfs);
  tsdbClose(pTsdb);
C
Cary Xu 已提交
575
  metaClose(pMeta);
C
Cary Xu 已提交
576
}
C
Cary Xu 已提交
577

C
Cary Xu 已提交
578 579 580
#endif

#pragma GCC diagnostic pop