io.daobab.result

Class EntityByteBuffer<E extends Entity>

java.lang.Object

io.daobab.target.BaseTarget

io.daobab.result.BaseByteBuffer<E>

io.daobab.result.EntityByteBuffer<E>

All Implemented Interfaces:

ILoggerBean, QueryReceiver, QueryTarget, StatisticCollectorProvider, StatisticProvider, Target

public class EntityByteBuffer<E extends Entity>
extends BaseByteBuffer<E>

Field Summary

Fields

Modifier and Type	Field and Description
protected Class<E>	entityClass

Fields inherited from class io.daobab.result.BaseByteBuffer

additionalParameters, bitBufferedClasses, bitFieldOperations, bufferStatic, columnOrderIntoEntityHashMap, columns, columnsPositionsQueue, indexRepository, isIndexRepositoryEmpty, locations, pageMaxCapacity, pageMaxCapacityBytes, pages, removed, totalBufferActiveElements, totalBufferSize, totalEntitySpace

Fields inherited from class io.daobab.target.BaseTarget

entityAny, log

Constructor Summary

Constructors

Constructor and Description
EntityByteBuffer(E entity)
EntityByteBuffer(E entity, int capacity)
EntityByteBuffer(List<E> entities)

Method Summary

Modifier and Type	Method and Description
boolean	add(E entity)
OpenedTransactionTarget	beginTransaction()
<E extends Entity> int	delete(QueryDelete<E> query, boolean transaction)
<E extends Entity> int	delete(QueryDelete<E> query, Propagation propagation)
List<E>	finalFilter(Query<E,?> query)
E	get(int i)
Plate	getPlate(int i, Collection<TableColumn> chosenColumns)
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()
boolean	isTransactionActive()
<E extends Entity> E	readEntity(QueryEntity<E> query)
<E1 extends Entity> Entities<E1>	readEntityList(QueryEntity<E1> 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)
void	remove(int position)
<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.result.BaseByteBuffer

adjustForCapacity, determineBitField, determineIndex, filterUsingIndexes, finalFilter, finalFilterField, getBufferMemoryUsage, getBufferPositionOfColumn, getColumnIntoEntityPosition, getLog, getNextFreeLocation, getPages, getValue, getValueForColumnPosition, isBufferStatic, isEmpty, mayBeBitBuffered, mergeIfNecessary, setBufferStatic, size

Methods inherited from class io.daobab.target.BaseTarget

addInterceptor, addInterceptorForAllEntities, afterDelete, afterInsert, afterUpdate, areInterceptorInUse, beforeDelete, beforeInsert, beforeUpdate, enableStatisticCollecting, getAccessProtector, getInterceptorsForEntity, getInterceptorsMap, getStatisticCollector, getStatistics, handleTransactionalTarget, isStatisticCollectingEnabled, 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

Field Detail

entityClass

protected Class<E extends Entity> entityClass

Constructor Detail

EntityByteBuffer

public EntityByteBuffer(List<E> entities)

EntityByteBuffer

public EntityByteBuffer(E entity)

EntityByteBuffer

public EntityByteBuffer(E entity,
                        int capacity)

Method Detail

remove

public void remove(int position)

add

public boolean add(E entity)

getPlate

public Plate getPlate(int i,
                      Collection<TableColumn> chosenColumns)

Overrides:

getPlate in class BaseByteBuffer<E extends Entity>

get

public E get(int i)

finalFilter

public List<E> finalFilter(Query<E,?> query)

readEntity

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

readEntityList

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

readField

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

readFieldList

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

readPlate

public Plate readPlate(QueryPlate query)

Specified by:

readPlate in interface QueryReceiver

Overrides:

readPlate in class BaseByteBuffer<E extends Entity>

readPlateList

public Plates readPlateList(QueryPlate query)

Specified by:

readPlateList in interface QueryReceiver

Overrides:

readPlateList in class BaseByteBuffer<E extends Entity>

delete

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

Specified by:

delete in interface QueryReceiver

Overrides:

delete in class BaseByteBuffer<E extends Entity>

update

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

Specified by:

update in interface QueryReceiver

Overrides:

update in class BaseByteBuffer<E extends Entity>

insert

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

Specified by:

insert in interface QueryReceiver

Overrides:

insert in class BaseByteBuffer<E extends Entity>

delete

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

Specified by:

delete in interface QueryReceiver

Overrides:

delete in class BaseByteBuffer<E extends Entity>

update

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

Specified by:

update in interface QueryReceiver

Overrides:

update in class BaseByteBuffer<E extends Entity>

insert

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

Specified by:

insert in interface QueryReceiver

Overrides:

insert in class BaseByteBuffer<E extends Entity>

isBuffer

public boolean isBuffer()

Specified by:

isBuffer in interface Target

Overrides:

isBuffer in class BaseByteBuffer<E extends Entity>

isConnectedToDatabase

public boolean isConnectedToDatabase()

Specified by:

isConnectedToDatabase in interface Target

Overrides:

isConnectedToDatabase in class BaseByteBuffer<E extends Entity>

beginTransaction

public OpenedTransactionTarget beginTransaction()

Specified by:

beginTransaction in interface Target

Overrides:

beginTransaction in class BaseByteBuffer<E extends Entity>

getTables

public List<Entity> getTables()

Specified by:

getTables in interface Target

Overrides:

getTables in class BaseByteBuffer<E extends Entity>

isTransactionActive

public boolean isTransactionActive()

Specified by:

isTransactionActive in interface Target

Overrides:

isTransactionActive in class BaseByteBuffer<E extends Entity>

isLogQueriesEnabled

public boolean isLogQueriesEnabled()

Specified by:

isLogQueriesEnabled in interface Target

Overrides:

isLogQueriesEnabled in class BaseByteBuffer<E extends Entity>

toSqlQuery

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