io.micronaut.data.model.query.builder.sql

Class SqlQueryBuilder

java.lang.Object

io.micronaut.data.model.query.builder.AbstractSqlLikeQueryBuilder

io.micronaut.data.model.query.builder.sql.SqlQueryBuilder

All Implemented Interfaces:

QueryBuilder, SqlQueryConfiguration.DialectConfiguration, java.lang.annotation.Annotation

public class SqlQueryBuilder
extends AbstractSqlLikeQueryBuilder
implements QueryBuilder, SqlQueryConfiguration.DialectConfiguration

Implementation of QueryBuilder that builds SQL queries.

Since:

1.0.0

Author:

graemerocher

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.data.model.query.builder.AbstractSqlLikeQueryBuilder

AbstractSqlLikeQueryBuilder.CriteriaContext, AbstractSqlLikeQueryBuilder.CriterionHandler<T extends QueryModel.Criterion>, AbstractSqlLikeQueryBuilder.Placeholder, AbstractSqlLikeQueryBuilder.QueryPosition, AbstractSqlLikeQueryBuilder.QueryPropertyPath, AbstractSqlLikeQueryBuilder.QueryState

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_POSITIONAL_PARAMETER_MARKER The start of an IN expression.
static java.lang.String	SQL_SERVER_FOR_UPDATE_CLAUSE
static java.lang.String	STANDARD_FOR_UPDATE_CLAUSE

Fields inherited from class io.micronaut.data.model.query.builder.AbstractSqlLikeQueryBuilder

ALIAS_REPLACE, ALIAS_REPLACE_QUOTED, AND, AS_CLAUSE, AVG, CLOSE_BRACKET, COMMA, COUNT_DISTINCT, DELETE_CLAUSE, DISTINCT, DOT, EQUALS, EQUALS_FALSE, EQUALS_TRUE, FROM_CLAUSE, FUNCTION_COUNT, GREATER_THAN, GREATER_THAN_OR_EQUALS, IS_EMPTY, IS_NOT_EMPTY, IS_NOT_NULL, IS_NULL, LESS_THAN, LESS_THAN_OR_EQUALS, LOGICAL_AND, LOGICAL_OR, MAX, MIN, NOT_CLAUSE, NOT_EQUALS, OPEN_BRACKET, OR, ORDER_BY_CLAUSE, queryHandlers, SELECT_CLAUSE, SPACE, SUM, UPDATE_CLAUSE, WHERE_CLAUSE

Fields inherited from interface io.micronaut.data.model.query.builder.QueryBuilder

IN_VARIABLES_PATTERN, VARIABLE_PATTERN

Constructor Summary

Constructors

Constructor and Description
SqlQueryBuilder() Default constructor.
SqlQueryBuilder(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata) Constructor with annotation metadata.
SqlQueryBuilder(Dialect dialect)

Method Summary

