Package com.valqueries.automapper

Class ValqueriesCrudRepositoryImpl<T,K>

java.lang.Object

com.valqueries.automapper.ValqueriesCrudRepositoryImpl<T,K>

All Implemented Interfaces:

ValqueriesCrudRepository<T,K>, CrudRepository<T,K>

Direct Known Subclasses:

AutoCrudRepositoryImpl, com.fracturecode.saga.repository.FairLockRepository

public class ValqueriesCrudRepositoryImpl<T,K>
extends Object
implements ValqueriesCrudRepository<T,K>

Nested Class Summary

Nested classes/interfaces inherited from interface io.ran.CrudRepository

CrudRepository.CrudUpdateResult, CrudRepository.InlineQuery<T,Q extends CrudRepository.InlineQuery<T,Q>>

Constructor Summary

Constructors

Constructor	Description
ValqueriesCrudRepositoryImpl(ValqueriesRepositoryFactory factory, Class<T> modelType, Class<K> keyType)

Method Summary

Modifier and Type	Method	Description
CrudRepository.CrudUpdateResult	deleteById(K id)	Delete an instance of the entity by its id (primary key).
CrudRepository.CrudUpdateResult	deleteByIds(Collection<K> collection)	Delete all instances of the entity which has an id (primary key) in the given collection.
void	doRetryableInTransaction(ITransaction tx)	Used to perform multiple operations in a transaction, with a retry mechanism in case of a transaction deadlock.
Optional<T>	get(ITransactionContext tx, K id)	Get an instance of the entity by its id in a transaction.
Optional<T>	get(K id)	Get an instance of the entity by its id (primary key).
Stream<T>	getAll()	Get all instances of the entity, as a stream.
CrudRepository.CrudUpdateResult	insert(ITransactionContext tx, Collection<T> entities)	Inserts new entries in the database in a transaction.
CrudRepository.CrudUpdateResult	insert(ITransactionContext tx, T entity)	Inserts a new entry in the database in a transaction.
<O> CrudRepository.CrudUpdateResult	insertOther(ITransactionContext tx, O t, Class<O> oClass)	Inserts a new entry of another type in the database in a transaction.
<O> CrudRepository.CrudUpdateResult	insertOthers(ITransactionContext tx, Collection<O> ts, Class<O> oClass)	Inserts new entries in the database in a transaction.
<X> X	obtainInTransaction(ITransactionWithResult<X> tx)	Used to perform multiple operations in a transaction, ultimately returning a result.
protected ValqueriesQuery<T>	query()
protected ValqueriesQuery<T>	query(ITransactionContext tx)
protected <O> ValqueriesQuery<O>	query(ITransactionContext tx, Class<O> oClass)
protected <O> ValqueriesQuery<O>	query(Class<O> oClass)
CrudRepository.CrudUpdateResult	save(ITransactionContext tx, Collection<T> entities)	Insert new instances of multiple entities or update existing ones in a transaction.
CrudRepository.CrudUpdateResult	save(ITransactionContext tx, T entity)	Insert a new instance of the entity or update an existing one in a transaction.
CrudRepository.CrudUpdateResult	save(T entity)	Insert a new instance of the entity or update an existing one.
<O> CrudRepository.CrudUpdateResult	saveOther(ITransactionContext tx, O t, Class<O> oClass)	Insert a new instance of another entity or update an existing one in a transaction.
<O> CrudRepository.CrudUpdateResult	saveOthers(ITransactionContext tx, Collection<O> t, Class<O> oClass)	Insert new instances of multiple other entities or update existing ones in a transaction.
CrudRepository.CrudUpdateResult	upsert(ITransactionContext tx, Collection<T> t, Consumer<ValqueriesUpsertUpdate<T>> updater)	Inserts a new entry or updates an existing entry in the database in a transaction.
CrudRepository.CrudUpdateResult	upsert(Collection<T> t, Consumer<ValqueriesUpsertUpdate<T>> updater)	Inserts a new entry or updates an existing entry in the database.

Methods inherited from class java.lang.Object

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

Constructor Details

ValqueriesCrudRepositoryImpl

public ValqueriesCrudRepositoryImpl(ValqueriesRepositoryFactory factory,
 Class<T> modelType,
 Class<K> keyType)

Method Details

get

public Optional<T> get(K id)

Description copied from interface: CrudRepository

Get an instance of the entity by its id (primary key).

Note: If the entity does not have a primary key, this method will not be available.

In case of compound primary key, pass the model object with the primary key fields populated.

Specified by:

get in interface CrudRepository<T,K>

Parameters:

id - the id of the entity

Returns:

an optional containing the entity if it exists

get

public Optional<T> get(ITransactionContext tx,
 K id)

Description copied from interface: ValqueriesCrudRepository

