package com.megatim.fdxcommons.tools.database.queries.jpql;
|
|
import com.megatim.fdxcommons.model.enumeration.CriteriaLogicConnector;
|
import com.megatim.fdxcommons.model.enumeration.Operateur;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.BETWEEN;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.EQUALS;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.GREATER_OR_EQUALS_THAN;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.GREATER_THAN;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.IN;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.IS_NOT_NULL;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.IS_NULL;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.LIKE;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.LOWER_OR_EQUALS_THAN;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.LOWER_THAN;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.NOT_BETWEEN;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.NOT_EQUALS;
|
import static com.megatim.fdxcommons.model.enumeration.Operateur.NOT_IN;
|
import com.megatim.fdxcommons.tools.database.exceptions.BadQueryCriteriaException;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.jpql.JpqlQueryCriterion;
|
import java.util.List;
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
/**
|
*
|
* @author lenovo
|
*/
|
public class JpqlWhereQueryString {
|
|
private final JpqlQueryCriterion queryCriterion;
|
private final String classAlias;
|
private final AtomicInteger rang = new AtomicInteger(1);
|
|
public JpqlWhereQueryString(JpqlQueryCriterion queryCriterion, String classAlias) {
|
this.queryCriterion = queryCriterion;
|
this.classAlias = classAlias;
|
}
|
|
public String query() throws BadQueryCriteriaException {
|
StringBuilder query = new StringBuilder("");
|
|
if (queryCriterion != null) {
|
query
|
.append(" WHERE ")
|
.append(buildQuery(queryCriterion));
|
}
|
return query.toString();
|
}
|
|
private String buildQuery(JpqlQueryCriterion criterion) throws BadQueryCriteriaException {
|
StringBuilder query = new StringBuilder();
|
|
if (criterion.getSubCriteria().isEmpty()) {
|
|
switch (criterion.getOperateur()) {
|
case EQUALS:
|
case NOT_EQUALS:
|
case LIKE:
|
case GREATER_OR_EQUALS_THAN:
|
case GREATER_THAN:
|
case LOWER_OR_EQUALS_THAN:
|
case LOWER_THAN:
|
query.append(buildQueryWithSingleParameter(criterion));
|
break;
|
case BETWEEN:
|
case NOT_BETWEEN:
|
query.append(buildBetweenQuery(criterion));
|
break;
|
case IS_NOT_NULL:
|
case IS_NULL:
|
query.append(buildQueryWithoutParameter(criterion));
|
break;
|
case NOT_IN:
|
case IN:
|
query.append(buildQueryWithMultipleParameters(criterion));
|
break;
|
}
|
|
} else {
|
|
CriteriaLogicConnector criteriaLogicConnector = criterion.getCriteriaLogicConnector();
|
if (criteriaLogicConnector == null) {
|
throw new BadQueryCriteriaException("Critère non valide : Connecteur logique absent");
|
}
|
int size = criterion.getSubCriteria().size();
|
int index = 0;
|
|
for (JpqlQueryCriterion c : criterion.getSubCriteria()) {
|
query
|
.append("(")
|
.append(buildQuery(c))
|
.append(")");
|
|
if ((++index) < size) {
|
query.append(criteriaLogicConnector.equals(CriteriaLogicConnector.AND) ? " AND " : " OR ");
|
}
|
|
}
|
|
}
|
|
return query.toString();
|
}
|
|
private String buildQueryWithoutParameter(JpqlQueryCriterion criterion) {
|
StringBuilder query = new StringBuilder("");
|
query
|
.append(classAlias)
|
.append(".")
|
.append(criterion.getNomColonne())
|
.append(" ")
|
.append(criterion.getOperateur().getValue());
|
return query.toString();
|
}
|
|
private String buildQueryWithSingleParameter(JpqlQueryCriterion criterion) {
|
StringBuilder query = new StringBuilder("");
|
if (criterion.getOperateur().equals(Operateur.LIKE)) {
|
query
|
.append("LOWER(")
|
.append(classAlias)
|
.append(".")
|
.append(criterion.getNomColonne())
|
.append(") LIKE LOWER(?")
|
.append(rang.getAndIncrement())
|
.append(")");
|
} else {
|
query
|
.append(classAlias)
|
.append(".")
|
.append(criterion.getNomColonne())
|
.append(" ")
|
.append(criterion.getOperateur().getValue())
|
.append(" ?")
|
.append(rang.getAndIncrement())
|
.append(" ");
|
}
|
|
return query.toString();
|
}
|
|
private String buildBetweenQuery(JpqlQueryCriterion criterion) {
|
StringBuilder query = new StringBuilder("");
|
query
|
.append(classAlias)
|
.append(".")
|
.append(criterion.getNomColonne())
|
.append(" ")
|
.append(criterion.getOperateur().getValue())
|
.append(" ?")
|
.append(rang.getAndIncrement())
|
.append(" AND ")
|
.append(" ?")
|
.append(rang.getAndIncrement())
|
.append(" ");
|
return query.toString();
|
}
|
|
private String buildQueryWithMultipleParameters(JpqlQueryCriterion criterion) {
|
StringBuilder query = new StringBuilder("");
|
|
query
|
.append(classAlias)
|
.append(".")
|
.append(criterion.getNomColonne())
|
.append(" ")
|
.append(criterion.getOperateur().getValue())
|
.append("(");
|
|
List values = (List) criterion.getCriteriaValue();
|
|
int size = values.size();
|
for (int i = 0; i < size; i++) {
|
|
if ((i + 1) < size) {
|
query.append("?").append(rang.getAndIncrement()).append(", ");
|
} else {
|
query.append("?").append(rang.getAndIncrement());
|
}
|
|
}
|
|
query.append(")");
|
|
return query.toString();
|
}
|
}
|
