Fix sharding sql rewrite error (#29089)

apache · Nov 20, 2023 · e9dcbc5 · e9dcbc5
1 parent be4bf84
commit e9dcbc5
Showing 1 changed file with 0 additions and 13 deletions.
diff --git a/...rg/apache/shardingsphere/sharding/rewrite/context/ShardingSQLRewriteContextDecorator.java b/...rg/apache/shardingsphere/sharding/rewrite/context/ShardingSQLRewriteContextDecorator.java
@@ -18,7 +18,6 @@
 package org.apache.shardingsphere.sharding.rewrite.context;
 
 import lombok.Setter;
-import org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
 import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
 import org.apache.shardingsphere.infra.rewrite.context.SQLRewriteContext;
 import org.apache.shardingsphere.infra.rewrite.context.SQLRewriteContextDecorator;
@@ -39,9 +38,6 @@ public final class ShardingSQLRewriteContextDecorator implements SQLRewriteConte
 
     @Override
     public void decorate(final ShardingRule shardingRule, final ConfigurationProperties props, final SQLRewriteContext sqlRewriteContext, final RouteContext routeContext) {
-        if (!containsShardingTable(shardingRule, sqlRewriteContext.getSqlStatementContext())) {
-            return;
-        }
         if (!sqlRewriteContext.getParameters().isEmpty()) {
             Collection<ParameterRewriter> parameterRewriters =
                     new ShardingParameterRewriterBuilder(shardingRule, routeContext, sqlRewriteContext.getDatabase().getSchemas(), sqlRewriteContext.getSqlStatementContext()).getParameterRewriters();
@@ -50,15 +46,6 @@ public void decorate(final ShardingRule shardingRule, final ConfigurationPropert
         sqlRewriteContext.addSQLTokenGenerators(new ShardingTokenGenerateBuilder(shardingRule, routeContext, sqlRewriteContext.getSqlStatementContext()).getSQLTokenGenerators());
     }
 
-    private boolean containsShardingTable(final ShardingRule shardingRule, final SQLStatementContext sqlStatementContext) {
-        for (String each : sqlStatementContext.getTablesContext().getTableNames()) {
-            if (shardingRule.findTableRule(each).isPresent()) {
-                return true;
-            }
-        }
-        return false;
-    }
-
     private void rewriteParameters(final SQLRewriteContext sqlRewriteContext, final Collection<ParameterRewriter> parameterRewriters) {
         for (ParameterRewriter each : parameterRewriters) {
             each.rewrite(sqlRewriteContext.getParameterBuilder(), sqlRewriteContext.getSqlStatementContext(), sqlRewriteContext.getParameters());