Modifier and Type	Method and Description
java.lang.Class<? extends java.lang.annotation.Annotation>	annotationType()
protected void	appendForUpdate(AbstractSqlLikeQueryBuilder.QueryPosition queryPosition, QueryModel query, java.lang.StringBuilder queryBuilder) Adds "forUpdate" pisimmistic locking.
protected void	appendProjectionRowCount(java.lang.StringBuilder queryString, java.lang.String logicalName) Appends a row count projection to the query string.
protected void	appendUpdateSetParameter(java.lang.StringBuilder sb, java.lang.String alias, PersistentProperty prop, java.lang.Runnable appendParameter) Appends the SET=? call to the query string.
protected java.lang.String	asLiteral(java.lang.Object value) Convert the literal value to it's SQL representation.
java.lang.String	buildBatchCreateTableStatement(PersistentEntity... entities) Builds a batch create tables statement.
java.lang.String	buildBatchDropTableStatement(PersistentEntity... entities) Builds a batch drop tables statement.
java.lang.String[]	buildCreateTableStatements(PersistentEntity entity) Builds the create table statement.
java.lang.String[]	buildDropTableStatements(PersistentEntity entity) Builds the drop table statement.
QueryResult	buildInsert(io.micronaut.core.annotation.AnnotationMetadata repositoryMetadata, PersistentEntity entity) Builds an insert statement for the given entity.
protected java.lang.String[]	buildJoin(java.lang.String alias, JoinPath joinPath, java.lang.String joinType, java.lang.StringBuilder target, java.util.Map<java.lang.String,java.lang.String> appliedJoinPaths, AbstractSqlLikeQueryBuilder.QueryState queryState) Build a join expression for the given alias, association, join type and builder.
java.lang.String	buildJoinTableInsert(PersistentEntity entity, Association association) Builds a join table insert statement for a given entity and association.
QueryResult	buildPagination(Pageable pageable) Encode the pageable.
protected boolean	computePropertyPaths() Whether property path expressions require computation by the implementation.
Dialect	dialect()
boolean	escapeQueries()
protected java.lang.String	formatEndsWith()
AbstractSqlLikeQueryBuilder.Placeholder	formatParameter(int index) Format the parameter at the given index.
protected java.lang.String	formatStartsWith()
protected java.lang.String	formatStartsWithBeginning()
protected java.lang.String	formEndsWithEnd()
protected java.lang.String	getAliasName(PersistentEntity entity) Get an alias name for the given entity.
java.lang.String	getColumnName(PersistentProperty persistentProperty) Get the column name for the given property.
Dialect	getDialect() Get dialect.
protected java.lang.String	getTableAsKeyword() Get the AS keyword to use for table aliases.
java.lang.String	getTableName(PersistentEntity entity) Get the table name for the given entity.
protected boolean	isAliasForBatch() Should aliases be used in batch statements.
protected boolean	isExpandEmbedded() Should embedded queries by expanded by the implementation.
static boolean	isForeignKeyWithJoinTable(Association association) Is the given association a foreign key reference that requires a join table.
java.lang.String	positionalParameterFormat()
java.util.regex.Pattern	positionalParameterPattern()
protected java.lang.String	quote(java.lang.String persistedName) Quote a column name for the dialect.
java.lang.String	resolveJoinType(Join.Type jt) Resolves the join type.
protected void	selectAllColumns(AbstractSqlLikeQueryBuilder.QueryState queryState, java.lang.StringBuilder queryBuffer) Obtain the string that selects all columns from the entity.
void	selectAllColumns(PersistentEntity entity, java.lang.String alias, java.lang.StringBuilder sb) Selects all columns for the given entity and alias.
protected GeneratedValue.Type	selectAutoStrategy(PersistentProperty property) Selects the default fallback strategy.
boolean	shouldAliasProjections() Whether projections should be aliased.
protected boolean	shouldEscape(PersistentEntity entity) Whether queries should be escaped for the given entity.
boolean	supportsForUpdate() Whether FOR UPDATE queries are supported.

Methods inherited from class io.micronaut.data.model.query.builder.AbstractSqlLikeQueryBuilder

addCriterionHandler, appendDeleteClause, appendTransformed, asPath, buildDelete, buildOrderBy, buildOrderBy, buildQuery, buildUpdate, buildUpdate, getAliasName, getDataTransformerReadValue, getDataTransformerWriteValue, getPathOnlyAliasName, getUnescapedTableName, handleSubQuery, traversePersistentProperties, traversePersistentProperties, traversePersistentProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.data.model.query.builder.QueryBuilder

buildDelete, buildDelete, buildOrderBy, buildQuery, buildQuery, buildUpdate, buildUpdate, buildUpdate, buildUpdate, newQueryBuilder

Methods inherited from interface java.lang.annotation.Annotation

equals, hashCode, toString

Field Detail

DEFAULT_POSITIONAL_PARAMETER_MARKER

public static final java.lang.String DEFAULT_POSITIONAL_PARAMETER_MARKER

The start of an IN expression.

See Also:

Constant Field Values

STANDARD_FOR_UPDATE_CLAUSE

public static final java.lang.String STANDARD_FOR_UPDATE_CLAUSE

See Also:

Constant Field Values

