From 2a67b83a2792415898f1432d05ff69a2ff96ca64 Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao> Date: Wed, 15 May 2024 14:11:55 +0800 Subject: [PATCH 1/3] adj code --- source/dnode/vnode/src/tsdb/tsdbReadUtil.h | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbReadUtil.h b/source/dnode/vnode/src/tsdb/tsdbReadUtil.h index c13d9ff563..6c76f8c372 100644 --- a/source/dnode/vnode/src/tsdb/tsdbReadUtil.h +++ b/source/dnode/vnode/src/tsdb/tsdbReadUtil.h @@ -47,9 +47,7 @@ extern "C" { } \ } else { \ (_pKey)->ts = (_pRow)->pBlockData->aTSKEY[(_pRow)->iRow]; \ - if ((_pRow)->pBlockData->nColData > 0) { \ - tColRowGetPrimaryKey((_pRow)->pBlockData, (_pRow)->iRow, (_pKey)); \ - } \ + tColRowGetPrimaryKey((_pRow)->pBlockData, (_pRow)->iRow, (_pKey)); \ } \ } From 0cc1c412af1001986489520b8c6f69491d96ab3c Mon Sep 17 00:00:00 2001 From: Chris Zhai Date: Wed, 15 May 2024 19:50:25 +0800 Subject: [PATCH 2/3] add test cases for TD-29196 --- tests/army/community/insert/insert_basic.py | 86 +++++++++++++++++++++ tests/parallel_test/cases.task | 1 + 2 files changed, 87 insertions(+) create mode 100644 tests/army/community/insert/insert_basic.py diff --git a/tests/army/community/insert/insert_basic.py b/tests/army/community/insert/insert_basic.py new file mode 100644 index 0000000000..481db4eadd --- /dev/null +++ b/tests/army/community/insert/insert_basic.py @@ -0,0 +1,86 @@ +################################################################### +# Copyright (c) 2016 by TAOS Technologies, Inc. +# All rights reserved. +# +# This file is proprietary and confidential to TAOS Technologies. +# No part of this file may be reproduced, stored, transmitted, +# disclosed or used in any form or by any means other than as +# expressly provided by the written permission from Jianhui Tao +# +################################################################### + +# -*- coding: utf-8 -*- + +import sys +import time +import random + +import taos +import frame +import frame.etool + + +from frame.log import * +from frame.cases import * +from frame.sql import * +from frame.caseBase import * +from frame import * + + +class TDTestCase(TBase): + + def checkGeometry(self): + tdLog.info(f"check geometry") + + tdSql.execute("create database db_geometry;") + tdSql.execute("use db_geometry;") + tdSql.execute("create table t_ge (ts timestamp, id int, c1 GEOMETRY(512));") + tdSql.execute("insert into t_ge values(now, 1, 'MULTIPOINT ((0 0), (1 1))');") + tdSql.execute("insert into t_ge values(now, 1, 'MULTIPOINT (0 0, 1 1)');") + tdSql.execute("insert into t_ge values(now, 2, 'POINT (0 0)');") + tdSql.execute("insert into t_ge values(now, 2, 'POINT EMPTY');") + tdSql.execute("insert into t_ge values(now, 3, 'LINESTRING (0 0, 0 1, 1 2)');") + tdSql.execute("insert into t_ge values(now, 3, 'LINESTRING EMPTY');") + tdSql.execute("insert into t_ge values(now, 4, 'POLYGON ((0 0, 1 0, 1 1, 0 1, 0 0))');") + tdSql.execute("insert into t_ge values(now, 4, 'POLYGON ((0 0, 4 0, 4 4, 0 4, 0 0), (1 1, 1 2, 2 2, 2 1, 1 1))');") + tdSql.execute("insert into t_ge values(now, 4, 'POLYGON EMPTY');") + tdSql.execute("insert into t_ge values(now, 5, 'MULTILINESTRING ((0 0, 1 1), (2 2, 3 3))');") + tdSql.execute("insert into t_ge values(now, 6, 'MULTIPOLYGON (((1 1, 1 3, 3 3, 3 1, 1 1)), ((4 3, 6 3, 6 1, 4 1, 4 3)))');") + tdSql.execute("insert into t_ge values(now, 7, 'GEOMETRYCOLLECTION (MULTIPOINT((0 0), (1 1)), POINT(3 4), LINESTRING(2 3, 3 4))');") + tdSql.query("select * from t_ge;") + tdSql.checkRows(12) + tdSql.query("select * from t_ge where id=1;") + tdSql.checkRows(2) + tdSql.query("select * from t_ge where id=2;") + tdSql.checkRows(2) + tdSql.query("select * from t_ge where id=3;") + tdSql.checkRows(2) + tdSql.query("select * from t_ge where id=4;") + tdSql.checkRows(3) + tdSql.query("select * from t_ge where id=5;") + tdSql.checkRows(1) + tdSql.query("select * from t_ge where id=6;") + tdSql.checkRows(1) + tdSql.query("select * from t_ge where id=7;") + tdSql.checkRows(1) + + def checkDataType(self): + tdLog.info(f"check datatype") + + self.checkGeometry() + + + + # run + def run(self): + tdLog.debug(f"start to excute {__file__}") + + # check insert datatype + self.checkDataType() + + tdLog.success(f"{__file__} successfully executed") + + + +tdCases.addLinux(__file__, TDTestCase()) +tdCases.addWindows(__file__, TDTestCase()) \ No newline at end of file diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task index 816288b5e9..39267b2a0e 100644 --- a/tests/parallel_test/cases.task +++ b/tests/parallel_test/cases.task @@ -20,6 +20,7 @@ ,,y,army,./pytest.sh python3 ./test.py -f community/query/fill/fill_desc.py -N 3 -L 3 -D 2 ,,y,army,./pytest.sh python3 ./test.py -f community/cluster/incSnapshot.py -N 3 ,,y,army,./pytest.sh python3 ./test.py -f community/query/query_basic.py -N 3 +,,y,army,./pytest.sh python3 ./test.py -f community/insert/insert_basic.py -N 3 ,,y,army,./pytest.sh python3 ./test.py -f community/cluster/splitVgroupByLearner.py -N 3 ,,n,army,python3 ./test.py -f community/cmdline/fullopt.py ,,n,army,python3 ./test.py -f community/query/show.py -N 3 From 4be4a0462127c0c79de41f1566d51b5a3170f33f Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao> Date: Thu, 16 May 2024 09:53:53 +0800 Subject: [PATCH 3/3] fix(meta scan):check system table scan result --- source/libs/executor/src/sysscanoperator.c | 86 +++++----- tests/script/tsim/query/sys_tbname.sim | 173 +++++++++++++++++++++ 2 files changed, 219 insertions(+), 40 deletions(-) diff --git a/source/libs/executor/src/sysscanoperator.c b/source/libs/executor/src/sysscanoperator.c index db83c46155..10d38b3d95 100644 --- a/source/libs/executor/src/sysscanoperator.c +++ b/source/libs/executor/src/sysscanoperator.c @@ -1651,50 +1651,56 @@ static SSDataBlock* doSysTableScan(SOperatorInfo* pOperator) { SSysTableScanInfo* pInfo = pOperator->info; char dbName[TSDB_DB_NAME_LEN] = {0}; - if (isTaskKilled(pOperator->pTaskInfo)) { - setOperatorCompleted(pOperator); - return NULL; - } + while (1) { - blockDataCleanup(pInfo->pRes); - - const char* name = tNameGetTableName(&pInfo->name); - if (pInfo->showRewrite) { - getDBNameFromCondition(pInfo->pCondition, dbName); - if (strncasecmp(name, TSDB_INS_TABLE_COMPACTS, TSDB_TABLE_FNAME_LEN) != 0 && - strncasecmp(name, TSDB_INS_TABLE_COMPACT_DETAILS, TSDB_TABLE_FNAME_LEN) != 0) { - sprintf(pInfo->req.db, "%d.%s", pInfo->accountId, dbName); - } - } else if (strncasecmp(name, TSDB_INS_TABLE_COLS, TSDB_TABLE_FNAME_LEN) == 0) { - getDBNameFromCondition(pInfo->pCondition, dbName); - if (dbName[0]) sprintf(pInfo->req.db, "%d.%s", pInfo->accountId, dbName); - sysTableIsCondOnOneTable(pInfo->pCondition, pInfo->req.filterTb); - } - - SSDataBlock* pBlock = NULL; - if (strncasecmp(name, TSDB_INS_TABLE_TABLES, TSDB_TABLE_FNAME_LEN) == 0) { - pBlock = sysTableScanUserTables(pOperator); - } else if (strncasecmp(name, TSDB_INS_TABLE_TAGS, TSDB_TABLE_FNAME_LEN) == 0) { - pBlock = sysTableScanUserTags(pOperator); - } else if (strncasecmp(name, TSDB_INS_TABLE_COLS, TSDB_TABLE_FNAME_LEN) == 0 && pInfo->readHandle.mnd == NULL) { - pBlock = sysTableScanUserCols(pOperator); - } else if (strncasecmp(name, TSDB_INS_TABLE_STABLES, TSDB_TABLE_FNAME_LEN) == 0 && pInfo->showRewrite && - IS_SYS_DBNAME(dbName)) { - pBlock = sysTableScanUserSTables(pOperator); - } else { // load the meta from mnode of the given epset - pBlock = sysTableScanFromMNode(pOperator, pInfo, name, pTaskInfo); - } - - sysTableScanFillTbName(pOperator, pInfo, name, pBlock); - if (pBlock != NULL) { - bool limitReached = applyLimitOffset(&pInfo->limitInfo, pBlock, pTaskInfo); - if (limitReached) { + if (isTaskKilled(pOperator->pTaskInfo)) { setOperatorCompleted(pOperator); + return NULL; } - return pBlock->info.rows > 0 ? pBlock : NULL; - } else { - return NULL; + blockDataCleanup(pInfo->pRes); + + const char* name = tNameGetTableName(&pInfo->name); + if (pInfo->showRewrite) { + getDBNameFromCondition(pInfo->pCondition, dbName); + if (strncasecmp(name, TSDB_INS_TABLE_COMPACTS, TSDB_TABLE_FNAME_LEN) != 0 && + strncasecmp(name, TSDB_INS_TABLE_COMPACT_DETAILS, TSDB_TABLE_FNAME_LEN) != 0) { + sprintf(pInfo->req.db, "%d.%s", pInfo->accountId, dbName); + } + } else if (strncasecmp(name, TSDB_INS_TABLE_COLS, TSDB_TABLE_FNAME_LEN) == 0) { + getDBNameFromCondition(pInfo->pCondition, dbName); + if (dbName[0]) sprintf(pInfo->req.db, "%d.%s", pInfo->accountId, dbName); + sysTableIsCondOnOneTable(pInfo->pCondition, pInfo->req.filterTb); + } + + SSDataBlock* pBlock = NULL; + if (strncasecmp(name, TSDB_INS_TABLE_TABLES, TSDB_TABLE_FNAME_LEN) == 0) { + pBlock = sysTableScanUserTables(pOperator); + } else if (strncasecmp(name, TSDB_INS_TABLE_TAGS, TSDB_TABLE_FNAME_LEN) == 0) { + pBlock = sysTableScanUserTags(pOperator); + } else if (strncasecmp(name, TSDB_INS_TABLE_COLS, TSDB_TABLE_FNAME_LEN) == 0 && pInfo->readHandle.mnd == NULL) { + pBlock = sysTableScanUserCols(pOperator); + } else if (strncasecmp(name, TSDB_INS_TABLE_STABLES, TSDB_TABLE_FNAME_LEN) == 0 && pInfo->showRewrite && + IS_SYS_DBNAME(dbName)) { + pBlock = sysTableScanUserSTables(pOperator); + } else { // load the meta from mnode of the given epset + pBlock = sysTableScanFromMNode(pOperator, pInfo, name, pTaskInfo); + } + + sysTableScanFillTbName(pOperator, pInfo, name, pBlock); + if (pBlock != NULL) { + bool limitReached = applyLimitOffset(&pInfo->limitInfo, pBlock, pTaskInfo); + if (limitReached) { + setOperatorCompleted(pOperator); + } + + if (pBlock->info.rows == 0) { + continue; + } + return pBlock; + } else { + return NULL; + } } } diff --git a/tests/script/tsim/query/sys_tbname.sim b/tests/script/tsim/query/sys_tbname.sim index 716937f073..7739ea5373 100644 --- a/tests/script/tsim/query/sys_tbname.sim +++ b/tests/script/tsim/query/sys_tbname.sim @@ -135,4 +135,177 @@ endi print =========================== td-24781 sql select DISTINCT (`precision`) from `information_schema`.`ins_databases` PARTITION BY `precision` +print =========================ins_stables + +print create database test vgroups 4; +sql create database test vgroups 4; +sql use test; +sql create stable st1(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st2(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st3(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st4(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st5(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st6(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st7(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st8(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st9(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st10(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st11(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st12(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st13(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st14(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st15(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st16(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st17(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st18(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st19(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st20(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st21(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st22(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st23(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st24(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st25(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st26(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st27(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st28(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st29(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st30(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st31(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st32(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st33(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st34(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st35(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st36(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st37(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st38(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st39(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st40(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st41(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st42(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st43(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st44(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st45(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st46(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st47(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st48(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st49(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st50(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st51(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st52(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st53(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st54(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st55(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st56(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st57(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st58(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st59(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st60(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st61(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st62(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st63(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st64(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st65(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st66(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st67(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st68(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st69(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st70(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); + +print create database test1 vgroups 4; +sql create database test1 vgroups 4; +sql use test1; + +sql create stable st1(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st2(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st3(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st4(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st5(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st6(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st7(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st8(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st9(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st10(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st11(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st12(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st13(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st14(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st15(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st16(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st17(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st18(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st19(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st20(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st21(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st22(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st23(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st24(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st25(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st26(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st27(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st28(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st29(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st30(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st31(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st32(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st33(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st34(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st35(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st36(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st37(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st38(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st39(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st40(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st41(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st42(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st43(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st44(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st45(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st46(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st47(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st48(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st49(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st50(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st51(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st52(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st53(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st54(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st55(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st56(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st57(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st58(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st59(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st60(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st61(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st62(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st63(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st64(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st65(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st66(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st67(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st68(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st69(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); +sql create stable st70(ts timestamp,a int,b int,c int) tags(ta int,tb int,tc int); + +sleep 1000 + +sql select * from information_schema.ins_stables where db_name = "test" limit 68,32; + +print $data00 $data01 $data02 $data03 +print $data10 $data11 $data12 $data13 +print $data20 $data21 $data22 $data23 + +if $rows != 2 then + return -1 +endi + +sql select * from information_schema.ins_stables where db_name = "test1" limit 68,32; + +print $data00 $data01 $data02 $data03 +print $data10 $data11 $data12 $data13 +print $data20 $data21 $data22 $data23 + +if $rows != 2 then + return -1 +endi + #system sh/exec.sh -n dnode1 -s stop -x SIGINT