Package ch.tocco.nice2.persist.core.impl.hibernate.pojo

Class PersistenceServiceImpl

java.lang.Object

ch.tocco.nice2.persist.core.impl.hibernate.pojo.PersistenceServiceImpl

All Implemented Interfaces:

PersistenceService

@Component
public class PersistenceServiceImpl
extends Object
implements PersistenceService

Nested Class Summary

Nested classes/interfaces inherited from interface ch.tocco.nice2.persist.core.api.hibernate.PersistenceService

PersistenceService.CompiledQuery

Constructor Summary

Constructors

Constructor

Description

PersistenceServiceImpl(SessionFactoryManager sessionFactoryManager, TypeManager typeManager, FieldResolver fieldResolver, EntityFactory entityFactory, EntityTransactionContext entityTransactionContext, EntityFacadeListenerManager entityFacadeListenerManager, DataModel dataModel, BinaryDataAccessor binaryDataAccessor, ConditionFactory conditionFactory, QueryCompiler queryCompiler, ContextService contextService, InsecureOrderPathsRegistry insecureOrderPathsRegistry)

Method Summary

Modifier and Type	Method	Description
void	addSessionListener(SessionFactoryManagerListener listener)
TransactionControl	beginTransaction(boolean rollbackOnly)	Start a new transaction.
PersistenceService.CompiledQuery	compileQuery(String query)
<T> T	create(Class<T> entityClass)
Entity	create(String modelName)
CountQueryBuilder	createCountQueryBuilder(Class<? extends Entity> entityClass)	Create a new CountQueryBuilder which executes count queries.
CountQueryBuilder	createCountQueryBuilder(Class<? extends Entity> entityClass, Map<String,?> hints)	Create a new CountQueryBuilder which executes count queries.
CountQueryBuilder	createCountQueryBuilder(String modelName)	Create a new CountQueryBuilder which executes count queries.
CountQueryBuilder	createCountQueryBuilder(String modelName, Map<String,?> hints)	Create a new CountQueryBuilder which executes count queries.
CriteriaDeleteBuilder	createDeleteBuilder(Class<? extends Entity> entityClass)	Create a new delete builder for the current Session.
CriteriaDeleteBuilder	createDeleteBuilder(String modelName)	Create a new delete builder for the current Session.
PrimaryKeyQueryBuilder	createPrimaryKeyQueryBuilder(Class<? extends Entity> entityClass)	Create a new PrimaryKeyQueryBuilder which executes queries for PrimaryKey instances.
PrimaryKeyQueryBuilder	createPrimaryKeyQueryBuilder(Class<? extends Entity> entityClass, Map<String,?> hints)	Create a new PrimaryKeyQueryBuilder which executes queries for PrimaryKey instances.
PrimaryKeyQueryBuilder	createPrimaryKeyQueryBuilder(String modelName)	Create a new PrimaryKeyQueryBuilder which executes queries for PrimaryKey instances.
PrimaryKeyQueryBuilder	createPrimaryKeyQueryBuilder(String modelName, Map<String,?> hints)	Create a new PrimaryKeyQueryBuilder which executes queries for PrimaryKey instances.
<T> SinglePathQueryBuilder<T>	createQueryBuilder(Class<? extends Entity> entityClass, Class<T> resultType)	Create a new SinglePathQueryBuilder that returns a single path of the root entity.
<T> SinglePathQueryBuilder<T>	createQueryBuilder(Class<? extends Entity> entityClass, Class<T> resultType, Map<String,?> hints)	Create a new SinglePathQueryBuilder that returns a single path of the root entity.
<T extends Entity> EntityQueryBuilder<T>	createQueryBuilder(Class<T> entityClass)	Create a new EntityQueryBuilder that returns Entity instances of the given type.
<T extends Entity> EntityQueryBuilder<T>	createQueryBuilder(Class<T> entityClass, Map<String,?> hints)	Create a new EntityQueryBuilder that returns Entity instances of the given type.
EntityQueryBuilder<Entity>	createQueryBuilder(String modelName)	Create a new EntityQueryBuilder that returns Entity instances of the given type.
<T> SinglePathQueryBuilder<T>	createQueryBuilder(String modelName, Class<T> returnType)	Create a new SinglePathQueryBuilder that returns a single path of the root entity.
<T> SinglePathQueryBuilder<T>	createQueryBuilder(String modelName, Class<T> returnType, Map<String,?> hints)	Create a new SinglePathQueryBuilder that returns a single path of the root entity.
EntityQueryBuilder<Entity>	createQueryBuilder(String modelName, Map<String,?> hints)	Create a new EntityQueryBuilder that returns Entity instances of the given type.
<T> PathQueryBuilder<T>	createQueryBuilderForPaths(Class<? extends Entity> entityClass, Class<T> targetClass)	Create a new PathQueryBuilder that returns an Object[] containing multiple paths of the root entity.
<T> PathQueryBuilder<T>	createQueryBuilderForPaths(Class<? extends Entity> entityClass, Class<T> targetClass, Map<String,?> hints)	Create a new PathQueryBuilder that returns an Object[] containing multiple paths of the root entity.
<T> PathQueryBuilder<T>	createQueryBuilderForPaths(String modelName, Class<T> targetClass)	Create a new PathQueryBuilder that returns an Object[] containing multiple paths of the root entity.
<T> PathQueryBuilder<T>	createQueryBuilderForPaths(String modelName, Class<T> targetClass, Map<String,?> hints)	Create a new PathQueryBuilder that returns an Object[] containing multiple paths of the root entity.
void	doInNewSession(Runnable runnable)	Same as returnFromNewSession but without a return type
void	doInTransaction(CheckedConsumer<TransactionControl> consumer)	The same as returnFromTransaction, but accepts a Consumer instead of a Function and has therefore no return type.
<T> T	doWithConnection(org.hibernate.jdbc.ReturningWork<T> work)	Execute an instance of ReturningWork using the connection (transaction) of the current session.
<T extends Entity> T	get(Class<T> entityClass, Serializable pk)
<T extends Entity> T	get(Class<T> entityClass, String identifier)
Entity	get(String modelName, Serializable id)
Entity	get(String modelName, String identifier)
PersistenceSession	getCurrentSession()
@Nullable TransactionControl	getCurrentTransaction()
<T extends Entity> Optional<T>	getIfPresent(Class<T> entityClass, Serializable pk)
<T extends Entity> Optional<T>	getIfPresent(Class<T> entityClass, String identifier)
Optional<Entity>	getIfPresent(String modelName, Serializable id)
Optional<Entity>	getIfPresent(String modelName, String identifier)
<T extends Entity> Class<T>	loadEntityClassByName(String entityName)	Utility method to load the dynamically generated entity class by entity name.
<T extends Entity> List<T>	queryAll(Class<T> entityClass)
List<Entity>	queryAll(String modelName)
void	removeSessionListener(SessionFactoryManagerListener listener)
<T> T	returnFromNewSession(Supplier<T> supplier)	Run the given supplier with a new session
<T> T	returnFromTransaction(CheckedFunction<TransactionControl,T> function)	Run the given function function inside a transaction.
void	setArgumentFactories(List<ArgumentFactoryContribution> contributions)
void	setCommitInvokerContributions(List<CommitInvokerContribution> commitInvokerContributions)
void	setJdbcFunctions(List<JdbcFunction> jdbcFunctions)
void	setPrimaryKeyLoaders(List<PrimaryKeyLoader> primaryKeyLoaders)
void	setQueryBuilderInterceptors(List<QueryBuilderInterceptor> queryBuilderInterceptors)
void	setRowMapperFactories(List<ResultRowMapperFactory> rowMapperFactories)
protected boolean	transactionInProgress(PersistenceSessionImplementor session)
Invoker	txInvoker()

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.tocco.nice2.persist.core.api.hibernate.PersistenceService