SQL_SERVER_FOR_UPDATE_CLAUSE

public static final java.lang.String SQL_SERVER_FOR_UPDATE_CLAUSE

See Also:

Constant Field Values

Constructor Detail

SqlQueryBuilder

@Creator
public SqlQueryBuilder(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)

Constructor with annotation metadata.

Parameters:

annotationMetadata - The annotation metadata

SqlQueryBuilder

public SqlQueryBuilder()

Default constructor.

SqlQueryBuilder

public SqlQueryBuilder(Dialect dialect)

Parameters:

dialect - The dialect

Method Detail

getDialect

public Dialect getDialect()

Description copied from class: AbstractSqlLikeQueryBuilder

Get dialect.

Overrides:

getDialect in class AbstractSqlLikeQueryBuilder

Returns:

The dialect being used by the builder.

shouldEscape

protected boolean shouldEscape(@NonNull
                               PersistentEntity entity)

Description copied from class: AbstractSqlLikeQueryBuilder

Whether queries should be escaped for the given entity.

Overrides:

shouldEscape in class AbstractSqlLikeQueryBuilder

Parameters:

entity - The entity

Returns:

True if they should be escaped

asLiteral

protected java.lang.String asLiteral(java.lang.Object value)

Description copied from class: AbstractSqlLikeQueryBuilder

Convert the literal value to it's SQL representation.

Overrides:

asLiteral in class AbstractSqlLikeQueryBuilder

Parameters:

value - The literal value

Returns:

converter value

shouldAliasProjections

public boolean shouldAliasProjections()

Description copied from interface: QueryBuilder

Whether projections should be aliased.

Specified by:

shouldAliasProjections in interface QueryBuilder

Returns:

True if they should

isExpandEmbedded

protected boolean isExpandEmbedded()

Description copied from class: AbstractSqlLikeQueryBuilder

Should embedded queries by expanded by the implementation.

Overrides:

isExpandEmbedded in class AbstractSqlLikeQueryBuilder

Returns:

True if they should

buildBatchCreateTableStatement

@NonNull
public java.lang.String buildBatchCreateTableStatement(@NonNull
                                                                PersistentEntity... entities)

Builds a batch create tables statement. Designed for testing and not production usage. For production a SQL migration tool such as Flyway or Liquibase is recommended.

Parameters:

entities - the entities

Returns:

The table

buildBatchDropTableStatement

@NonNull
public java.lang.String buildBatchDropTableStatement(@NonNull
                                                              PersistentEntity... entities)

Builds a batch drop tables statement. Designed for testing and not production usage. For production a SQL migration tool such as Flyway or Liquibase is recommended.

Parameters:

entities - the entities

Returns:

The table

buildDropTableStatements

@NonNull
public java.lang.String[] buildDropTableStatements(@NonNull
                                                            PersistentEntity entity)

Builds the drop table statement. Designed for testing and not production usage. For production a SQL migration tool such as Flyway or Liquibase is recommended.

Parameters:

entity - The entity

Returns:

The tables for the give entity

buildJoinTableInsert

@NonNull
public java.lang.String buildJoinTableInsert(@NonNull
                                                      PersistentEntity entity,
                                                      @NonNull
                                                      Association association)

Builds a join table insert statement for a given entity and association.

Parameters:

entity - The entity

association - The association

Returns:

The join table insert statement

isForeignKeyWithJoinTable

public static boolean isForeignKeyWithJoinTable(@NonNull
                                                Association association)

Is the given association a foreign key reference that requires a join table.

Parameters:

association - The association.

Returns:

True if it is.

buildCreateTableStatements

@NonNull
public java.lang.String[] buildCreateTableStatements(@NonNull
                                                              PersistentEntity entity)

Builds the create table statement. Designed for testing and not production usage. For production a SQL migration tool such as Flyway or Liquibase is recommended.

Parameters:

entity - The entity

Returns:

The tables for the give entity

getTableAsKeyword

protected java.lang.String getTableAsKeyword()

Description copied from class: AbstractSqlLikeQueryBuilder

