io.micronaut.data.hibernate.operations

Class HibernateJpaOperations

java.lang.Object

io.micronaut.data.hibernate.operations.HibernateJpaOperations

All Implemented Interfaces:

JpaRepositoryOperations, AsyncCapableRepository, PrimaryRepositoryOperations, ReactiveCapableRepository, RepositoryOperations

@EachBean(value=org.hibernate.SessionFactory.class)
public class HibernateJpaOperations
extends java.lang.Object
implements JpaRepositoryOperations, AsyncCapableRepository, ReactiveCapableRepository

Implementation of the JpaRepositoryOperations interface for Hibernate.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HibernateJpaOperations(org.hibernate.SessionFactory sessionFactory, TransactionOperations<java.sql.Connection> transactionOperations, java.util.concurrent.ExecutorService executorService) Default constructor.

Method Summary

Modifier and Type	Method and Description
ExecutorAsyncOperations	async()
<T> long	count(PagedQuery<T> pagedQuery) Counts all results for the given query.
<T> int	delete(DeleteOperation<T> operation) Deletes the entity.
<T> java.util.Optional<java.lang.Number>	deleteAll(DeleteBatchOperation<T> operation) Deletes all the entities of the given type.
java.util.Optional<java.lang.Number>	executeUpdate(PreparedQuery<?,java.lang.Number> preparedQuery) Executes an update for the given query and parameter values.
<T> boolean	exists(PreparedQuery<T,java.lang.Boolean> preparedQuery) Execute a query that checks for existence.
<T> java.lang.Iterable<T>	findAll(PagedQuery<T> query) Finds all results for the given query.
<T,R> java.lang.Iterable<R>	findAll(PreparedQuery<T,R> preparedQuery) Finds all results for the given query.
<T> T	findOne(java.lang.Class<T> type, java.io.Serializable id) Find one by ID.
<T,R> R	findOne(PreparedQuery<T,R> preparedQuery) Find one by Query.
<R> Page<R>	findPage(PagedQuery<R> query) Find a page for the given entity and pageable.
<T> java.util.stream.Stream<T>	findStream(PagedQuery<T> pagedQuery) Finds a stream for the given arguments.
<T,R> java.util.stream.Stream<R>	findStream(PreparedQuery<T,R> preparedQuery) Finds all results for the given query.
void	flush() Flush the current session.
javax.persistence.EntityManager	getCurrentEntityManager()
javax.persistence.EntityManagerFactory	getEntityManagerFactory()
java.util.Map<java.lang.String,java.lang.Object>	getQueryHints(StoredQuery<?,?> storedQuery) Obtain any custom query hints for this method and repository implementation.
<T> T	persist(InsertOperation<T> operation) Persist the operation returning a possibly new entity.
<T> java.lang.Iterable<T>	persistAll(InsertBatchOperation<T> operation) Persist all the given entities.
ReactiveRepositoryOperations	reactive()
<T> T	update(UpdateOperation<T> operation) Updates the entity for the given operation.

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.operations.RepositoryOperations

executeDelete, getEntity

Constructor Detail

HibernateJpaOperations

protected HibernateJpaOperations(@NonNull
                                 org.hibernate.SessionFactory sessionFactory,
                                 @NonNull @Parameter
                                 TransactionOperations<java.sql.Connection> transactionOperations,
                                 @Named(value="io") @Nullable
                                 java.util.concurrent.ExecutorService executorService)

Default constructor.

Parameters:

sessionFactory - The session factory

transactionOperations - The transaction operations

executorService - The executor service for I/O tasks to use

Method Detail

getQueryHints

@NonNull
public java.util.Map<java.lang.String,java.lang.Object> getQueryHints(@NonNull
                                                                               StoredQuery<?,?> storedQuery)

Description copied from interface: RepositoryOperations

Obtain any custom query hints for this method and repository implementation.

Specified by:

getQueryHints in interface RepositoryOperations

Parameters:

storedQuery - The stored query

Returns:

THe query hints

findOne

@Nullable
public <T> T findOne(@NonNull
                               java.lang.Class<T> type,
                               @NonNull
                               java.io.Serializable id)

Description copied from interface: RepositoryOperations

Find one by ID.

Specified by:

findOne in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

type - The type

id - The id

Returns:

A result or null

findOne