beginTransaction

Constructor Details

PersistenceServiceImpl

public PersistenceServiceImpl(@Lazy
 SessionFactoryManager sessionFactoryManager,
 TypeManager typeManager,
 FieldResolver fieldResolver,
 @Lazy
 EntityFactory entityFactory,
 @Lazy
 EntityTransactionContext entityTransactionContext,
 @Lazy
 EntityFacadeListenerManager entityFacadeListenerManager,
 @Lazy
 DataModel dataModel,
 @Lazy
 BinaryDataAccessor binaryDataAccessor,
 ConditionFactory conditionFactory,
 @Lazy
 QueryCompiler queryCompiler,
 ContextService contextService,
 InsecureOrderPathsRegistry insecureOrderPathsRegistry)

Method Details

setQueryBuilderInterceptors

@Autowired
public void setQueryBuilderInterceptors(List<QueryBuilderInterceptor> queryBuilderInterceptors)

setPrimaryKeyLoaders

@Autowired
public void setPrimaryKeyLoaders(List<PrimaryKeyLoader> primaryKeyLoaders)

setRowMapperFactories

@Autowired
public void setRowMapperFactories(List<ResultRowMapperFactory> rowMapperFactories)

setCommitInvokerContributions

@Autowired
public void setCommitInvokerContributions(List<CommitInvokerContribution> commitInvokerContributions)

