io.daobab.target.buffer

Class BufferedTarget

java.lang.Object

io.daobab.target.BaseTarget

io.daobab.target.buffer.BufferedTarget

All Implemented Interfaces:

ILoggerBean, BufferStorage, QueryReceiver, QueryTarget, StatisticCollectorProvider, StatisticProvider, Target

Direct Known Subclasses:

MetaSpecificsDataBaseTarget

public abstract class BufferedTarget
extends BaseTarget
implements BufferStorage, QueryTarget

Author:

Klaudiusz Wojtkowiak, (C) Elephant Software 2018-2021

Field Summary

Fields inherited from class io.daobab.target.BaseTarget

entityAny, log

Constructor Summary

Constructors

Constructor and Description
BufferedTarget()

Method Summary

Modifier and Type	Method and Description
OpenedTransactionTarget	beginTransaction()
<E extends Entity> int	delete(QueryDelete<E> query, boolean transaction)
<E extends Entity> int	delete(QueryDelete<E> query, Propagation propagation)
<E extends Entity> Entities<E>	getBuffer(Class<E> entityClazz)
<E extends Entity> Entities<E>	getBuffer(E entity)
protected abstract QueryTarget	getSourceTarget()
Map<Class<? extends Entity>,Entities<? extends Entity>>	getStorage()
List<Entity>	getTables()
<E extends Entity> E	insert(QueryInsert<E> query, boolean transaction)
<E extends Entity> E	insert(QueryInsert<E> query, Propagation propagation)
boolean	isBuffer()
boolean	isConnectedToDatabase()
boolean	isLogQueriesEnabled()
<E extends Entity> E	readEntity(QueryEntity<E> query)
<E extends Entity> Entities<E>	readEntityList(QueryEntity<E> query)
<E extends Entity,F> F	readField(QueryField<E,F> query)
<E extends Entity,F> List<F>	readFieldList(QueryField<E,F> query)
Plate	readPlate(QueryPlate query)
Plates	readPlateList(QueryPlate query)
<E extends Entity> void	refresh(Class<E> entityClazz)
protected <E extends Entity> void	register(Class<E> entityClazz)
protected <E extends Entity> void	register(Class<E> entityClazz, QueryEntity<E> refreshQuery)
<E extends Entity> String	toSqlQuery(Query<E,?> query)
<E extends Entity> int	update(QueryUpdate<E> query, boolean transaction)
<E extends Entity> int	update(QueryUpdate<E> query, Propagation propagation)

Methods inherited from class io.daobab.target.BaseTarget

addInterceptor, addInterceptorForAllEntities, afterDelete, afterInsert, afterUpdate, areInterceptorInUse, beforeDelete, beforeInsert, beforeUpdate, enableStatisticCollecting, getAccessProtector, getInterceptorsForEntity, getInterceptorsMap, getLog, getStatisticCollector, getStatistics, handleTransactionalTarget, isStatisticCollectingEnabled, isTransactionActive, setAccessProtector

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.daobab.target.QueryTarget

delete, deleteCollection, deletePkEntity, deletePkEntity, findAll, findAll, findFieldsByPk, findFieldsByPk, findManyByPk, findManyByPk, findOneByPk, findOneByPk, findOneByPk, getPrimaryKeyGenerator, insert, insertAll, insertAll, nativeSelect, nativeSelect, nativeSelect, select, select, select, select, select, selectRelated, update, update, update, update, updateWhole

Methods inherited from interface io.daobab.target.Target

aroundTransaction, isTransactionActive

Methods inherited from interface io.daobab.internallogger.ILoggerBean

getLog

Constructor Detail

BufferedTarget

public BufferedTarget()

Method Detail

getSourceTarget

protected abstract QueryTarget getSourceTarget()

isBuffer

public boolean isBuffer()

Specified by:

isBuffer in interface Target

isConnectedToDatabase

public boolean isConnectedToDatabase()

Specified by:

isConnectedToDatabase in interface Target

isLogQueriesEnabled

public boolean isLogQueriesEnabled()

Specified by:

isLogQueriesEnabled in interface Target

beginTransaction

public OpenedTransactionTarget beginTransaction()

Specified by:

beginTransaction in interface Target

register

protected <E extends Entity> void register(Class<E> entityClazz)

register

protected <E extends Entity> void register(Class<E> entityClazz,
                                           QueryEntity<E> refreshQuery)

refresh

public <E extends Entity> void refresh(Class<E> entityClazz)

getBuffer

public <E extends Entity> Entities<E> getBuffer(E entity)

Specified by:

getBuffer in interface BufferStorage

getBuffer

public <E extends Entity> Entities<E> getBuffer(Class<E> entityClazz)

Specified by:

getBuffer in interface BufferStorage

readEntityList

public <E extends Entity> Entities<E> readEntityList(QueryEntity<E> query)

Specified by:

readEntityList in interface QueryReceiver

readEntity

public <E extends Entity> E readEntity(QueryEntity<E> query)

Specified by:

readEntity in interface QueryReceiver

readPlate

public Plate readPlate(QueryPlate query)

Specified by:

readPlate in interface QueryReceiver

readField

public <E extends Entity,F> F readField(QueryField<E,F> query)

Specified by:

readField in interface QueryReceiver

insert

public <E extends Entity> E insert(QueryInsert<E> query,
                                   boolean transaction)

Specified by:

insert in interface QueryReceiver

insert

public <E extends Entity> E insert(QueryInsert<E> query,
                                   Propagation propagation)

Specified by:

insert in interface QueryReceiver

update

public <E extends Entity> int update(QueryUpdate<E> query,
                                     boolean transaction)

Specified by:

update in interface QueryReceiver

update

public <E extends Entity> int update(QueryUpdate<E> query,
                                     Propagation propagation)

Specified by:

update in interface QueryReceiver

readFieldList

public <E extends Entity,F> List<F> readFieldList(QueryField<E,F> query)

Specified by:

readFieldList in interface QueryReceiver

readPlateList

public Plates readPlateList(QueryPlate query)

Specified by:

readPlateList in interface QueryReceiver

delete

public <E extends Entity> int delete(QueryDelete<E> query,
                                     boolean transaction)

Specified by:

delete in interface QueryReceiver

delete

public <E extends Entity> int delete(QueryDelete<E> query,
                                     Propagation propagation)

Specified by:

delete in interface QueryReceiver

getTables

public List<Entity> getTables()

Specified by:

getTables in interface Target

getStorage

public Map<Class<? extends Entity>,Entities<? extends Entity>> getStorage()

Specified by:

getStorage in interface BufferStorage

toSqlQuery

public <E extends Entity> String toSqlQuery(Query<E,?> query)

Specified by:

toSqlQuery in interface QueryReceiver