EqlCountQueryTransformer.java
/*
* Copyright 2023-present the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.data.jpa.repository.query;
import static org.springframework.data.jpa.repository.query.QueryTokens.*;
import java.util.List;
import org.jspecify.annotations.Nullable;
import org.springframework.data.jpa.repository.query.EqlParser.Constructor_expressionContext;
import org.springframework.data.jpa.repository.query.EqlParser.Constructor_itemContext;
import org.springframework.data.jpa.repository.query.EqlParser.Select_itemContext;
import org.springframework.data.jpa.repository.query.QueryRenderer.QueryRendererBuilder;
/**
* An ANTLR {@link org.antlr.v4.runtime.tree.ParseTreeVisitor} that transforms a parsed EQL query into a
* {@code COUNT(���)} query.
*
* @author Greg Turnquist
* @author Mark Paluch
* @author Christoph Strobl
* @since 3.4
*/
class EqlCountQueryTransformer extends EqlQueryRenderer
implements CountSelection.Grammar<Select_itemContext, Constructor_expressionContext, Constructor_itemContext> {
private final @Nullable String primaryFromAlias;
private final CountSelection<Select_itemContext, Constructor_expressionContext, Constructor_itemContext> countSelection;
EqlCountQueryTransformer(@Nullable String countProjection, QueryInformation queryInformation) {
this.primaryFromAlias = queryInformation.getAlias();
this.countSelection = new CountSelection<>(countProjection, primaryFromAlias, true, false, this);
}
@Override
public QueryTokenStream visitSelectQuery(EqlParser.SelectQueryContext ctx) {
QueryRendererBuilder builder = QueryRenderer.builder();
builder.appendExpression(visit(ctx.select_clause()));
builder.appendExpression(visit(ctx.from_clause()));
if (ctx.where_clause() != null) {
builder.appendExpression(visit(ctx.where_clause()));
}
if (ctx.groupby_clause() != null) {
builder.appendExpression(visit(ctx.groupby_clause()));
}
if (ctx.having_clause() != null) {
builder.appendExpression(visit(ctx.having_clause()));
}
return builder;
}
@Override
public QueryTokenStream visitFromQuery(EqlParser.FromQueryContext ctx) {
QueryRendererBuilder builder = QueryRenderer.builder();
builder.appendExpression(countSelection.render());
if (ctx.from_clause() != null) {
builder.appendExpression(visit(ctx.from_clause()));
if (primaryFromAlias == null) {
builder.append(TOKEN_AS);
builder.append(TOKEN_DOUBLE_UNDERSCORE);
}
}
if (ctx.where_clause() != null) {
builder.appendExpression(visit(ctx.where_clause()));
}
if (ctx.groupby_clause() != null) {
builder.appendExpression(visit(ctx.groupby_clause()));
}
if (ctx.having_clause() != null) {
builder.appendExpression(visit(ctx.having_clause()));
}
return builder;
}
@Override
public QueryTokenStream visitSelect_clause(EqlParser.Select_clauseContext ctx) {
return countSelection.render(QueryTokens.expression(ctx.SELECT()), QueryTokens.expressionOrNull(ctx.DISTINCT()),
ctx.select_item());
}
@Override
public QueryTokenStream visitSelect_item(EqlParser.Select_itemContext ctx) {
return visit(ctx.select_expression()); // skip AS field aliasing
}
@Override
public QueryTokenStream visitConstructor_expression(EqlParser.Constructor_expressionContext ctx) {
return countSelection.renderConstructor(ctx);
}
@Override
public @Nullable Constructor_expressionContext getConstructorExpression(Select_itemContext selectItem) {
return selectItem.select_expression().constructor_expression();
}
@Override
public List<Constructor_itemContext> getConstructorArguments(Constructor_expressionContext constructorExpression) {
return constructorExpression.constructor_item();
}
@Override
public boolean isPath(Constructor_itemContext argument) {
return argument.single_valued_path_expression() != null || argument.identification_variable() != null;
}
}