alter user type to str
This commit is contained in:
parent
bec05f2677
commit
b9f77798a2
|
@ -1185,9 +1185,9 @@ static int32_t mndProcessCreateStbReq(SRpcMsg *pReq) {
|
||||||
createReq.watermark1, createReq.watermark2);
|
createReq.watermark1, createReq.watermark2);
|
||||||
|
|
||||||
SName name = {0};
|
SName name = {0};
|
||||||
tNameFromString(&name, pDb->name, T_NAME_ACCT | T_NAME_DB);
|
tNameFromString(&name, createReq.name, T_NAME_ACCT | T_NAME_DB | T_NAME_TABLE);
|
||||||
|
|
||||||
auditRecord(pReq, pMnode->clusterId, "createStb", name.dbname, createReq.name, detail);
|
auditRecord(pReq, pMnode->clusterId, "createStb", name.dbname, name.tname, detail);
|
||||||
|
|
||||||
_OVER:
|
_OVER:
|
||||||
if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) {
|
if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) {
|
||||||
|
|
|
@ -791,6 +791,67 @@ static int32_t mndRemoveTablePriviledge(SMnode *pMnode, SHashObj *hash, SHashObj
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static char* mndUserAuditTypeStr(int32_t type){
|
||||||
|
if(type == TSDB_ALTER_USER_PASSWD){
|
||||||
|
return "changePassword";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_SUPERUSER){
|
||||||
|
return "changeSuperUser";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ADD_READ_DB){
|
||||||
|
return "addReadToDB";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ADD_READ_DB){
|
||||||
|
return "addReadToDB";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_REMOVE_READ_DB){
|
||||||
|
return "removeReadFromDB";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ADD_WRITE_DB){
|
||||||
|
return "addWriteToDB";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_REMOVE_WRITE_DB){
|
||||||
|
return "removeWriteFromDB";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ADD_ALL_DB){
|
||||||
|
return "addToAllDB";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_REMOVE_ALL_DB){
|
||||||
|
return "removeFromAllDB";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ENABLE){
|
||||||
|
return "enableUser";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_SYSINFO){
|
||||||
|
return "userSysInfo";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ADD_SUBSCRIBE_TOPIC){
|
||||||
|
return "addSubscribeTopic";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_REMOVE_SUBSCRIBE_TOPIC){
|
||||||
|
return "removeSubscribeTopic";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ADD_READ_TABLE){
|
||||||
|
return "addReadToTable";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_REMOVE_READ_TABLE){
|
||||||
|
return "removeReadFromTable";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ADD_WRITE_TABLE){
|
||||||
|
return "addWriteToTable";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_REMOVE_WRITE_TABLE){
|
||||||
|
return "removeWriteFromTable";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_ADD_ALL_TABLE){
|
||||||
|
return "addToAllTable";
|
||||||
|
}
|
||||||
|
if(type == TSDB_ALTER_USER_REMOVE_ALL_TABLE){
|
||||||
|
return "removeFromAllTable";
|
||||||
|
}
|
||||||
|
return "error";
|
||||||
|
}
|
||||||
|
|
||||||
static int32_t mndProcessAlterUserReq(SRpcMsg *pReq) {
|
static int32_t mndProcessAlterUserReq(SRpcMsg *pReq) {
|
||||||
SMnode *pMnode = pReq->info.node;
|
SMnode *pMnode = pReq->info.node;
|
||||||
SSdb *pSdb = pMnode->pSdb;
|
SSdb *pSdb = pMnode->pSdb;
|
||||||
|
@ -978,8 +1039,8 @@ static int32_t mndProcessAlterUserReq(SRpcMsg *pReq) {
|
||||||
if (code == 0) code = TSDB_CODE_ACTION_IN_PROGRESS;
|
if (code == 0) code = TSDB_CODE_ACTION_IN_PROGRESS;
|
||||||
|
|
||||||
char detail[1000] = {0};
|
char detail[1000] = {0};
|
||||||
sprintf(detail, "alterType:%d, enable:%d, superUser:%d, sysInfo:%d, tabName:%s",
|
sprintf(detail, "alterType:%s, enable:%d, superUser:%d, sysInfo:%d, tabName:%s",
|
||||||
alterReq.alterType, alterReq.enable, alterReq.superUser, alterReq.sysInfo, alterReq.tabName);
|
mndUserAuditTypeStr(alterReq.alterType), alterReq.enable, alterReq.superUser, alterReq.sysInfo, alterReq.tabName);
|
||||||
|
|
||||||
if(alterReq.alterType == TSDB_ALTER_USER_PASSWD){
|
if(alterReq.alterType == TSDB_ALTER_USER_PASSWD){
|
||||||
auditRecord(pReq, pMnode->clusterId, "changePassword", alterReq.user, "", detail);
|
auditRecord(pReq, pMnode->clusterId, "changePassword", alterReq.user, "", detail);
|
||||||
|
|
Loading…
Reference in New Issue