commit
be99073f3f
|
@ -1807,7 +1807,7 @@ int tscBuildCreateDbMsg(SSqlObj *pSql) {
|
||||||
pMsg += sizeof(SMgmtHead);
|
pMsg += sizeof(SMgmtHead);
|
||||||
|
|
||||||
pCreateDbMsg = (SCreateDbMsg *)pMsg;
|
pCreateDbMsg = (SCreateDbMsg *)pMsg;
|
||||||
strncpy(pCreateDbMsg->db, pMeterMetaInfo->name, tListLen(pCreateDbMsg->db));
|
(void)extractDBName(pMeterMetaInfo->name, pCreateDbMsg->db); // only send db name, then recombining db name + acctId on the mgmt
|
||||||
pMsg += sizeof(SCreateDbMsg);
|
pMsg += sizeof(SCreateDbMsg);
|
||||||
|
|
||||||
msgLen = pMsg - pStart;
|
msgLen = pMsg - pStart;
|
||||||
|
|
|
@ -256,7 +256,7 @@ int mgmtCreateDb(SAcctObj *pAcct, SCreateDbMsg *pCreate) {
|
||||||
|
|
||||||
pDb = malloc(sizeof(SDbObj));
|
pDb = malloc(sizeof(SDbObj));
|
||||||
memset(pDb, 0, sizeof(SDbObj));
|
memset(pDb, 0, sizeof(SDbObj));
|
||||||
strcpy(pDb->name, pCreate->db);
|
sprintf(pDb->name, "%d.%s", pAcct->acctId, pCreate->db); // set fullname
|
||||||
strcpy(pCreate->acct, pAcct->user);
|
strcpy(pCreate->acct, pAcct->user);
|
||||||
pDb->createdTime = taosGetTimestampMs();
|
pDb->createdTime = taosGetTimestampMs();
|
||||||
pDb->cfg = *pCreate;
|
pDb->cfg = *pCreate;
|
||||||
|
|
Loading…
Reference in New Issue