io.micronaut.data.runtime.operations.internal

Class AbstractSqlRepositoryOperations.SqlOperation

java.lang.Object

io.micronaut.data.runtime.operations.internal.AbstractSqlRepositoryOperations.SqlOperation

Direct Known Subclasses:

AbstractSqlRepositoryOperations.StoredSqlOperation

Enclosing class:

AbstractSqlRepositoryOperations<Cnt,RS,PS,Exc extends java.lang.Exception>

protected abstract class AbstractSqlRepositoryOperations.SqlOperation
extends java.lang.Object

The sql operation.

Field Summary

Fields

Modifier and Type	Field and Description
protected Dialect	dialect
protected java.lang.String	query

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SqlOperation(java.lang.String query, Dialect dialect) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
<T> java.util.Map<java.lang.String,java.lang.Object>	collectAutoPopulatedPreviousValues(RuntimePersistentEntity<T> persistentEntity, T entity) Collect auto-populated property values before pre-actions are triggered and property values are modified.
java.lang.String	exandedQuery() Expanded query.
Dialect	getDialect() Get dialect.
java.lang.String	getQuery() Get sql query.
boolean	isOptimisticLock() Return true if query contains previous version check.
<T> void	setParameters(PS stmt, RuntimePersistentEntity<T> persistentEntity, T entity) Set query parameters.
abstract <T> void	setParameters(PS stmt, RuntimePersistentEntity<T> persistentEntity, T entity, java.util.Map<java.lang.String,java.lang.Object> previousValues) Set query parameters.

Methods inherited from class java.lang.Object

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

Field Detail

query

protected java.lang.String query

dialect

protected final Dialect dialect

Constructor Detail

SqlOperation

protected SqlOperation(java.lang.String query,
                       Dialect dialect)

Creates a new instance.

Parameters:

query - The sql query

dialect - The dialect

Method Detail

exandedQuery

public java.lang.String exandedQuery()

Expanded query.

Returns:

expanded query

getQuery

public java.lang.String getQuery()

Get sql query.

Returns:

sql query

getDialect

public Dialect getDialect()

Get dialect.

Returns:

dialect

isOptimisticLock

public boolean isOptimisticLock()

Return true if query contains previous version check. If true and modifying query updates less records than expected should be thrown.

Returns:

true if the query contains optimistic lock

collectAutoPopulatedPreviousValues

public <T> java.util.Map<java.lang.String,java.lang.Object> collectAutoPopulatedPreviousValues(RuntimePersistentEntity<T> persistentEntity,
                                                                                               T entity)

Collect auto-populated property values before pre-actions are triggered and property values are modified.

Type Parameters:

T - The entity type

Parameters:

persistentEntity - The persistent entity

entity - The entity instance

Returns:

collected values

setParameters

public abstract <T> void setParameters(PS stmt,
                                       RuntimePersistentEntity<T> persistentEntity,
                                       T entity,
                                       java.util.Map<java.lang.String,java.lang.Object> previousValues)

Set query parameters.

Type Parameters:

T - The entity type

Parameters:

stmt - The statement

persistentEntity - The persistentEntity

entity - The entity

previousValues - The previous auto-populated collected values

setParameters

public <T> void setParameters(PS stmt,
                              RuntimePersistentEntity<T> persistentEntity,
                              T entity)

Set query parameters.

Type Parameters:

T - The entity type

Parameters:

stmt - The statement

persistentEntity - The persistentEntity

entity - The entity