setJdbcFunctions

@Autowired
public void setJdbcFunctions(List<JdbcFunction> jdbcFunctions)

setArgumentFactories

@Autowired
public void setArgumentFactories(List<ArgumentFactoryContribution> contributions)

create

public <T> T create(Class<T> entityClass)

Specified by:

create in interface PersistenceService

Returns:

an instance of the given entity interface

create

public Entity create(String modelName)

Specified by:

create in interface PersistenceService

Returns:

an instance of the given entity model

queryAll

public <T extends Entity> List<T> queryAll(Class<T> entityClass)

Specified by:

queryAll in interface PersistenceService

Returns:

all entities of the given class

queryAll

public List<Entity> queryAll(String modelName)

Specified by:

queryAll in interface PersistenceService

Returns:

all entities of the given class

get

public <T extends Entity> T get(Class<T> entityClass,
 Serializable pk)

Specified by:

get in interface PersistenceService

Returns:

the entity with the given identifier

get

public Entity get(String modelName,
 Serializable id)

Specified by:

get in interface PersistenceService

Returns:

the entity with the given identifier

get

public <T extends Entity> T get(Class<T> entityClass,
 String identifier)

Specified by:

get in interface PersistenceService

Parameters:

identifier - the unique_id or string key of an entity

Returns:

the entity with the given identifier

get

public Entity get(String modelName,
 String identifier)

Specified by:

get in interface PersistenceService

Parameters:

identifier - the unique_id or string key of an entity

Returns:

the entity with the given identifier

getIfPresent

public <T extends Entity> Optional<T> getIfPresent(Class<T> entityClass,
 Serializable pk)

Specified by:

getIfPresent in interface PersistenceService

Returns:

the entity with the given identifier or an empty optional if it does not exist

getIfPresent

public Optional<Entity> getIfPresent(String modelName,
 Serializable id)

Specified by:

getIfPresent in interface PersistenceService

Returns:

the entity with the given identifier or an empty optional if it does not exist

getIfPresent

public <T extends Entity> Optional<T> getIfPresent(Class<T> entityClass,
 String identifier)

Specified by:

getIfPresent in interface PersistenceService

Parameters:

identifier - the unique_id or string key of an entity

Returns:

the entity with the given identifier or an empty optional if it does not exist

getIfPresent

public Optional<Entity> getIfPresent(String modelName,
 String identifier)

Specified by:

getIfPresent in interface PersistenceService

Parameters:

identifier - the unique_id or string key of an entity

Returns:

the entity with the given identifier or an empty optional if it does not exist

beginTransaction

public TransactionControl beginTransaction(boolean rollbackOnly)

Description copied from interface: PersistenceService

Start a new transaction. Preferably PersistenceService.doInTransaction(CheckedConsumer) and PersistenceService.returnFromTransaction(CheckedFunction) should be used. The transaction handling (commit/rollback) must be handled by the user of this method.

Specified by:

beginTransaction in interface PersistenceService

Parameters:

rollbackOnly - if the transaction should be rolled back at the end of the transaction

Returns:

the TransactionControl for the newly created transaction

See Also:

• TransactionControl.isRollbackTransaction()
• TransactionControl.getRollbackOnly()

getCurrentTransaction

@Nullable
public @Nullable TransactionControl getCurrentTransaction()

Specified by:

getCurrentTransaction in interface PersistenceService

Returns:

a TransactionControl for the currently running transaction (or null)

returnFromTransaction

public <T> T returnFromTransaction(CheckedFunction<TransactionControl,T> function)

Description copied from interface: PersistenceService

Run the given function function inside a transaction. If a transaction is already running, the existing transaction is used. Newly created entities will automatically be inserted before committing.

Specified by:

returnFromTransaction in interface PersistenceService

Type Parameters:

T - the return type

Parameters:

function - the function to run

Returns:

the result of the function

doInTransaction

public void doInTransaction(CheckedConsumer<TransactionControl> consumer)

Description copied from interface: PersistenceService

The same as returnFromTransaction, but accepts a Consumer instead of a Function and has therefore no return type.

Specified by:

doInTransaction in interface PersistenceService

Parameters:

consumer - the function to run

transactionInProgress

protected boolean transactionInProgress(PersistenceSessionImplementor session)

getCurrentSession

public PersistenceSession getCurrentSession()

Specified by:

getCurrentSession in interface PersistenceService

Returns:

the currently active session - this may open a new thread-bound session.

returnFromNewSession

public <T> T returnFromNewSession(Supplier<T> supplier)

Description copied from interface: PersistenceService

Run the given supplier with a new session

Specified by:

returnFromNewSession in interface PersistenceService

Type Parameters:

T - the return type

Parameters:

supplier - the supplier to run

Returns:

the result of the supplier

doInNewSession

public void doInNewSession(Runnable runnable)

Description copied from interface: PersistenceService

Same as returnFromNewSession but without a return type

Specified by:

doInNewSession in interface PersistenceService

Parameters:

runnable - to run in a new session

doWithConnection

public <T> T doWithConnection(org.hibernate.jdbc.ReturningWork<T> work)

Description copied from interface: PersistenceService

Execute an instance of ReturningWork using the connection (transaction) of the current session.

Specified by:

doWithConnection in interface PersistenceService

txInvoker

public Invoker txInvoker()

Specified by:

txInvoker in interface PersistenceService

createDeleteBuilder

public CriteriaDeleteBuilder createDeleteBuilder(Class<? extends Entity> entityClass)

Description copied from interface: PersistenceService

Create a new delete builder for the current Session.

Specified by:

createDeleteBuilder in interface PersistenceService

Parameters:

entityClass - the root entity (which is also the return type)

createDeleteBuilder

public CriteriaDeleteBuilder createDeleteBuilder(String modelName)

Description copied from interface: PersistenceService

Create a new delete builder for the current Session.

Specified by:

createDeleteBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

compileQuery

public PersistenceService.CompiledQuery compileQuery(String query)

Specified by:

compileQuery in interface PersistenceService

createQueryBuilder

public <T extends Entity> EntityQueryBuilder<T> createQueryBuilder(Class<T> entityClass)

Description copied from interface: PersistenceService

Create a new EntityQueryBuilder that returns Entity instances of the given type.

