enh: show command optimize

This commit is contained in:
Xiaoyu Wang 2022-08-11 20:26:40 +08:00
parent 4f0c6d3aa4
commit 9a9aef985e
226 changed files with 2359 additions and 2193 deletions

View File

@ -266,12 +266,60 @@
#define TK_OFFSET 248
#define TK_ASC 249
#define TK_NULLS 250
#define TK_ID 251
#define TK_NK_BITNOT 252
#define TK_VALUES 253
#define TK_IMPORT 254
#define TK_NK_SEMI 255
#define TK_FILE 256
#define TK_ABORT 251
#define TK_AFTER 252
#define TK_ATTACH 253
#define TK_BEFORE 254
#define TK_BEGIN 255
#define TK_BITAND 256
#define TK_BITNOT 257
#define TK_BITOR 258
#define TK_BLOCKS 259
#define TK_CHANGE 260
#define TK_COMMA 261
#define TK_COMPACT 262
#define TK_CONCAT 263
#define TK_CONFLICT 264
#define TK_COPY 265
#define TK_DEFERRED 266
#define TK_DELIMITERS 267
#define TK_DETACH 268
#define TK_DIVIDE 269
#define TK_DOT 270
#define TK_EACH 271
#define TK_END 272
#define TK_FAIL 273
#define TK_FILE 274
#define TK_FOR 275
#define TK_GLOB 276
#define TK_ID 277
#define TK_IMMEDIATE 278
#define TK_IMPORT 279
#define TK_INITIALLY 280
#define TK_INSTEAD 281
#define TK_ISNULL 282
#define TK_KEY 283
#define TK_NK_BITNOT 284
#define TK_NK_SEMI 285
#define TK_NOTNULL 286
#define TK_OF 287
#define TK_PLUS 288
#define TK_PRIVILEGE 289
#define TK_RAISE 290
#define TK_REPLACE 291
#define TK_RESTRICT 292
#define TK_ROW 293
#define TK_SEMI 294
#define TK_STAR 295
#define TK_STATEMENT 296
#define TK_STRING 297
#define TK_TIMES 298
#define TK_UPDATE 299
#define TK_VALUES 300
#define TK_VARIABLE 301
#define TK_VIEW 302
#define TK_VNODES 303
#define TK_WAL 304
#define TK_NK_SPACE 300
#define TK_NK_COMMENT 301

View File

@ -269,6 +269,7 @@ typedef struct SSelectStmt {
bool hasInterpFunc;
bool hasLastRowFunc;
bool hasTimeLineFunc;
bool hasUdaf;
bool onlyHasKeepOrderFunc;
bool groupSort;
} SSelectStmt;

View File

