[shardingsphere] branch master updated: Release lock supports different nodes (#16521)

[jianglongtao]

This is an automated email from the ASF dual-hosted git repository.

jianglongtao 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 8b99550  Release lock supports different nodes (#16521)
8b99550 is described below

commit 8b995509e14c29658979c3e2a3558a72ee6835e5
Author: gin <jacky7...@163.com>
AuthorDate: Thu Mar 31 19:11:21 2022 +0800

    Release lock supports different nodes (#16521)
---
 .../proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java
index 6c8e29a..b1d34aa 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java
@@ -20,6 +20,7 @@ package org.apache.shardingsphere.proxy.backend.text.distsql;
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
 import org.apache.shardingsphere.distsql.parser.statement.DistSQLStatement;
+import 
org.apache.shardingsphere.distsql.parser.statement.ral.CommonDistSQLStatement;
 import 
org.apache.shardingsphere.distsql.parser.statement.ral.QueryableRALStatement;
 import org.apache.shardingsphere.distsql.parser.statement.ral.RALStatement;
 import 
org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
@@ -61,7 +62,8 @@ public final class DistSQLBackendHandlerFactory {
             return RDLBackendHandlerFactory.newInstance(databaseType, 
(RDLStatement) sqlStatement, connectionSession);
         }
         if (sqlStatement instanceof RALStatement) {
-            if (sqlStatement instanceof QueryableRALStatement || sqlStatement 
instanceof QueryableScalingRALStatement || sqlStatement instanceof 
UpdatableScalingRALStatement) {
+            if (sqlStatement instanceof CommonDistSQLStatement || sqlStatement 
instanceof QueryableRALStatement || sqlStatement instanceof 
QueryableScalingRALStatement
+                    || sqlStatement instanceof UpdatableScalingRALStatement) {
                 return RALBackendHandlerFactory.newInstance(databaseType, 
(RALStatement) sqlStatement, connectionSession);
             }
             checkLockedSchema(connectionSession);