Get an instance of the entity by its id in a transaction.

Note: If the entity does not have a primary key, this method will not be available.

Specified by:

get in interface ValqueriesCrudRepository<T,K>

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

id - the id of the entity

Returns:

an optional containing the entity if it exists

getAll

public Stream<T> getAll()

Description copied from interface: CrudRepository

Get all instances of the entity, as a stream.

Specified by:

getAll in interface CrudRepository<T,K>

Returns:

an unordered stream of all instances of the entity

deleteById

public CrudRepository.CrudUpdateResult deleteById(K id)

Description copied from interface: CrudRepository

Delete an instance of the entity by its id (primary key).

Note: If the entity does not have a primary key, this method will not be available.

In case of compound primary key, pass the model object with the primary key fields populated.

Specified by:

deleteById in interface CrudRepository<T,K>

Parameters:

id - the id of the entity to be deleted

Returns:

the result of the delete operation

deleteByIds

public CrudRepository.CrudUpdateResult deleteByIds(Collection<K> collection)

Description copied from interface: CrudRepository

Delete all instances of the entity which has an id (primary key) in the given collection.

Note: If the entity does not have a primary key, this method will not be available.

In case of compound primary key, pass the model object with the primary key fields populated.

Specified by:

deleteByIds in interface CrudRepository<T,K>

Parameters:

collection - a collection of ids to be deleted

Returns:

the result of the delete operation

save

public CrudRepository.CrudUpdateResult save(T entity)

Description copied from interface: CrudRepository

Insert a new instance of the entity or update an existing one. Will match by primary key, but not other unique keys.

Specified by:

save in interface CrudRepository<T,K>

Parameters:

entity - the entity to save

Returns:

the result of the save operation

save

public CrudRepository.CrudUpdateResult save(ITransactionContext tx,
 T entity)

Description copied from interface: ValqueriesCrudRepository

Insert a new instance of the entity or update an existing one in a transaction.

Specified by:

save in interface ValqueriesCrudRepository<T,K>

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

entity - the entity to save

Returns:

the result of the save operation

insert

public CrudRepository.CrudUpdateResult insert(ITransactionContext tx,
 T entity)
                                       throws ValqueriesInsertFailedException

Description copied from interface: ValqueriesCrudRepository

Inserts a new entry in the database in a transaction. Important to notice: no Relation will be persisted. If the entity to be inserted contains relations, they will have to be inserted manually.

Specified by:

insert in interface ValqueriesCrudRepository<T,K>

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

entity - the entity to be inserted

Returns:

the result of the insert operation

Throws:

ValqueriesInsertFailedException - if the insert statement fails

save

public CrudRepository.CrudUpdateResult save(ITransactionContext tx,
 Collection<T> entities)

Description copied from interface: ValqueriesCrudRepository

Insert new instances of multiple entities or update existing ones in a transaction.

Specified by:

save in interface ValqueriesCrudRepository<T,K>

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

entities - the entities to save

Returns:

the result of the save operation

insert

public CrudRepository.CrudUpdateResult insert(ITransactionContext tx,
 Collection<T> entities)
                                       throws ValqueriesInsertFailedException

Description copied from interface: ValqueriesCrudRepository

Inserts new entries in the database in a transaction. Important to notice: no Relation will be persisted. If the entity to be inserted contains relations, they will have to be inserted manually.

Specified by:

insert in interface ValqueriesCrudRepository<T,K>

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

entities - the entities to be inserted

Returns:

the result of the insert operation

Throws:

ValqueriesInsertFailedException - if the insert statement fails

saveOther

public <O> CrudRepository.CrudUpdateResult saveOther(ITransactionContext tx,
 O t,
 Class<O> oClass)

Description copied from interface: ValqueriesCrudRepository

Insert a new instance of another entity or update an existing one in a transaction.

Specified by:

saveOther in interface ValqueriesCrudRepository<T,K>

Type Parameters:

O - the type of the entity

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

t - the entity to save

oClass - the type of the entity

Returns:

the result of the save operation

insertOther

public <O> CrudRepository.CrudUpdateResult insertOther(ITransactionContext tx,
 O t,
 Class<O> oClass)
                                                throws ValqueriesInsertFailedException

Description copied from interface: ValqueriesCrudRepository

Inserts a new entry of another type in the database in a transaction. Important to notice: no Relation will be persisted. If the entity to be inserted contains relations, they will have to be inserted manually.

Specified by:

insertOther in interface ValqueriesCrudRepository<T,K>

Type Parameters:

O - the type of the entity

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

t - the entity to be inserted

oClass - the type of the entity

Returns:

the result of the insert operation

Throws:

ValqueriesInsertFailedException - if the insert statement fails

saveOthers