Get the AS keyword to use for table aliases.

Overrides:

getTableAsKeyword in class AbstractSqlLikeQueryBuilder

Returns:

The AS keyword if any

selectAllColumns

protected void selectAllColumns(AbstractSqlLikeQueryBuilder.QueryState queryState,
                                java.lang.StringBuilder queryBuffer)

Description copied from class: AbstractSqlLikeQueryBuilder

Obtain the string that selects all columns from the entity.

Specified by:

selectAllColumns in class AbstractSqlLikeQueryBuilder

Parameters:

queryState - The query state

selectAllColumns

public void selectAllColumns(PersistentEntity entity,
                             java.lang.String alias,
                             java.lang.StringBuilder sb)

Selects all columns for the given entity and alias.

Specified by:

selectAllColumns in class AbstractSqlLikeQueryBuilder

Parameters:

entity - The entity

alias - The alias

sb - The builder to add the columns

resolveJoinType

public java.lang.String resolveJoinType(Join.Type jt)

Description copied from class: AbstractSqlLikeQueryBuilder

Resolves the join type.

Specified by:

resolveJoinType in class AbstractSqlLikeQueryBuilder

Parameters:

jt - The join type

Returns:

The join type.

buildInsert

@NonNull
public QueryResult buildInsert(io.micronaut.core.annotation.AnnotationMetadata repositoryMetadata,
                                        PersistentEntity entity)

Description copied from interface: QueryBuilder

Builds an insert statement for the given entity.

Specified by:

buildInsert in interface QueryBuilder

Parameters:

repositoryMetadata - The repository annotation metadata

entity - The entity

Returns:

The insert statement or null if the implementation doesn't require insert statements

buildPagination

@NonNull
public QueryResult buildPagination(@NonNull
                                            Pageable pageable)

Description copied from interface: QueryBuilder

Encode the pageable.

Specified by:

buildPagination in interface QueryBuilder

Parameters:

pageable - The pageable

Returns:

The encoded query

getAliasName

protected java.lang.String getAliasName(PersistentEntity entity)

Description copied from class: AbstractSqlLikeQueryBuilder

Get an alias name for the given entity.

Overrides:

getAliasName in class AbstractSqlLikeQueryBuilder

Parameters:

entity - The entity

Returns:

The alias name

getTableName

public java.lang.String getTableName(PersistentEntity entity)

Description copied from class: AbstractSqlLikeQueryBuilder

Get the table name for the given entity.

Specified by:

getTableName in class AbstractSqlLikeQueryBuilder

Parameters:

entity - The entity

Returns:

The table name

formatStartsWith

protected java.lang.String formatStartsWith()

Overrides:

formatStartsWith in class AbstractSqlLikeQueryBuilder

Returns:

Formats the starts with expression.

formEndsWithEnd

protected java.lang.String formEndsWithEnd()

Overrides:

formEndsWithEnd in class AbstractSqlLikeQueryBuilder

Returns:

Formats end of an ends with expression

formatEndsWith

protected java.lang.String formatEndsWith()

Overrides:

formatEndsWith in class AbstractSqlLikeQueryBuilder

Returns:

Formats the ends with expression.

formatStartsWithBeginning

protected java.lang.String formatStartsWithBeginning()

Overrides:

formatStartsWithBeginning in class AbstractSqlLikeQueryBuilder

Returns:

Formats the beginning of an starts with expression

appendUpdateSetParameter

protected void appendUpdateSetParameter(java.lang.StringBuilder sb,
                                        java.lang.String alias,
                                        PersistentProperty prop,
                                        java.lang.Runnable appendParameter)

Description copied from class: AbstractSqlLikeQueryBuilder

Appends the SET=? call to the query string.

Overrides:

appendUpdateSetParameter in class AbstractSqlLikeQueryBuilder

Parameters:

sb - The string builder

alias - The alias

prop - The property

appendParameter - The append parameter action

buildJoin