Specified by:

createQueryBuilder in interface PersistenceService

Parameters:

entityClass - the root entity (which is also the return type)

createQueryBuilder

public <T extends Entity> EntityQueryBuilder<T> createQueryBuilder(Class<T> entityClass,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new EntityQueryBuilder that returns Entity instances of the given type.

Specified by:

createQueryBuilder in interface PersistenceService

Parameters:

entityClass - the root entity (which is also the return type)

hints - optional hints about the query (see QueryHints for available hints)

createQueryBuilder

public EntityQueryBuilder<Entity> createQueryBuilder(String modelName)

Description copied from interface: PersistenceService

Create a new EntityQueryBuilder that returns Entity instances of the given type.

Specified by:

createQueryBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

createQueryBuilder

public EntityQueryBuilder<Entity> createQueryBuilder(String modelName,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new EntityQueryBuilder that returns Entity instances of the given type.

Specified by:

createQueryBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

hints - optional hints about the query (see QueryHints for available hints)

createQueryBuilder

public <T> SinglePathQueryBuilder<T> createQueryBuilder(Class<? extends Entity> entityClass,
 Class<T> resultType)

Description copied from interface: PersistenceService

Create a new SinglePathQueryBuilder that returns a single path of the root entity.

Specified by:

createQueryBuilder in interface PersistenceService

Parameters:

entityClass - the root entity

resultType - the type of the path to be returned

createQueryBuilder

public <T> SinglePathQueryBuilder<T> createQueryBuilder(Class<? extends Entity> entityClass,
 Class<T> resultType,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new SinglePathQueryBuilder that returns a single path of the root entity.

Specified by:

createQueryBuilder in interface PersistenceService

Parameters:

entityClass - the root entity

resultType - the type of the path to be returned

hints - optional hints about the query (see QueryHints for available hints)

createQueryBuilder

public <T> SinglePathQueryBuilder<T> createQueryBuilder(String modelName,
 Class<T> returnType)

Description copied from interface: PersistenceService

Create a new SinglePathQueryBuilder that returns a single path of the root entity.

Specified by:

createQueryBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

returnType - the type of the path to be returned

createQueryBuilder

public <T> SinglePathQueryBuilder<T> createQueryBuilder(String modelName,
 Class<T> returnType,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new SinglePathQueryBuilder that returns a single path of the root entity.

Specified by:

createQueryBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

returnType - the type of the path to be returned

hints - optional hints about the query (see QueryHints for available hints)

createQueryBuilderForPaths

public <T> PathQueryBuilder<T> createQueryBuilderForPaths(Class<? extends Entity> entityClass,
 Class<T> targetClass)

Description copied from interface: PersistenceService

Create a new PathQueryBuilder that returns an Object[] containing multiple paths of the root entity.

Specified by:

createQueryBuilderForPaths in interface PersistenceService

Parameters:

entityClass - the root entity

targetClass - the return type of the query builder (for example Map or Object[]

createQueryBuilderForPaths

public <T> PathQueryBuilder<T> createQueryBuilderForPaths(String modelName,
 Class<T> targetClass)

Description copied from interface: PersistenceService

Create a new PathQueryBuilder that returns an Object[] containing multiple paths of the root entity.

Specified by:

createQueryBuilderForPaths in interface PersistenceService

Parameters:

modelName - the model name of the root entity

targetClass - the return type of the query builder (for example Map or Object[]

createQueryBuilderForPaths

public <T> PathQueryBuilder<T> createQueryBuilderForPaths(Class<? extends Entity> entityClass,
 Class<T> targetClass,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new PathQueryBuilder that returns an Object[] containing multiple paths of the root entity.

Specified by:

createQueryBuilderForPaths in interface PersistenceService

Parameters:

entityClass - the root entity

targetClass - the return type of the query builder (for example Map or Object[]

hints - optional hints about the query (see QueryHints for available hints)

createQueryBuilderForPaths

public <T> PathQueryBuilder<T> createQueryBuilderForPaths(String modelName,
 Class<T> targetClass,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new PathQueryBuilder that returns an Object[] containing multiple paths of the root entity.

Specified by:

createQueryBuilderForPaths in interface PersistenceService

Parameters:

modelName - the model name of the root entity

targetClass - the return type of the query builder (for example Map or Object[]

hints - optional hints about the query (see QueryHints for available hints)

createCountQueryBuilder

public CountQueryBuilder createCountQueryBuilder(Class<? extends Entity> entityClass)

Description copied from interface: PersistenceService

Create a new CountQueryBuilder which executes count queries.

Specified by:

createCountQueryBuilder in interface PersistenceService

Parameters:

entityClass - the root entity

createCountQueryBuilder

public CountQueryBuilder createCountQueryBuilder(String modelName)

Description copied from interface: PersistenceService

Create a new CountQueryBuilder which executes count queries.

Specified by:

createCountQueryBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

createCountQueryBuilder

public CountQueryBuilder createCountQueryBuilder(Class<? extends Entity> entityClass,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new CountQueryBuilder which executes count queries.

Specified by:

createCountQueryBuilder in interface PersistenceService

Parameters:

entityClass - the root entity

hints - optional hints about the query (see QueryHints for available hints)

createCountQueryBuilder

public CountQueryBuilder createCountQueryBuilder(String modelName,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new CountQueryBuilder which executes count queries.

Specified by:

createCountQueryBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

hints - optional hints about the query (see QueryHints for available hints)

createPrimaryKeyQueryBuilder

public PrimaryKeyQueryBuilder createPrimaryKeyQueryBuilder(String modelName)

Description copied from interface: PersistenceService

Create a new PrimaryKeyQueryBuilder which executes queries for PrimaryKey instances.

Specified by:

createPrimaryKeyQueryBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

createPrimaryKeyQueryBuilder

public PrimaryKeyQueryBuilder createPrimaryKeyQueryBuilder(Class<? extends Entity> entityClass)

Description copied from interface: PersistenceService

Create a new PrimaryKeyQueryBuilder which executes queries for PrimaryKey instances.

Specified by:

createPrimaryKeyQueryBuilder in interface PersistenceService

Parameters:

entityClass - the root entity

createPrimaryKeyQueryBuilder

public PrimaryKeyQueryBuilder createPrimaryKeyQueryBuilder(String modelName,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new PrimaryKeyQueryBuilder which executes queries for PrimaryKey instances.

Specified by:

createPrimaryKeyQueryBuilder in interface PersistenceService

Parameters:

modelName - the model name of the root entity

hints - optional hints about the query (see QueryHints for available hints)

createPrimaryKeyQueryBuilder

public PrimaryKeyQueryBuilder createPrimaryKeyQueryBuilder(Class<? extends Entity> entityClass,
 Map<String,?> hints)

Description copied from interface: PersistenceService

Create a new PrimaryKeyQueryBuilder which executes queries for PrimaryKey instances.

Specified by:

createPrimaryKeyQueryBuilder in interface PersistenceService

Parameters:

entityClass - the root entity

hints - optional hints about the query (see QueryHints for available hints)

loadEntityClassByName

public <T extends Entity> Class<T> loadEntityClassByName(String entityName)

Description copied from interface: PersistenceService

Utility method to load the dynamically generated entity class by entity name.

Specified by:

loadEntityClassByName in interface PersistenceService

Parameters:

entityName - name of the entity to load. Can be the fully qualified class name or just the entity name

Returns:

the entity class instance

addSessionListener

public void addSessionListener(SessionFactoryManagerListener listener)

Specified by:

addSessionListener in interface PersistenceService

removeSessionListener

public void removeSessionListener(SessionFactoryManagerListener listener)

Specified by:

removeSessionListener in interface PersistenceService