diff --git a/src/client/src/tscSQLParser.c b/src/client/src/tscSQLParser.c index 7c9d85491bb679a002027828841899c7698cccda..97875a5bb3865d3959a1a794f704a3c52d68c7dc 100644 --- a/src/client/src/tscSQLParser.c +++ b/src/client/src/tscSQLParser.c @@ -282,6 +282,7 @@ int32_t tscToSQLCmd(SSqlObj* pSql, struct SSqlInfo* pInfo) { const char* msg2 = "name too long"; SCreateDBInfo* pCreateDB = &(pInfo->pDCLInfo->dbOpt); + pCmd->existsCheck = pInfo->pDCLInfo->existsCheck; if (tscValidateName(&pCreateDB->dbname) != TSDB_CODE_SUCCESS) { return invalidSqlErrMsg(tscGetErrorMsgPayload(pCmd), msg1); } diff --git a/src/client/src/tscSQLParserImpl.c b/src/client/src/tscSQLParserImpl.c index 52a68a9a16670a6cacd7ac01b36503a629b849f3..1bd43fe4903ac86d9bc2ab255d6d65b04509e779 100644 --- a/src/client/src/tscSQLParserImpl.c +++ b/src/client/src/tscSQLParserImpl.c @@ -815,6 +815,7 @@ void setCreateDBSQL(SSqlInfo *pInfo, int32_t type, SSQLToken *pToken, SCreateDBI pInfo->pDCLInfo->dbOpt.dbname = *pToken; tTokenListAppend(pInfo->pDCLInfo, pIgExists); + pInfo->pDCLInfo->existsCheck = (pIgExists->n == 1); } void setCreateAcctSQL(SSqlInfo *pInfo, int32_t type, SSQLToken *pName, SSQLToken *pPwd, SCreateAcctSQL *pAcctInfo) {