diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/builder/BaseHandlerBuilder.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/builder/BaseHandlerBuilder.java index cf27f2fe3..022910765 100644 --- a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/builder/BaseHandlerBuilder.java +++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/builder/BaseHandlerBuilder.java @@ -10,7 +10,7 @@ import com.actiontech.dble.backend.mysql.nio.handler.builder.sqlvisitor.GlobalVi import com.actiontech.dble.backend.mysql.nio.handler.query.DMLResponseHandler; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.*; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.groupby.DirectGroupByHandler; -import com.actiontech.dble.backend.mysql.nio.handler.query.impl.groupby.OrderedGroupByHandler; +import com.actiontech.dble.backend.mysql.nio.handler.query.impl.groupby.AggregateHandler; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.subquery.AllAnySubQueryHandler; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.subquery.InSubQueryHandler; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.subquery.SingleRowSubQueryHandler; @@ -218,13 +218,13 @@ public abstract class BaseHandlerBuilder { } else { OrderByHandler oh = new OrderByHandler(getSequenceId(), session, node.getGroupBys()); addHandler(oh); - OrderedGroupByHandler gh = new OrderedGroupByHandler(getSequenceId(), session, node.getGroupBys(), + AggregateHandler gh = new AggregateHandler(getSequenceId(), session, node.getGroupBys(), sumRefs); addHandler(gh); } } else { // @bug 1052 canDirectGroupby condition we use // directgroupby already - OrderedGroupByHandler gh = new OrderedGroupByHandler(getSequenceId(), session, node.getGroupBys(), + AggregateHandler gh = new AggregateHandler(getSequenceId(), session, node.getGroupBys(), sumRefs); addHandler(gh); } diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/groupby/OrderedGroupByHandler.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/groupby/AggregateHandler.java similarity index 97% rename from src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/groupby/OrderedGroupByHandler.java rename to src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/groupby/AggregateHandler.java index f8c599512..810c9851b 100644 --- a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/groupby/OrderedGroupByHandler.java +++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/groupby/AggregateHandler.java @@ -33,8 +33,8 @@ import java.util.concurrent.locks.ReentrantLock; /** * 1.executed the ordered result of group by 2. group by of Aggregator_distinct */ -public class OrderedGroupByHandler extends BaseDMLHandler { - private static final Logger LOGGER = LoggerFactory.getLogger(OrderedGroupByHandler.class); +public class AggregateHandler extends BaseDMLHandler { + private static final Logger LOGGER = LoggerFactory.getLogger(AggregateHandler.class); private List groupBys; private List referredSumFunctions; @@ -63,7 +63,7 @@ public class OrderedGroupByHandler extends BaseDMLHandler { * @param groupBys * @param referredSumFunctions */ - public OrderedGroupByHandler(long id, NonBlockingSession session, List groupBys, List referredSumFunctions) { + public AggregateHandler(long id, NonBlockingSession session, List groupBys, List referredSumFunctions) { super(id, session); this.groupBys = groupBys; this.referredSumFunctions = referredSumFunctions; diff --git a/src/main/java/com/actiontech/dble/plan/util/ComplexQueryPlanUtil.java b/src/main/java/com/actiontech/dble/plan/util/ComplexQueryPlanUtil.java index 32bc6a345..d1b5ed9dd 100644 --- a/src/main/java/com/actiontech/dble/plan/util/ComplexQueryPlanUtil.java +++ b/src/main/java/com/actiontech/dble/plan/util/ComplexQueryPlanUtil.java @@ -9,7 +9,7 @@ import com.actiontech.dble.backend.mysql.nio.handler.builder.BaseHandlerBuilder; import com.actiontech.dble.backend.mysql.nio.handler.query.DMLResponseHandler; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.*; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.groupby.DirectGroupByHandler; -import com.actiontech.dble.backend.mysql.nio.handler.query.impl.groupby.OrderedGroupByHandler; +import com.actiontech.dble.backend.mysql.nio.handler.query.impl.groupby.AggregateHandler; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.join.JoinHandler; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.join.NotInHandler; import com.actiontech.dble.backend.mysql.nio.handler.query.impl.subquery.AllAnySubQueryHandler; @@ -167,8 +167,8 @@ public final class ComplexQueryPlanUtil { private static String getTypeName(DMLResponseHandler handler) { - if (handler instanceof OrderedGroupByHandler) { - return "ORDERED_GROUP"; + if (handler instanceof AggregateHandler) { + return "AGGREGATE"; } else if (handler instanceof DistinctHandler) { return "DISTINCT"; } else if (handler instanceof LimitHandler) {