Commit 7b2f4d88 authored by terrymanu's avatar terrymanu
Browse files

for #2084, add ShardingSubqueryPredicateFiller.getShardingOrPredicateFiller()

parent 7dfeb1a4

sharding-core/sharding-core-parse/sharding-core-parse-common/src/main/java/org/apache/shardingsphere/core/parse/antlr/filler/sharding/dml/select/ShardingSubqueryPredicateFiller.java

+8 −3
Original line number Diff line number Diff line
@@ -44,11 +44,16 @@ public final class ShardingSubqueryPredicateFiller implements SQLSegmentFiller<S 
    @Override

    public void fill(final SubqueryPredicateSegment sqlSegment, final SQLStatement sqlStatement) {

        SelectStatement selectStatement = (SelectStatement) sqlStatement;

        ShardingOrPredicateFiller shardingOrPredicateFiller = new ShardingOrPredicateFiller();

        shardingOrPredicateFiller.setShardingRule(shardingRule);

        shardingOrPredicateFiller.setShardingTableMetaData(shardingTableMetaData);

        ShardingOrPredicateFiller shardingOrPredicateFiller = getShardingOrPredicateFiller();

        for (OrPredicateSegment each : sqlSegment.getOrPredicates()) {

            selectStatement.getSubqueryConditions().add(shardingOrPredicateFiller.buildCondition(each, sqlStatement));

        }

    }

    

    private ShardingOrPredicateFiller getShardingOrPredicateFiller() {

        ShardingOrPredicateFiller result = new ShardingOrPredicateFiller();

        result.setShardingRule(shardingRule);

        result.setShardingTableMetaData(shardingTableMetaData);

        return result;

    }

}