@ -346,7 +346,7 @@ static const SSysTableMeta perfsMeta[] = {
{TSDB_PERFS_TABLE_TOPICS, topicSchema, tListLen(topicSchema)},
{TSDB_PERFS_TABLE_CONSUMERS, consumerSchema, tListLen(consumerSchema)},
{TSDB_PERFS_TABLE_SUBSCRIPTIONS, subscriptionSchema, tListLen(subscriptionSchema)},
{TSDB_PERFS_TABLE_OFFSETS, offsetSchema, tListLen(offsetSchema)},
// {TSDB_PERFS_TABLE_OFFSETS, offsetSchema, tListLen(offsetSchema)},
{TSDB_PERFS_TABLE_TRANS, transSchema, tListLen(transSchema)},
{TSDB_PERFS_TABLE_SMAS, smaSchema, tListLen(smaSchema)},
{TSDB_PERFS_TABLE_STREAMS, streamSchema, tListLen(streamSchema)},

View File

@ -998,4 +998,6 @@ null_ordering_opt(A) ::= .
null_ordering_opt(A) ::= NULLS FIRST. { A = NULL_ORDER_FIRST; }
null_ordering_opt(A) ::= NULLS LAST. { A = NULL_ORDER_LAST; }
%fallback ID NK_BITNOT VALUES IMPORT NK_SEMI FILE.
%fallback ABORT AFTER ATTACH BEFORE BEGIN BITAND BITNOT BITOR BLOCKS CHANGE COMMA COMPACT CONCAT CONFLICT COPY DEFERRED DELIMITERS DETACH DIVIDE DOT EACH END FAIL
FILE FOR GLOB ID IMMEDIATE IMPORT INITIALLY INSTEAD ISNULL KEY NK_BITNOT NK_SEMI NOTNULL OF PLUS PRIVILEGE RAISE REPLACE RESTRICT ROW SEMI STAR STATEMENT STRING
TIMES UPDATE VALUES VARIABLE VIEW VNODES WAL.

View File

@ -43,8 +43,8 @@ static SKeyword keywordTable[] = {
{"AT_ONCE", TK_AT_ONCE},
{"BALANCE", TK_BALANCE},
{"BETWEEN", TK_BETWEEN},
{"BINARY", TK_BINARY},
{"BIGINT", TK_BIGINT},
{"BINARY", TK_BINARY},
{"BNODE", TK_BNODE},
{"BNODES", TK_BNODES},
{"BOOL", TK_BOOL},
@ -60,9 +60,9 @@ static SKeyword keywordTable[] = {
{"COLUMN", TK_COLUMN},
{"COMMENT", TK_COMMENT},
{"COMP", TK_COMP},
{"CONNS", TK_CONNS},
{"CONNECTION", TK_CONNECTION},
{"CONNECTIONS", TK_CONNECTIONS},
{"CONNS", TK_CONNS},
{"CONSUMER", TK_CONSUMER},
{"CONSUMERS", TK_CONSUMERS},
{"CONTAINS", TK_CONTAINS},
@ -106,8 +106,8 @@ static SKeyword keywordTable[] = {
{"INDEX", TK_INDEX},
{"INDEXES", TK_INDEXES},
{"INNER", TK_INNER},
{"INT", TK_INT},
{"INSERT", TK_INSERT},
{"INT", TK_INT},
{"INTEGER", TK_INTEGER},
{"INTERVAL", TK_INTERVAL},
{"INTO", TK_INTO},
@ -147,10 +147,10 @@ static SKeyword keywordTable[] = {
{"OR", TK_OR},
{"ORDER", TK_ORDER},
{"OUTPUTTYPE", TK_OUTPUTTYPE},
{"PARTITION", TK_PARTITION},
{"PASS", TK_PASS},
{"PAGES", TK_PAGES},
{"PAGESIZE", TK_PAGESIZE},
{"PARTITION", TK_PARTITION},
{"PASS", TK_PASS},
{"PORT", TK_PORT},
{"PPS", TK_PPS},
{"PRECISION", TK_PRECISION},

View File

@ -82,7 +82,7 @@ static const SSysTableShowAdapter sysTableShowAdapter[] = {
.pDbName = TSDB_INFORMATION_SCHEMA_DB,
.pTableName = TSDB_INS_TABLE_MODULES,
.numOfShowCols = 1,
.pShowCols = {"module"}
.pShowCols = {"endpoint"}
},
{
.showType = QUERY_NODE_SHOW_QNODES_STMT,
@ -1528,6 +1528,7 @@ static void setFuncClassification(SNode* pCurrStmt, SFunctionNode* pFunc) {
pSelect->hasInterpFunc = pSelect->hasInterpFunc ? true : (FUNCTION_TYPE_INTERP == pFunc->funcType);
pSelect->hasLastRowFunc = pSelect->hasLastRowFunc ? true : (FUNCTION_TYPE_LAST_ROW == pFunc->funcType);
pSelect->hasTimeLineFunc = pSelect->hasTimeLineFunc ? true : fmIsTimelineFunc(pFunc->funcId);
pSelect->hasUdaf = pSelect->hasUdaf ? true : fmIsUserDefinedFunc(pFunc->funcId) && fmIsAggFunc(pFunc->funcId);
pSelect->onlyHasKeepOrderFunc = pSelect->onlyHasKeepOrderFunc ? fmIsKeepOrderFunc(pFunc->funcId) : false;
}
}
@ -2819,6 +2820,11 @@ static int32_t translateInterp(STranslateContext* pCxt, SSelectStmt* pSelect) {
return TSDB_CODE_SUCCESS;
}
if (NULL == pSelect->pRange || NULL == pSelect->pEvery || NULL == pSelect->pFill) {
return generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_INVALID_INTERP_CLAUSE,
"Missing RANGE clause, EVERY clause or FILL clause");
}
int32_t code = translateExpr(pCxt, &pSelect->pRange);
if (TSDB_CODE_SUCCESS == code) {
code = translateExpr(pCxt, &pSelect->pEvery);
@ -4909,6 +4915,11 @@ static bool crossTableWithoutAggOper(SSelectStmt* pSelect) {
!isPartitionByTbname(pSelect->pPartitionByList);
}
static bool crossTableWithUdaf(SSelectStmt* pSelect) {
return pSelect->hasUdaf && TSDB_SUPER_TABLE == ((SRealTableNode*)pSelect->pFromTable)->pMeta->tableType &&
!isPartitionByTbname(pSelect->pPartitionByList);
}
static int32_t checkCreateStream(STranslateContext* pCxt, SCreateStreamStmt* pStmt) {
if (NULL != pStmt->pOptions->pWatermark &&
(DEAL_RES_ERROR == translateValue(pCxt, (SValueNode*)pStmt->pOptions->pWatermark))) {
@ -4960,7 +4971,8 @@ static int32_t addWstartTsToCreateStreamQuery(SNode* pStmt) {
static int32_t checkStreamQuery(STranslateContext* pCxt, SSelectStmt* pSelect) {
if (TSDB_DATA_TYPE_TIMESTAMP != ((SExprNode*)nodesListGetNode(pSelect->pProjectionList, 0))->resType.type ||
!pSelect->isTimeLineResult || crossTableWithoutAggOper(pSelect)) {
!pSelect->isTimeLineResult || crossTableWithoutAggOper(pSelect) || NULL != pSelect->pOrderByList ||
crossTableWithUdaf(pSelect)) {
return generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_INVALID_STREAM_QUERY, "Unsupported stream query");
}
return TSDB_CODE_SUCCESS;

File diff suppressed because it is too large Load Diff

View File

@ -35,25 +35,25 @@ void generateInformationSchema(MockCatalogService* mcs) {
{
ITableBuilder& builder =
mcs->createTableBuilder(TSDB_INFORMATION_SCHEMA_DB, TSDB_INS_TABLE_DNODES, TSDB_SYSTEM_TABLE, 1)
.addColumn("id", TSDB_DATA_TYPE_INT);
.addColumn("endpoint", TSDB_DATA_TYPE_BINARY, TSDB_EP_LEN);
builder.done();
}
{
ITableBuilder& builder =
mcs->createTableBuilder(TSDB_INFORMATION_SCHEMA_DB, TSDB_INS_TABLE_MNODES, TSDB_SYSTEM_TABLE, 1)
.addColumn("id", TSDB_DATA_TYPE_INT);
.addColumn("endpoint", TSDB_DATA_TYPE_BINARY, TSDB_EP_LEN);
builder.done();
}
{
ITableBuilder& builder =
mcs->createTableBuilder(TSDB_INFORMATION_SCHEMA_DB, TSDB_INS_TABLE_MODULES, TSDB_SYSTEM_TABLE, 1)
.addColumn("id", TSDB_DATA_TYPE_INT);
.addColumn("endpoint", TSDB_DATA_TYPE_BINARY, TSDB_EP_LEN);
builder.done();
}
{
ITableBuilder& builder =
mcs->createTableBuilder(TSDB_INFORMATION_SCHEMA_DB, TSDB_INS_TABLE_QNODES, TSDB_SYSTEM_TABLE, 1)
.addColumn("id", TSDB_DATA_TYPE_INT);
.addColumn("endpoint", TSDB_DATA_TYPE_BINARY, TSDB_EP_LEN);
builder.done();
}
{
@ -70,7 +70,8 @@ void generateInformationSchema(MockCatalogService* mcs) {
}
{
ITableBuilder& builder =
mcs->createTableBuilder(TSDB_INFORMATION_SCHEMA_DB, TSDB_INS_TABLE_INDEXES, TSDB_SYSTEM_TABLE, 2)
mcs->createTableBuilder(TSDB_INFORMATION_SCHEMA_DB, TSDB_INS_TABLE_INDEXES, TSDB_SYSTEM_TABLE, 3)
.addColumn("index_name", TSDB_DATA_TYPE_BINARY, TSDB_TABLE_NAME_LEN)
.addColumn("db_name", TSDB_DATA_TYPE_BINARY, TSDB_DB_NAME_LEN)
.addColumn("table_name", TSDB_DATA_TYPE_BINARY, TSDB_TABLE_NAME_LEN);
builder.done();
@ -98,7 +99,7 @@ void generateInformationSchema(MockCatalogService* mcs) {
{
ITableBuilder& builder =
mcs->createTableBuilder(TSDB_INFORMATION_SCHEMA_DB, TSDB_INS_TABLE_USERS, TSDB_SYSTEM_TABLE, 1)
.addColumn("user_name", TSDB_DATA_TYPE_BINARY, TSDB_USER_LEN);
.addColumn("name", TSDB_DATA_TYPE_BINARY, TSDB_USER_LEN);
builder.done();
}
{
@ -122,7 +123,7 @@ void generateInformationSchema(MockCatalogService* mcs) {
{
ITableBuilder& builder =
mcs->createTableBuilder(TSDB_INFORMATION_SCHEMA_DB, TSDB_INS_TABLE_CLUSTER, TSDB_SYSTEM_TABLE, 1)
.addColumn("id", TSDB_DATA_TYPE_BIGINT);
.addColumn("name", TSDB_DATA_TYPE_BINARY, TSDB_CLUSTER_ID_LEN);
builder.done();
}
}

View File

@ -294,16 +294,6 @@ TEST_F(ParserSelectTest, intervalSemanticCheck) {
TEST_F(ParserSelectTest, interp) {
useDb("root", "test");
run("SELECT INTERP(c1) FROM t1");
run("SELECT INTERP(c1) FROM t1 RANGE('2017-7-14 18:00:00', '2017-7-14 19:00:00')");
run("SELECT INTERP(c1) FROM t1 RANGE('2017-7-14 18:00:00', '2017-7-14 19:00:00') FILL(LINEAR)");
run("SELECT INTERP(c1) FROM t1 EVERY(5s)");
run("SELECT INTERP(c1) FROM t1 RANGE('2017-7-14 18:00:00', '2017-7-14 19:00:00') EVERY(5s)");
run("SELECT INTERP(c1) FROM t1 RANGE('2017-7-14 18:00:00', '2017-7-14 19:00:00') EVERY(5s) FILL(LINEAR)");
}

View File

@ -93,8 +93,6 @@ TEST_F(PlanBasicTest, tailFunc) {
TEST_F(PlanBasicTest, interpFunc) {
useDb("root", "test");
run("SELECT INTERP(c1) FROM t1");
run("SELECT INTERP(c1) FROM t1 RANGE('2017-7-14 18:00:00', '2017-7-14 19:00:00') EVERY(5s) FILL(LINEAR)");
}

View File

@ -49,7 +49,7 @@ return
print =============== step2: create database
sql create database db vgroups 1 replica 3
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -33,7 +33,7 @@ endi
print =============== step2: create database
sql create database db vgroups 1 replica 1
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -659,7 +659,7 @@ endi
print ======= over
sql drop database d1
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -169,7 +169,7 @@ $cnt = $cnt + 1
if $cnt == 20 then
return -1
endi
sql show databases
sql select * from information_schema.ins_databases
if $rows != 0 then
sleep 2000
goto wait_database_dropped

View File

@ -169,7 +169,7 @@ $cnt = $cnt + 1
if $cnt == 20 then
return -1
endi
sql show databases
sql select * from information_schema.ins_databases
if $rows != 0 then
sleep 2000
goto wait_database_dropped

View File

@ -189,7 +189,7 @@ $cnt = $cnt + 1
if $cnt == 20 then
return -1
endi
sql show databases
sql select * from information_schema.ins_databases
if $rows != 0 then
sleep 2000
goto wait_database_dropped

View File

@ -189,7 +189,7 @@ $cnt = $cnt + 1
if $cnt == 20 then
return -1
endi
sql show databases
sql select * from information_schema.ins_databases
if $rows != 0 then
sleep 2000
goto wait_database_dropped

View File

@ -237,7 +237,7 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step13: alter replica 2
sql alter database $db replica 2
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $data04 != 2 then
@ -259,7 +259,7 @@ sleep 20000
print ============== step15: alter replica 1
sql alter database $db replica 1
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $data04 != 1 then
print rplica is not modify to 1, error!!!!!!
@ -268,7 +268,7 @@ endi
print ============== step16: alter replica 2
sql alter database $db replica 2
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $data04 != 2 then
print rplica is not modify to 2, error!!!!!!
@ -285,7 +285,7 @@ endi
print ============== step18: alter replica 3
sql alter database $db replica 3
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $data04 != 3 then
print rplica is not modify to 3, error!!!!!!

View File

@ -224,7 +224,7 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step13: alter replica 2
sql alter database $db replica 2
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $data04 != 2 then
@ -244,7 +244,7 @@ sleep 20000
print ============== step15: alter replica 1
sql alter database $db replica 1
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $data04 != 1 then
print rplica is not modify to 1, error!!!!!!
@ -253,7 +253,7 @@ endi
print ============== step16: alter replica 2
sql alter database $db replica 2
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $data04 != 2 then
print rplica is not modify to 2, error!!!!!!
@ -270,7 +270,7 @@ endi
print ============== step18: alter replica 3
sql alter database $db replica 3
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $data04 != 3 then
print rplica is not modify to 3, error!!!!!!

View File

@ -223,7 +223,7 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step13: alter replica 2
sql alter database $db replica 2
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
@ -253,7 +253,7 @@ sleep 20000
print ============== step15: alter replica 1
sql alter database $db replica 1
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
@ -273,7 +273,7 @@ endi
print ============== step16: alter replica 2
sql alter database $db replica 2
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
@ -301,7 +301,7 @@ endi
print ============== step18: alter replica 3
sql alter database $db replica 3
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19

View File

@ -227,7 +227,7 @@ print $data0_9 $data1_9 $data2_9 $data3_9 $data4_9
print ============== step13: alter replica 2
sql alter database $db replica 2
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
@ -257,7 +257,7 @@ sleep 20000
print ============== step15: alter replica 1
sql alter database $db replica 1
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
@ -277,7 +277,7 @@ endi
print ============== step16: alter replica 2
sql alter database $db replica 2
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
@ -305,7 +305,7 @@ endi
print ============== step18: alter replica 3
sql alter database $db replica 3
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19

View File

@ -157,7 +157,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -93,7 +93,7 @@ sql_error select _block_dist() from (select * from $mt)
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -92,7 +92,7 @@ step6:
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -185,7 +185,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -85,7 +85,7 @@ step6:
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -147,7 +147,7 @@ step6:
print =============== clear
#sql drop database $db
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 2 then
# return -1
#endi

View File

@ -159,7 +159,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -196,7 +196,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -163,7 +163,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -208,7 +208,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -87,7 +87,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -163,7 +163,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -161,7 +161,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -223,7 +223,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -122,7 +122,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -93,7 +93,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -163,7 +163,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -94,7 +94,7 @@ step6:
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -47,7 +47,7 @@ print ============= create database
# | WAL_LEVEL value [1 | 2]
sql create database db CACHEMODEL 'both' COMP 0 DURATION 240 WAL_FSYNC_PERIOD 1000 MAXROWS 8000 MINROWS 10 KEEP 1000 PRECISION 'ns' REPLICA 3 WAL_LEVEL 2 VGROUPS 6 SINGLE_STABLE 1
sql show databases
sql select * from information_schema.ins_databases
print rows: $rows
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
print $data10 $data11 $data12 $data13 $data14 $data15 $data16 $data17 $data18 $data19
@ -184,13 +184,13 @@ sql_error alter database db replica 5
sql_error alter database db replica -1
sql_error alter database db replica 0
#sql alter database db replica 1
#sql show databases
#sql select * from information_schema.ins_databases
#print replica: $data4_db
#if $data4_db != 1 then
# return -1
#endi
#sql alter database db replica 3
#sql show databases
#sql select * from information_schema.ins_databases
#print replica: $data4_db
#if $data4_db != 3 then
# return -1
@ -198,13 +198,13 @@ sql_error alter database db replica 0
#print ============== modify quorum
#sql alter database db quorum 2
#sql show databases
#sql select * from information_schema.ins_databases
#print quorum $data5_db
#if $data5_db != 2 then
# return -1
#endi
#sql alter database db quorum 1
#sql show databases
#sql select * from information_schema.ins_databases
#print quorum $data5_db
#if $data5_db != 1 then
# return -1
@ -224,14 +224,14 @@ sql_error alter database db duration 14400 # set over than keep
print ============== modify keep
sql alter database db keep 2400
sql show databases
sql select * from information_schema.ins_databases
print keep $data7_db
if $data7_db != 3456000m,3456000m,3456000m then
return -1
endi
#sql alter database db keep 1000,2000
#sql show databases
#sql select * from information_schema.ins_databases
#print keep $data7_db
#if $data7_db != 500,500,500 then
# return -1
@ -261,13 +261,13 @@ sql_error alter database db keep -1
#print ============== modify blocks
#sql alter database db blocks 3
#sql show databases
#sql select * from information_schema.ins_databases
#print blocks $data9_db
#if $data9_db != 3 then
# return -1
#endi
#sql alter database db blocks 11
#sql show databases
#sql select * from information_schema.ins_databases
#print blocks $data9_db
#if $data9_db != 11 then
# return -1
@ -298,13 +298,13 @@ sql_error alter database db maxrows 10 # little than minrows
print ============== step wal_level
sql alter database db wal_level 1
sql show databases
sql select * from information_schema.ins_databases
print wal_level $data20_db
if $data20_db != 1 then
return -1
endi
sql alter database db wal_level 2
sql show databases
sql select * from information_schema.ins_databases
print wal_level $data20_db
if $data20_db != 2 then
return -1
@ -317,19 +317,19 @@ sql_error alter database db wal_level -1
print ============== modify wal_fsync_period
sql alter database db wal_fsync_period 2000
sql show databases
sql select * from information_schema.ins_databases
print wal_fsync_period $data21_db
if $data21_db != 2000 then
return -1
endi
sql alter database db wal_fsync_period 500
sql show databases
sql select * from information_schema.ins_databases
print wal_fsync_period $data21_db
if $data21_db != 500 then
return -1
endi
sql alter database db wal_fsync_period 0
sql show databases
sql select * from information_schema.ins_databases
print wal_fsync_period $data21_db
if $data21_db != 0 then
return -1
@ -349,31 +349,31 @@ sql_error alter database db comp -1
print ============== modify cachelast [0, 1, 2, 3]
sql alter database db cachemodel 'last_value'
sql show databases
sql select * from information_schema.ins_databases
print cachelast $data18_db
if $data18_db != last_value then
return -1
endi
sql alter database db cachemodel 'last_row'
sql show databases
sql select * from information_schema.ins_databases
print cachelast $data18_db
if $data18_db != last_row then
return -1
endi
sql alter database db cachemodel 'none'
sql show databases
sql select * from information_schema.ins_databases
print cachelast $data18_db
if $data18_db != none then
return -1
endi
sql alter database db cachemodel 'last_value'
sql show databases
sql select * from information_schema.ins_databases
print cachelast $data18_db
if $data18_db != last_value then
return -1
endi
sql alter database db cachemodel 'both'
sql show databases
sql select * from information_schema.ins_databases
print cachelast $data18_db
if $data18_db != both then
return -1

View File

@ -35,7 +35,7 @@ endi
print =============== step2: create database
sql create database db vgroups 1
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -46,7 +46,7 @@ endi
print =============== step2: create database
sql create database db vgroups 1 replica 3
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -5,7 +5,7 @@ sql connect
print =============== create database
sql create database d1 vgroups 2
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -39,7 +39,7 @@ endi
print =============== drop database
sql drop database d1
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
@ -48,7 +48,7 @@ print =============== more databases
sql create database d2 vgroups 2
sql create database d3 vgroups 3
sql create database d4 vgroups 4
sql show databases
sql select * from information_schema.ins_databases
if $rows != 5 then
return -1
endi
@ -110,7 +110,7 @@ endi
print =============== drop database
sql drop database d2
sql drop database d3
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -152,8 +152,8 @@ print =============== restart
system sh/exec.sh -n dnode1 -s stop -x SIGKILL
system sh/exec.sh -n dnode1 -s start
print =============== show databases
sql show databases
print =============== select * from information_schema.ins_databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -11,7 +11,7 @@ sql create table t2 (ts timestamp, i int);
sql create table t3 (ts timestamp, i int);
sql create table t4 (ts timestamp, i int);
sql show databases
sql select * from information_schema.ins_databases
print rows: $rows
print $data00 $data01 $data02 $data03
print $data10 $data11 $data12 $data13
@ -43,7 +43,7 @@ sql create table t1 (ts timestamp, i int);
sql create table t2 (ts timestamp, i int);
sql create table t3 (ts timestamp, i int);
sql show databases
sql select * from information_schema.ins_databases
if $rows != 4 then
return -1
endi

View File

@ -10,7 +10,7 @@ sql create table d1.t2 (ts timestamp, i int);
sql create table d1.t3 (ts timestamp, i int);
sql create table d1.t4 (ts timestamp, i int);
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -38,7 +38,7 @@ sql create table d2.t1 (ts timestamp, i int);
sql create table d2.t2 (ts timestamp, i int);
sql create table d2.t3 (ts timestamp, i int);
sql show databases
sql select * from information_schema.ins_databases
if $rows != 4 then
return -1
endi

View File

@ -10,7 +10,7 @@ sql create table d1.t2 (ts timestamp, i int);
sql create table d1.t3 (ts timestamp, i int);
sql create table d1.t4 (ts timestamp, i int);
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -46,7 +46,7 @@ endi
print =============== drop table
sql drop table d1.t1
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -83,7 +83,7 @@ sql drop table d1.t2
sql drop table d1.t3
sql drop table d1.t4
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -16,7 +16,7 @@ $tb = $tbPrefix . $i
print =============== step1
# quorum presicion
sql create database $db vgroups 8 replica 1 duration 2 keep 10 minrows 80 maxrows 10000 wal_level 2 wal_fsync_period 1000 comp 0 cachemodel 'last_value' precision 'us'
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07 $data08 $data09
if $rows != 3 then
@ -50,14 +50,14 @@ endi
print =============== step2
sql_error create database $db
sql create database if not exists $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
print =============== step3
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
@ -67,7 +67,7 @@ sql_error drop database $db
print =============== step5
sql create database $db replica 1 duration 15 keep 1500
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07
if $data20 != $db then
return -1
@ -312,7 +312,7 @@ if $rows != 5 then
endi
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -70,7 +70,7 @@ print ============= create database with all options
print ====> create database db, with default
sql create database db
sql show databases
sql select * from information_schema.ins_databases
print rows: $rows
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $rows != 3 then
@ -133,7 +133,7 @@ sql drop database db
#print ====> BLOCKS value [3~1000, default: 6]
#sql create database db BLOCKS 3
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data9_db != 3 then
# return -1
@ -141,7 +141,7 @@ sql drop database db
#sql drop database db
#sql create database db BLOCKS 1000
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data9_db != 1000 then
# return -1
@ -153,7 +153,7 @@ sql drop database db
#print ====> CACHE value [default: 16]
#sql create database db CACHE 1
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data8_db != 1 then
# return -1
@ -161,7 +161,7 @@ sql drop database db
#sql drop database db
#sql create database db CACHE 128
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data8_db != 128 then
# return -1
@ -170,7 +170,7 @@ sql drop database db
print ====> CACHEMODEL value [0, 1, 2, 3, default: 0]
sql create database db CACHEMODEL 'last_row'
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data18_db != last_row then
return -1
@ -178,7 +178,7 @@ endi
sql drop database db
sql create database db CACHEMODEL 'last_value'
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data18_db != last_value then
return -1
@ -186,7 +186,7 @@ endi
sql drop database db
sql create database db CACHEMODEL 'both'
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data18_db != both then
return -1
@ -197,7 +197,7 @@ sql_error create database db CACHEMODEL '-1'
print ====> COMP [0 | 1 | 2, default: 2]
sql create database db COMP 1
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data13_db != 1 then
return -1
@ -205,7 +205,7 @@ endi
sql drop database db
sql create database db COMP 0
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data13_db != 0 then
return -1
@ -217,7 +217,7 @@ sql_error create database db COMP -1
#print ====> DURATION value [60m ~ min(3650d,keep), default: 10d, unit may be minut/hour/day]
#print ====> KEEP value [max(1d ~ 365000d), default: 1d, unit may be minut/hour/day]
#sql create database db DURATION 60m KEEP 60m
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data6_db != 60 then
# return -1
@ -227,7 +227,7 @@ sql_error create database db COMP -1
#endi
#sql drop database db
#sql create database db DURATION 60m KEEP 1d
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data6_db != 60 then
# return -1
@ -236,7 +236,7 @@ sql_error create database db COMP -1
# return -1
#endi
#sql create database db DURATION 3650d KEEP 365000d
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data6_db != 5256000 then
# return -1
@ -256,7 +256,7 @@ sql_error create database db COMP -1
print ====> WAL_FSYNC_PERIOD value [0 ~ 180000 ms, default: 3000]
sql create database db WAL_FSYNC_PERIOD 0
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data21_db != 0 then
return -1
@ -264,7 +264,7 @@ endi
sql drop database db
sql create database db WAL_FSYNC_PERIOD 180000
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data21_db != 180000 then
return -1
@ -275,7 +275,7 @@ sql_error create database db WAL_FSYNC_PERIOD -1
print ====> MAXROWS value [200~10000, default: 4096], MINROWS value [10~1000, default: 100]
sql create database db MAXROWS 10000 MINROWS 1000
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data11_db != 1000 then
return -1
@ -286,7 +286,7 @@ endi
sql drop database db
sql create database db MAXROWS 200 MINROWS 10
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data11_db != 10 then
return -1
@ -307,7 +307,7 @@ sql_error create database db MAXROWS 500 MINROWS 1000
print ====> PRECISION ['ms' | 'us' | 'ns', default: ms]
sql create database db PRECISION 'us'
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data14_db != us then
return -1
@ -315,7 +315,7 @@ endi
sql drop database db
sql create database db PRECISION 'ns'
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data14_db != ns then
return -1
@ -326,7 +326,7 @@ sql_error create database db PRECISION -1
print ====> QUORUM value [1 | 2, default: 1] 3.0 not support this item
#sql_error create database db QUORUM 2
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data5_db != 2 then
# return -1
@ -334,7 +334,7 @@ print ====> QUORUM value [1 | 2, default: 1] 3.0 not support this item
#sql drop database db
#sql create database db QUORUM 1
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $data5_db != 1 then
# return -1
@ -348,7 +348,7 @@ sql_error create database db QUORUM -1
print ====> REPLICA value [1 | 3, default: 1]
sql create database db REPLICA 3
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data4_db != 3 then
return -1
@ -356,7 +356,7 @@ endi
sql drop database db
sql create database db REPLICA 1
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data4_db != 1 then
return -1
@ -369,7 +369,7 @@ sql_error create database db REPLICA 4
#print ====> TTL value [1d ~ , default: 1]
#sql create database db TTL 1
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $dataXX_db != 1 then
# return -1
@ -377,7 +377,7 @@ sql_error create database db REPLICA 4
#sql drop database db
#sql create database db TTL 10
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $dataXX_db != 10 then
# return -1
@ -388,7 +388,7 @@ sql_error create database db REPLICA 4
print ====> WAL_LEVEL value [1 | 2, default: 1]
sql create database db WAL_LEVEL 2
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data20_db != 2 then
return -1
@ -396,7 +396,7 @@ endi
sql drop database db
sql create database db WAL_LEVEL 1
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data20_db != 1 then
return -1
@ -408,7 +408,7 @@ sql_error create database db WAL_LEVEL 0
print ====> VGROUPS value [1~4096, default: 2]
sql create database db VGROUPS 1
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data2_db != 1 then
return -1
@ -416,7 +416,7 @@ endi
sql drop database db
sql create database db VGROUPS 16
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
if $data2_db != 16 then
return -1
@ -428,7 +428,7 @@ sql_error create database db VGROUPS 0
print ====> SINGLE_STABLE [0 | 1, default: ]
sql create database db SINGLE_STABLE 1
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $dataXXXX_db != 1 then
# return -1
@ -436,7 +436,7 @@ print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $dat
sql drop database db
sql create database db SINGLE_STABLE 0
sql show databases
sql select * from information_schema.ins_databases
print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $dataXXXX_db != 0 then
# return -1
@ -447,7 +447,7 @@ sql_error create database db SINGLE_STABLE -1
#print ====> STREAM_MODE [0 | 1, default: ]
#sql create database db STREAM_MODE 1
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $dataXXX_db != 1 then
# return -1
@ -455,7 +455,7 @@ sql_error create database db SINGLE_STABLE -1
#sql drop database db
#sql create database db STREAM_MODE 0
#sql show databases
#sql select * from information_schema.ins_databases
#print $data0_db $data1_db $data2_db $data3_db $data4_db $data5_db $data6_db $data7_db $data8_db $data9_db $data10_db $data11_db $data12_db $data13_db $data14_db $data15_db $data16_db $data17_db
#if $dataXXX_db != 0 then
# return -1

View File

@ -24,7 +24,7 @@ while $i < 30
endw
print ======== step2
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
@ -89,7 +89,7 @@ while $i < 10
endw
print ======== step2
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -57,7 +57,7 @@ endw
print ======== step2
sql drop database db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -41,7 +41,7 @@ re-create1:
sql create database d1 vgroups 2 -x re-create1
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -80,7 +80,7 @@ re-create2:
sql create database d1 vgroups 5 -x re-create2
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -40,7 +40,7 @@ $num1 = $rows + 40
print ======== step3 alter db
sql alter database keepdb keep 60
sql flush database keepdb
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02 $data03 $data04 $data05 $data06 $data07
if $data22 != 2 then
return -1
@ -82,7 +82,7 @@ endi
print ======== step6 alter db
sql alter database keepdb keep 30
sql show databases
sql select * from information_schema.ins_databases
if $data22 != 2 then
return -1
endi

View File

@ -10,33 +10,33 @@ sql create database -x step1
return -1
step1:
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
print =============== step2
sql create database a
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
sql drop database a
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
print =============== step3
sql create database a12345678
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
sql drop database a12345678
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
@ -45,7 +45,7 @@ print =============== step4
sql create database a012345678901201234567890120123456789012a012345678901201234567890120123456789012 -x step4
return -1
step4:
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
@ -53,7 +53,7 @@ endi
print =============== step5
sql create database a;1
sql drop database a
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
@ -63,7 +63,7 @@ sql create database a'1 -x step6
return -1
step6:
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
@ -72,7 +72,7 @@ print =============== step7
sql create database (a) -x step7
return -1
step7:
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
@ -81,7 +81,7 @@ print =============== step8
sql create database a.1 -x step8
return -1
step8:
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -5,7 +5,7 @@ sql connect
print =============== step2
sql create database db
sql show databases
sql select * from information_schema.ins_databases
print $rows $data07
if $rows != 3 then
@ -68,7 +68,7 @@ sql reset query cache
print =============== step7
sql create database db
sql show databases
sql select * from information_schema.ins_databases
print $rows $data07
if $rows != 3 then

View File

@ -8,7 +8,7 @@ sql connect
print =============== create database
sql create database d1 vgroups 2
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -20,9 +20,9 @@ sleep 200
system rm -rf ../../sim/dnode1/log
system sh/exec.sh -n dnode1 -s start
print =============== show databases
print =============== select * from information_schema.ins_databases
sql create database d2 vgroups 6
sql show databases
sql select * from information_schema.ins_databases
if $rows != 4 then
return -1
endi

View File

@ -82,7 +82,7 @@ print =============== create database
sql create database d1 vgroups 4;
sql create database d2;
sql show databases
sql select * from information_schema.ins_databases
if $rows != 4 then
return -1
endi

View File

@ -288,7 +288,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -511,7 +511,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -701,7 +701,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -824,7 +824,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -979,7 +979,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -151,7 +151,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -65,7 +65,7 @@ sql_error select count(tbcol), avg(tbcol), sum(tbcol), min(tbcol), max(tbcol), f
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -150,7 +150,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -149,7 +149,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -150,7 +150,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -150,7 +150,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -208,7 +208,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -150,7 +150,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -150,7 +150,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -155,7 +155,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -7,7 +7,7 @@ sql connect
print =============== create database
sql create database `database`
sql create database `DataBase`
sql show databases
sql select * from information_schema.ins_databases
print rows: $rows
print $data00 $data01
print $data10 $data11
@ -184,7 +184,7 @@ print =============== stop and restart taosd
system sh/exec.sh -n dnode1 -s stop -x SIGINT
system sh/exec.sh -n dnode1 -s start
sql show databases
sql select * from information_schema.ins_databases
print rows: $rows
print $data00 $data01
print $data10 $data11

View File

@ -5,7 +5,7 @@ sql connect
print =============== create database
sql create database d0
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -5,7 +5,7 @@ sql connect
print =============== create database
sql create database d1
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -5,7 +5,7 @@ sql connect
print =============== create database
sql create database db duration 300 keep 365000d,365000d,365000d
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -5,7 +5,7 @@ sql connect
print =============== create database
sql create database d0
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -184,7 +184,7 @@ endi
clear:
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -169,7 +169,7 @@ endi
clear:
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -190,7 +190,7 @@ endi
clear:
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -161,7 +161,7 @@ if $rows != 0 then
endi
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -189,7 +189,7 @@ endi
clear:
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -36,7 +36,7 @@ if $rows < $N then
endi
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -74,7 +74,7 @@ if $rows != 2 then
endi
sql create database db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -100,7 +100,7 @@ if $rows != 2 then
return -1
endi
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi

View File

@ -36,7 +36,7 @@ sql_error alter database $db keep 20,19,18
sql_error alter database $db keep 20,20,20,20
sql_error alter database $db keep 365001,365001,365001
sql alter database $db keep 21
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -44,7 +44,7 @@ if $data27 != 30240m,30240m,30240m then
return -1
endi
sql alter database $db keep 11,12
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -52,7 +52,7 @@ if $data27 != 15840m,17280m,17280m then
return -1
endi
sql alter database $db keep 20,20,20
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -60,7 +60,7 @@ if $data27 != 28800m,28800m,28800m then
return -1
endi
sql alter database $db keep 10,10,10
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -68,7 +68,7 @@ if $data27 != 14400m,14400m,14400m then
return -1
endi
sql alter database $db keep 10,10,11
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -76,7 +76,7 @@ if $data27 != 14400m,14400m,15840m then
return -1
endi
sql alter database $db keep 11,12,13
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -84,7 +84,7 @@ if $data27 != 15840m,17280m,18720m then
return -1
endi
sql alter database $db keep 365000,365000,365000
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -310,7 +310,7 @@ sql_error alter table mt add column c1 int
sql_error alter table mt drop column c9
#sql drop database $db
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 0 then
# return -1
#endi

View File

@ -125,7 +125,7 @@ if $rows != 3 then
endi
#sql drop database $db
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 0 then
# return -1
#endi

View File

@ -19,7 +19,7 @@ $mt = $mtPrefix . $i
sql drop database if exists $db
sql create database $db duration 10 keep 20
sql use $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -45,7 +45,7 @@ sql_error alter database $db keep 20,20,20,20
sql_error alter database $db keep 365001,365001,365001
sql_error alter database $db keep 365001
sql_error alter database $db keep 20
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -53,7 +53,7 @@ if $data27 != 28800m,28800m,28800m then
return -1
endi
sql alter database $db keep 10
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -61,7 +61,7 @@ if $data27 != 14400m,14400m,14400m then
return -1
endi
sql alter database $db keep 11
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -69,7 +69,7 @@ if $data27 != 15840m,15840m,15840m then
return -1
endi
sql alter database $db keep 13
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -77,7 +77,7 @@ if $data27 != 18720m,18720m,18720m then
return -1
endi
sql alter database $db keep 365000
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -297,7 +297,7 @@ sql_error alter table mt add column c1 int
sql_error alter table mt drop column c9
#sql drop database $db
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 0 then
# return -1
#endi

View File

@ -289,7 +289,7 @@ if $rows != 1 then
endi
#sql drop database $db
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 0 then
# return -1
#endi

View File

@ -21,7 +21,7 @@ $mt = $mtPrefix . $i
sql_error createdatabase $db
sql create database $db
sql use $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
@ -36,7 +36,7 @@ print =========== create_db.sim case1: case insensitivity test
sql_error CREATEDATABASE $db
sql CREATE DATABASE $db
sql use $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
@ -64,7 +64,7 @@ $CN_db3 = db数据库1
sql_error create database $CN_db1
sql_error create database $CN_db2
sql_error create database $CN_db3
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 3 then
# return -1
#endi
@ -86,7 +86,7 @@ print case_chinese_char_in_db_name test passed
print create_db.sim case4: db_already_exists
sql create database db0
sql create database db0
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -108,7 +108,7 @@ $wal = 1 # valid value is 1, 2
$comp = 1 # max=32, automatically trimmed when exceeding
sql create database $db replica $replica duration $duration keep $keep maxrows $rows_db wal_level $wal comp $comp
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -151,7 +151,7 @@ sql_error create database $db keep 8
sql_error create database $db keep 12,11
sql_error create database $db keep 365001,365001,365001
sql create database dbk0 keep 19
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -160,7 +160,7 @@ if $data27 != 27360m,27360m,27360m then
endi
sql drop database dbk0
sql create database dbka keep 19,20
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -170,7 +170,7 @@ endi
sql drop database dbka
sql create database dbk1 keep 11,11,11
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -179,7 +179,7 @@ if $data27 != 15840m,15840m,15840m then
endi
sql drop database dbk1
sql create database dbk2 keep 11,12,13
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -188,7 +188,7 @@ if $data27 != 15840m,17280m,18720m then
endi
sql drop database dbk2
sql create database dbk3 keep 11,11,13
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -197,7 +197,7 @@ if $data27 != 15840m,15840m,18720m then
endi
sql drop database dbk3
sql create database dbk4 keep 11,13,13
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -226,17 +226,17 @@ sql_error create database $db ctime 40961
# wal {0, 2}
sql_error create database testwal wal_level 0
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi
sql create database testwal wal_level 1
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
sql show databases
sql select * from information_schema.ins_databases
print wallevel $data20_testwal
if $data20_testwal != 1 then
return -1
@ -244,7 +244,7 @@ endi
sql drop database testwal
sql create database testwal wal_level 2
sql show databases
sql select * from information_schema.ins_databases
if $rows != 3 then
return -1
endi
@ -262,7 +262,7 @@ sql_error create database $db comp -1
sql_error create database $db comp 3
sql_error drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -240,7 +240,7 @@ $mt2 = mt2
print chinese_char_in_metrics test passed
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -180,7 +180,7 @@ sql_error create table $tbname65 (ts timestamp, col int)
print table_already_exists test passed
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -75,7 +75,7 @@ endi
### select distinct
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

View File

@ -1061,7 +1061,7 @@ endi
print =============== clear
#sql drop database $db
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 0 then
# return -1
#endi

View File

@ -431,7 +431,7 @@ endi
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 0 then
return -1
endi

View File

@ -844,7 +844,7 @@ endi
#print =============== clear
#sql drop database $db
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 0 then
# return -1
#endi

View File

@ -6,7 +6,7 @@ sql connect
$dbNamme = d0
print =============== create database
sql create database $dbNamme vgroups 1
sql show databases
sql select * from information_schema.ins_databases
print $data00 $data01 $data02
if $rows != 3 then
return -1

View File

@ -41,7 +41,7 @@ $ts = $ts0 + $delta
$ts = $ts + 1
sql import into $tb values ( $ts , -2, -2, -2, -2, -2)
sql show databases
sql select * from information_schema.ins_databases
sql select count(*) from $tb
$res = $rowNum + 2

View File

@ -221,7 +221,7 @@ if $rows != 1 then
endi
#sql drop database $db
#sql show databases
#sql select * from information_schema.ins_databases
#if $rows != 0 then
# return -1
#endi

View File

@ -50,7 +50,7 @@ while $x < $rowNum
$x = $x + 1
endw
print ====== tables created
sql show databases
sql select * from information_schema.ins_databases
print ================== restart server to commit data into disk
system sh/exec.sh -n dnode1 -s stop -x SIGINT

View File

@ -305,7 +305,7 @@ endi
# case: query_with_wildcard
# print =============== clear
# sql drop database $db
# sql show databases
# sql select * from information_schema.ins_databases
# if $rows != 0 then
# return -1
# endi

View File

@ -100,7 +100,7 @@ sql select count(*) from $mt interval(100000000b) sliding(100000000b)
print =============== clear
sql drop database $db
sql show databases
sql select * from information_schema.ins_databases
if $rows != 2 then
return -1
endi

Some files were not shown because too many files have changed in this diff Show More