test: add test case for create index
This commit is contained in:
parent
6bac747ab9
commit
81d8b9b98b
|
@ -6930,10 +6930,11 @@ static int32_t translateCreateFullTextIndex(STranslateContext* pCxt, SCreateInde
|
||||||
}
|
}
|
||||||
|
|
||||||
static int32_t translateCreateNormalIndex(STranslateContext* pCxt, SCreateIndexStmt* pStmt) {
|
static int32_t translateCreateNormalIndex(STranslateContext* pCxt, SCreateIndexStmt* pStmt) {
|
||||||
|
int32_t code = 0;
|
||||||
SName name;
|
SName name;
|
||||||
STableMeta* pMeta = NULL;
|
STableMeta* pMeta = NULL;
|
||||||
int32_t code =
|
|
||||||
getTargetMeta(pCxt, toName(pCxt->pParseCxt->acctId, pStmt->dbName, pStmt->tableName, &name), &pMeta, false);
|
code = getTargetMeta(pCxt, toName(pCxt->pParseCxt->acctId, pStmt->dbName, pStmt->tableName, &name), &pMeta, false);
|
||||||
if (code) {
|
if (code) {
|
||||||
taosMemoryFree(pMeta);
|
taosMemoryFree(pMeta);
|
||||||
return code;
|
return code;
|
||||||
|
@ -6955,10 +6956,6 @@ static int32_t translateCreateNormalIndex(STranslateContext* pCxt, SCreateIndexS
|
||||||
taosMemoryFree(pMeta);
|
taosMemoryFree(pMeta);
|
||||||
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_INVALID_TAG_NAME, ((SColumnNode*)pNode)->colName);
|
return generateSyntaxErrMsg(&pCxt->msgBuf, TSDB_CODE_PAR_INVALID_TAG_NAME, ((SColumnNode*)pNode)->colName);
|
||||||
}
|
}
|
||||||
if (IS_IDX_ON(pSchema)) {
|
|
||||||
code = TSDB_CODE_MND_TAG_INDEX_ALREADY_EXIST;
|
|
||||||
goto _exit;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
SCreateTagIndexReq createTagIdxReq = {0};
|
SCreateTagIndexReq createTagIdxReq = {0};
|
||||||
|
@ -6966,7 +6963,7 @@ static int32_t translateCreateNormalIndex(STranslateContext* pCxt, SCreateIndexS
|
||||||
if (TSDB_CODE_SUCCESS == code) {
|
if (TSDB_CODE_SUCCESS == code) {
|
||||||
code = buildCmdMsg(pCxt, TDMT_MND_CREATE_INDEX, (FSerializeFunc)tSerializeSCreateTagIdxReq, &createTagIdxReq);
|
code = buildCmdMsg(pCxt, TDMT_MND_CREATE_INDEX, (FSerializeFunc)tSerializeSCreateTagIdxReq, &createTagIdxReq);
|
||||||
}
|
}
|
||||||
_exit:
|
_exit:
|
||||||
taosMemoryFree(pMeta);
|
taosMemoryFree(pMeta);
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
|
@ -88,6 +88,13 @@ class TDTestCase:
|
||||||
|
|
||||||
tdLog.info(f" create {count} child tables ok.")
|
tdLog.info(f" create {count} child tables ok.")
|
||||||
|
|
||||||
|
def create_tagidx_check(self, stbname):
|
||||||
|
err_dict = {"NULL","",",","\"","\"\"","undef","t1,t2","t12,t12"}
|
||||||
|
for errs in err_dict:
|
||||||
|
sql = (f'create index idx_err_check on {stbname} (%s)'% (errs))
|
||||||
|
tdLog.info(f' sql={sql}')
|
||||||
|
tdSql.error(f'{sql}')
|
||||||
|
tdLog.info(f' create tagidx check ok.')
|
||||||
|
|
||||||
# create stable and child tables
|
# create stable and child tables
|
||||||
def create_tagidx(self, stbname):
|
def create_tagidx(self, stbname):
|
||||||
|
@ -231,6 +238,7 @@ class TDTestCase:
|
||||||
count = 1000
|
count = 1000
|
||||||
# do
|
# do
|
||||||
self.create_table(stable, tbname, count)
|
self.create_table(stable, tbname, count)
|
||||||
|
self.create_tagidx_check(stable)
|
||||||
self.create_tagidx(stable)
|
self.create_tagidx(stable)
|
||||||
self.insert_data(tbname)
|
self.insert_data(tbname)
|
||||||
self.show_tagidx(stable)
|
self.show_tagidx(stable)
|
||||||
|
|
Loading…
Reference in New Issue