This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new b8aee3d7556 Refactor DropDatabaseProxyBackendHandler (#36811)
b8aee3d7556 is described below
commit b8aee3d755659fa66b1b8aee8e7c1faf94a0f9f6
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Oct 7 23:30:12 2025 +0800
Refactor DropDatabaseProxyBackendHandler (#36811)
---
.../backend/handler/database/type/DropDatabaseProxyBackendHandler.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandler.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandler.java
index 808c223029a..5fd05e09751 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandler.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/database/type/DropDatabaseProxyBackendHandler.java
@@ -64,7 +64,8 @@ public final class DropDatabaseProxyBackendHandler implements
ProxyBackendHandle
private void check(final DropDatabaseStatement sqlStatement, final Grantee
grantee) {
String databaseName = sqlStatement.getDatabaseName().toLowerCase();
AuthorityRule authorityRule =
ProxyContext.getInstance().getContextManager().getMetaDataContexts().getMetaData().getGlobalRuleMetaData().getSingleRule(AuthorityRule.class);
- ShardingSpherePreconditions.checkState(new
AuthorityChecker(authorityRule, grantee).isAuthorized(databaseName), () -> new
UnknownDatabaseException(databaseName));
+ AuthorityChecker authorityChecker = new
AuthorityChecker(authorityRule, grantee);
+
ShardingSpherePreconditions.checkState(authorityChecker.isAuthorized(databaseName),
() -> new UnknownDatabaseException(databaseName));
ShardingSpherePreconditions.checkState(sqlStatement.isIfExists() ||
ProxyContext.getInstance().databaseExists(databaseName), () -> new
DatabaseDropNotExistsException(databaseName));
}