@@ -281,11 +281,11 @@ private void parseAggExprCommon(SchemaConfig schema, RouteResultset rrs, MySqlSe
281281 if (isDistinct && !isNeedOptimizer (itemExpr )) {
282282 if (itemExpr instanceof SQLIdentifierExpr ) {
283283 SQLIdentifierExpr item = (SQLIdentifierExpr ) itemExpr ;
284- hasPartitionColumn = hasShardingColumn (tc , item .getSimpleName ());
284+ if ( hasShardingColumn (tc , item .getSimpleName ())) hasPartitionColumn = true ;
285285 addToAliaColumn (aliaColumns , selectItem );
286286 } else if (itemExpr instanceof SQLPropertyExpr ) {
287287 SQLPropertyExpr item = (SQLPropertyExpr ) itemExpr ;
288- hasPartitionColumn = hasShardingColumn (tc , item .getSimpleName ());
288+ if ( hasShardingColumn (tc , item .getSimpleName ())) hasPartitionColumn = true ;
289289 addToAliaColumn (aliaColumns , selectItem );
290290 }
291291 } else if (isSumFuncOrSubQuery (schema .getName (), itemExpr )) {
@@ -313,10 +313,10 @@ private void parseGroupCommon(RouteResultset rrs, MySqlSelectQueryBlock mysqlSel
313313 return ;
314314 } else if (groupByItem instanceof SQLIdentifierExpr ) {
315315 SQLIdentifierExpr item = (SQLIdentifierExpr ) groupByItem ;
316- hasPartitionColumn = hasShardingColumn (tc , item .getSimpleName ());
316+ if ( hasShardingColumn (tc , item .getSimpleName ())) hasPartitionColumn = true ;
317317 } else if (groupByItem instanceof SQLPropertyExpr ) {
318318 SQLPropertyExpr item = (SQLPropertyExpr ) groupByItem ;
319- hasPartitionColumn = hasShardingColumn (tc , item .getSimpleName ());
319+ if ( hasShardingColumn (tc , item .getSimpleName ())) hasPartitionColumn = true ;
320320 }
321321 }
322322 if (groupBy .getItems ().size () > 0 && !hasPartitionColumn ) {
0 commit comments