@Nullable
public <T,R> R findOne(@NonNull
                                 PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Find one by Query.

Specified by:

findOne in interface RepositoryOperations

Type Parameters:

T - The generic resultType

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

A result or null

exists

public <T> boolean exists(@NonNull
                          PreparedQuery<T,java.lang.Boolean> preparedQuery)

Description copied from interface: RepositoryOperations

Execute a query that checks for existence.

Specified by:

exists in interface RepositoryOperations

Type Parameters:

T - The generic resultType

Parameters:

preparedQuery - The prepared query

Returns:

A result or null

findAll

@NonNull
public <T> java.lang.Iterable<T> findAll(@NonNull
                                                  PagedQuery<T> query)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

query - The root entity

Returns:

An iterable result

count

public <T> long count(PagedQuery<T> pagedQuery)

Description copied from interface: RepositoryOperations

Counts all results for the given query.

Specified by:

count in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

pagedQuery - The paged query

Returns:

An iterable result

findAll

@NonNull
public <T,R> java.lang.Iterable<R> findAll(@NonNull
                                                    PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface RepositoryOperations

Type Parameters:

T - The entity type

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

An iterable result

persist

public <T> T persist(@NonNull
                     InsertOperation<T> operation)

Description copied from interface: RepositoryOperations

Persist the operation returning a possibly new entity.

Specified by:

persist in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The operation

update

@NonNull
public <T> T update(@NonNull
                             UpdateOperation<T> operation)

Description copied from interface: RepositoryOperations

Updates the entity for the given operation.

Specified by:

update in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The operation

persistAll

@NonNull
public <T> java.lang.Iterable<T> persistAll(@NonNull
                                                     InsertBatchOperation<T> operation)

Description copied from interface: RepositoryOperations

Persist all the given entities.

Specified by:

persistAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The entities, possibly mutated

executeUpdate

@NonNull
public java.util.Optional<java.lang.Number> executeUpdate(@NonNull
                                                                   PreparedQuery<?,java.lang.Number> preparedQuery)

Description copied from interface: RepositoryOperations

Executes an update for the given query and parameter values. If it is possible to return the number of objects updated, then do so.

Specified by:

executeUpdate in interface RepositoryOperations

Parameters:

preparedQuery - The prepared query

Returns:

An optional number with the count of the number of records updated

delete

public <T> int delete(@NonNull
                      DeleteOperation<T> operation)

Description copied from interface: RepositoryOperations

Deletes the entity.

Specified by:

delete in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The number of entities deleted

deleteAll

public <T> java.util.Optional<java.lang.Number> deleteAll(@NonNull
                                                          DeleteBatchOperation<T> operation)

Description copied from interface: RepositoryOperations

Deletes all the entities of the given type.

Specified by:

deleteAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The number of entities deleted

findStream

@NonNull
public <T,R> java.util.stream.Stream<R> findStream(@NonNull
                                                            PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findStream in interface RepositoryOperations

Type Parameters:

T - The entity type

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

An iterable result

findStream

@NonNull
public <T> java.util.stream.Stream<T> findStream(@NonNull
                                                          PagedQuery<T> pagedQuery)

Description copied from interface: RepositoryOperations

Finds a stream for the given arguments.

Specified by:

findStream in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

pagedQuery - The query

Returns:

The stream

findPage

public <R> Page<R> findPage(@NonNull
                            PagedQuery<R> query)

Description copied from interface: RepositoryOperations

Find a page for the given entity and pageable.

Specified by:

findPage in interface RepositoryOperations

Type Parameters:

R - The entity generic type

Parameters:

query - The query

Returns:

The page type

async

@NonNull
public ExecutorAsyncOperations async()

Specified by:

async in interface AsyncCapableRepository

Returns:

The async operations.

reactive

@NonNull
public ReactiveRepositoryOperations reactive()

Specified by:

reactive in interface ReactiveCapableRepository

Returns:

The reactive operations instance.

getCurrentEntityManager

@NonNull
public javax.persistence.EntityManager getCurrentEntityManager()

Specified by:

getCurrentEntityManager in interface JpaRepositoryOperations

Returns:

The currrent entity manager

getEntityManagerFactory

@NonNull
public javax.persistence.EntityManagerFactory getEntityManagerFactory()

Specified by:

getEntityManagerFactory in interface JpaRepositoryOperations

Returns:

The entity manager factory

flush

public void flush()

Description copied from interface: JpaRepositoryOperations

Flush the current session.

Specified by:

flush in interface JpaRepositoryOperations