public <O> CrudRepository.CrudUpdateResult saveOthers(ITransactionContext tx,
 Collection<O> t,
 Class<O> oClass)

Description copied from interface: ValqueriesCrudRepository

Insert new instances of multiple other entities or update existing ones in a transaction.

Specified by:

saveOthers in interface ValqueriesCrudRepository<T,K>

Type Parameters:

O - the type of the entities

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

t - the entities to save

oClass - the type of the entities

Returns:

the result of the save operation

insertOthers

public <O> CrudRepository.CrudUpdateResult insertOthers(ITransactionContext tx,
 Collection<O> ts,
 Class<O> oClass)
                                                 throws ValqueriesInsertFailedException

Description copied from interface: ValqueriesCrudRepository

Inserts new entries in the database in a transaction. Important to notice: no Relation will be persisted. If the entity to be inserted contains relations, they will have to be inserted manually.

Specified by:

insertOthers in interface ValqueriesCrudRepository<T,K>

Type Parameters:

O - the type of the entities

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

ts - the entities to be inserted

oClass - the type of the entities

Returns:

the result of the insert operation

Throws:

ValqueriesInsertFailedException - if the insert statement fails

upsert

public CrudRepository.CrudUpdateResult upsert(Collection<T> t,
 Consumer<ValqueriesUpsertUpdate<T>> updater)

Description copied from interface: ValqueriesCrudRepository

Inserts a new entry or updates an existing entry in the database. Important to notice: no Relation will be persisted. If the entity to be inserted contains relations, they will have to be inserted manually.

You can use this method instead of CrudRepository.save(Object) if you need a custom update operation. Existing fields are matched based on any key, primary or unique. If the primary key is auto-increment, its value has to be `null` and at least one unique key needs to exist. If existing entry is not matched, the entry will be inserted as is. If existing entry is matched, only the fields that are set by the updater argument will be updated.

Due to different behavior of supported database vendors, case where multiple upserted entities match the same row in the database is not supported, and case where one upserted entity matches multiple rows in the database will result in update of at least one of the rows. If the primary key is auto-increment and only one entity is being upserted, the primary key of the entity will be set to the value of the inserted / updated row.

Specified by:

upsert in interface ValqueriesCrudRepository<T,K>

Parameters:

t - the entities to be upserted

updater - the function to specify the update operation

Returns:

the result of the upsert operation

upsert

public CrudRepository.CrudUpdateResult upsert(ITransactionContext tx,
 Collection<T> t,
 Consumer<ValqueriesUpsertUpdate<T>> updater)

Description copied from interface: ValqueriesCrudRepository

Inserts a new entry or updates an existing entry in the database in a transaction. Important to notice: no Relation will be persisted. If the entity to be inserted contains relations, they will have to be inserted manually.

You can use this method instead of ValqueriesCrudRepository.save(ITransactionContext, T) if you need a custom update operation. Existing fields are matched based on any key, primary or unique. If the primary key is auto-increment, its value has to be `null` and at least one unique key needs to exist. If existing entry is not matched, the entry will be inserted as is. If existing entry is matched, only the fields that are set by the updater argument will be updated.

Due to different behavior of supported database vendors, case where multiple upserted entities match the same row in the database is not supported, and case where one upserted entity matches multiple rows in the database will result in update of at least one of the rows. If the primary key is auto-increment and only one entity is being upserted, the primary key of the entity will be set to the value of the inserted / updated row.

Specified by:

upsert in interface ValqueriesCrudRepository<T,K>

Parameters:

tx - the transaction context (will be rolled-back if an error occurs)

t - the entities to be upserted

updater - the function to specify the update operation

Returns:

the result of the upsert operation

query

protected ValqueriesQuery<T> query()

query

protected <O> ValqueriesQuery<O> query(Class<O> oClass)

query

protected ValqueriesQuery<T> query(ITransactionContext tx)

query

protected <O> ValqueriesQuery<O> query(ITransactionContext tx,
 Class<O> oClass)

obtainInTransaction

public <X> X obtainInTransaction(ITransactionWithResult<X> tx)

Description copied from interface: ValqueriesCrudRepository

Used to perform multiple operations in a transaction, ultimately returning a result.

Specified by:

obtainInTransaction in interface ValqueriesCrudRepository<T,K>

Type Parameters:

X - the type of the result

Parameters:

tx - the function to be executed which takes ITransactionContext

Returns:

the result of the function

doRetryableInTransaction

public void doRetryableInTransaction(ITransaction tx)

Description copied from interface: ValqueriesCrudRepository

Used to perform multiple operations in a transaction, with a retry mechanism in case of a transaction deadlock.

Specified by:

doRetryableInTransaction in interface ValqueriesCrudRepository<T,K>

Parameters:

tx - the function to be executed which takes ITransactionContext