protected java.lang.String[] buildJoin(java.lang.String alias,
                                       JoinPath joinPath,
                                       java.lang.String joinType,
                                       java.lang.StringBuilder target,
                                       java.util.Map<java.lang.String,java.lang.String> appliedJoinPaths,
                                       AbstractSqlLikeQueryBuilder.QueryState queryState)

Description copied from class: AbstractSqlLikeQueryBuilder

Build a join expression for the given alias, association, join type and builder.

Specified by:

buildJoin in class AbstractSqlLikeQueryBuilder

Parameters:

alias - The alias

joinPath - The join path

joinType - The join type string

target - The target builder

appliedJoinPaths - The applied joins paths

queryState - The query state

Returns:

An array representing the aliases for each join association in the specified join path

quote

protected java.lang.String quote(java.lang.String persistedName)

Quote a column name for the dialect.

Overrides:

quote in class AbstractSqlLikeQueryBuilder

Parameters:

persistedName - The persisted name.

Returns:

The quoted name

getColumnName

public java.lang.String getColumnName(PersistentProperty persistentProperty)

Description copied from class: AbstractSqlLikeQueryBuilder

Get the column name for the given property.

Specified by:

getColumnName in class AbstractSqlLikeQueryBuilder

Parameters:

persistentProperty - The property

Returns:

The column name

appendProjectionRowCount

protected void appendProjectionRowCount(java.lang.StringBuilder queryString,
                                        java.lang.String logicalName)

Description copied from class: AbstractSqlLikeQueryBuilder

Appends a row count projection to the query string.

Specified by:

appendProjectionRowCount in class AbstractSqlLikeQueryBuilder

Parameters:

queryString - The query string

logicalName - The alias to the table name

appendForUpdate

protected void appendForUpdate(AbstractSqlLikeQueryBuilder.QueryPosition queryPosition,
                               QueryModel query,
                               java.lang.StringBuilder queryBuilder)

Description copied from class: AbstractSqlLikeQueryBuilder

Adds "forUpdate" pisimmistic locking.

Overrides:

appendForUpdate in class AbstractSqlLikeQueryBuilder

Parameters:

queryPosition - The query position

query - The query

queryBuilder - The builder

computePropertyPaths

protected final boolean computePropertyPaths()

Description copied from class: AbstractSqlLikeQueryBuilder

Whether property path expressions require computation by the implementation. In a certain query dialects property paths are supported (such as JPA-QL where you can do select foo.bar) whilst for explicit SQL queries paths like this have to be computed into aliases / column name references.

Specified by:

computePropertyPaths in class AbstractSqlLikeQueryBuilder

Returns:

True if property path computation is required.

isAliasForBatch

protected boolean isAliasForBatch()

Description copied from class: AbstractSqlLikeQueryBuilder

Should aliases be used in batch statements.

Specified by:

isAliasForBatch in class AbstractSqlLikeQueryBuilder

Returns:

True if they should

formatParameter

public AbstractSqlLikeQueryBuilder.Placeholder formatParameter(int index)

Description copied from class: AbstractSqlLikeQueryBuilder

Format the parameter at the given index.

Specified by:

formatParameter in class AbstractSqlLikeQueryBuilder

Parameters:

index - The parameter

Returns:

The index

selectAutoStrategy

protected GeneratedValue.Type selectAutoStrategy(PersistentProperty property)

Selects the default fallback strategy. For a generated value.

Parameters:

property - The Persistent property

Returns:

The generated value

supportsForUpdate

public boolean supportsForUpdate()

Description copied from interface: QueryBuilder

Whether FOR UPDATE queries are supported.

Specified by:

supportsForUpdate in interface QueryBuilder

Returns:

True if FOR UPDATE queries are supported

dialect

public Dialect dialect()

positionalParameterFormat

public java.lang.String positionalParameterFormat()

positionalParameterPattern

public java.util.regex.Pattern positionalParameterPattern()

Returns:

The regex pattern for positional parameters.

escapeQueries

public boolean escapeQueries()

annotationType

public java.lang.Class<? extends java.lang.annotation.Annotation> annotationType()

Specified by:

annotationType in interface java.lang.annotation.Annotation