Skip to content

Commit 21ee901

Browse files
committed
fix
1 parent 9135ce6 commit 21ee901

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -311,27 +311,27 @@ private TSStatus checkPermission(final ConfigPhysicalPlan plan) throws IOExcepti
311311
database = ((DatabaseSchemaPlan) plan).getSchema().getName();
312312
if (PathUtils.isTableModelDatabase(database)) {
313313
status = checkDatabaseStatus(userEntity, PrivilegeType.CREATE, database);
314-
if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
315-
return checkGlobalStatus(userEntity, PrivilegeType.SYSTEM, database, true);
316-
}
314+
return status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()
315+
? status
316+
: checkGlobalStatus(userEntity, PrivilegeType.SYSTEM, database, true);
317317
}
318318
return checkGlobalStatus(userEntity, PrivilegeType.MANAGE_DATABASE, database, true);
319319
case AlterDatabase:
320320
database = ((DatabaseSchemaPlan) plan).getSchema().getName();
321321
if (PathUtils.isTableModelDatabase(database)) {
322322
status = checkDatabaseStatus(userEntity, PrivilegeType.ALTER, database);
323-
if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
324-
return checkGlobalStatus(userEntity, PrivilegeType.SYSTEM, database, true);
325-
}
323+
return status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()
324+
? status
325+
: checkGlobalStatus(userEntity, PrivilegeType.SYSTEM, database, true);
326326
}
327327
return checkGlobalStatus(userEntity, PrivilegeType.MANAGE_DATABASE, database, true);
328328
case DeleteDatabase:
329329
database = ((DeleteDatabasePlan) plan).getName();
330330
if (PathUtils.isTableModelDatabase(database)) {
331331
status = checkDatabaseStatus(userEntity, PrivilegeType.DELETE, database);
332-
if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
333-
return checkGlobalStatus(userEntity, PrivilegeType.SYSTEM, database, true);
334-
}
332+
return status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()
333+
? status
334+
: checkGlobalStatus(userEntity, PrivilegeType.SYSTEM, database, true);
335335
}
336336
return checkGlobalStatus(userEntity, PrivilegeType.MANAGE_DATABASE, database, true);
337337
case ExtendSchemaTemplate:

0 commit comments

Comments
 (0)