You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/10/17 11:52:32 UTC
[iotdb] 01/01: Make show version can be used by anyone
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch ShowVersion
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e9544a1e445ded44074a4ea2668b734a66dcc83a
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Oct 17 19:52:18 2023 +0800
Make show version can be used by anyone
---
.../main/java/org/apache/iotdb/db/auth/AuthorityChecker.java | 12 +++++++-----
.../queryengine/plan/statement/sys/ShowVersionStatement.java | 7 +++----
2 files changed, 10 insertions(+), 9 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/AuthorityChecker.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/AuthorityChecker.java
index d2504863776..5fe9f9fd613 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/AuthorityChecker.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/AuthorityChecker.java
@@ -57,6 +57,8 @@ public class AuthorityChecker {
public static final String SUPER_USER = CommonDescriptor.getInstance().getConfig().getAdminName();
+ public static final TSStatus SUCCEED = new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
+
private static final String NO_PERMISSION_PROMOTION =
"No permissions for this operation, please add privilege ";
@@ -112,19 +114,19 @@ public class AuthorityChecker {
public static TSStatus getOptTSStatus(boolean hasGrantOpt, String errMsg) {
return hasGrantOpt
- ? new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode())
+ ? SUCCEED
: new TSStatus(TSStatusCode.NOT_HAS_PRIVILEGE_GRANTOPT.getStatusCode()).setMessage(errMsg);
}
public static TSStatus getTSStatus(boolean hasPermission, String errMsg) {
return hasPermission
- ? new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode())
+ ? SUCCEED
: new TSStatus(TSStatusCode.NO_PERMISSION.getStatusCode()).setMessage(errMsg);
}
public static TSStatus getTSStatus(boolean hasPermission, PrivilegeType neededPrivilege) {
return hasPermission
- ? new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode())
+ ? SUCCEED
: new TSStatus(TSStatusCode.NO_PERMISSION.getStatusCode())
.setMessage(NO_PERMISSION_PROMOTION + neededPrivilege);
}
@@ -132,7 +134,7 @@ public class AuthorityChecker {
public static TSStatus getTSStatus(
boolean hasPermission, PartialPath path, PrivilegeType neededPrivilege) {
return hasPermission
- ? new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode())
+ ? SUCCEED
: new TSStatus(TSStatusCode.NO_PERMISSION.getStatusCode())
.setMessage(NO_PERMISSION_PROMOTION + neededPrivilege + " on " + path);
}
@@ -142,7 +144,7 @@ public class AuthorityChecker {
List<PartialPath> pathList,
PrivilegeType neededPrivilege) {
if (noPermissionIndexList == null || noPermissionIndexList.isEmpty()) {
- return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
+ return SUCCEED;
}
StringBuilder prompt = new StringBuilder(NO_PERMISSION_PROMOTION);
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ShowVersionStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ShowVersionStatement.java
index f9537118e5a..69825844311 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ShowVersionStatement.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ShowVersionStatement.java
@@ -20,10 +20,11 @@
package org.apache.iotdb.db.queryengine.plan.statement.sys;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
-import org.apache.iotdb.db.auth.AuthorityChecker;
import org.apache.iotdb.db.queryengine.plan.statement.StatementVisitor;
import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowStatement;
+import static org.apache.iotdb.db.auth.AuthorityChecker.SUCCEED;
+
public class ShowVersionStatement extends ShowStatement {
public ShowVersionStatement() {
@@ -37,8 +38,6 @@ public class ShowVersionStatement extends ShowStatement {
@Override
public TSStatus checkPermissionBeforeProcess(String userName) {
- return AuthorityChecker.getTSStatus(
- AuthorityChecker.SUPER_USER.equals(userName),
- "Only the admin user can perform this operation");
+ return SUCCEED;
}
}