io.daobab.result

Class BaseByteBuffer<E>

java.lang.Object

io.daobab.target.BaseTarget

io.daobab.result.BaseByteBuffer<E>

All Implemented Interfaces:

ILoggerBean, QueryReceiver, QueryTarget, StatisticCollectorProvider, StatisticProvider, Target

Direct Known Subclasses:

EntityByteBuffer, PlateByteBuffer

public abstract class BaseByteBuffer<E>
extends BaseTarget
implements QueryTarget

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Integer,HashMap<String,Object>>	additionalParameters
protected static List<Class>	bitBufferedClasses
protected BitField[]	bitFieldOperations
protected boolean	bufferStatic
protected Map<String,Integer>	columnOrderIntoEntityHashMap
protected List<TableColumn>	columns
protected Integer[]	columnsPositionsQueue
protected BitBufferIndexBase[]	indexRepository
protected boolean	isIndexRepositoryEmpty
protected List<Integer>	locations
protected int	pageMaxCapacity
int	pageMaxCapacityBytes
protected List<ByteBuffer>	pages
protected LinkedList<Integer>	removed
protected AtomicInteger	totalBufferActiveElements
protected int	totalBufferSize
int	totalEntitySpace

Fields inherited from class io.daobab.target.BaseTarget

entityAny, log

Constructor Summary

Constructors

Constructor and Description
BaseByteBuffer()

Method Summary

Modifier and Type	Method and Description
protected void	adjustForCapacity(int capacity)
OpenedTransactionTarget	beginTransaction()
<E1 extends Entity> int	delete(QueryDelete<E1> query, boolean transaction)
<E1 extends Entity> int	delete(QueryDelete<E1> query, Propagation propagation)
protected BitField	determineBitField(Column column)
protected BitBufferIndexBase<?>	determineIndex(TableColumn infocolumn)
protected ResultBitBufferPositionWithSkipStepsWrapper	filterUsingIndexes(List<Integer> entitiesToHandle, Where wrapper)
protected List<Integer>	finalFilter(ResultBitBufferPositionWithSkipStepsWrapper rw, Query<?,?> query)
<F> List<F>	finalFilterField(QueryField<?,F> query)
long	getBufferMemoryUsage()
Integer	getBufferPositionOfColumn(Column column)
Integer	getColumnIntoEntityPosition(Column column)
org.slf4j.Logger	getLog()
protected Integer	getNextFreeLocation()
List<ByteBuffer>	getPages()
Plate	getPlate(int i, Collection<TableColumn> chosenColumns)
List<Entity>	getTables()
Object	getValue(int entityPosition, int columnPositionIntoEntity, int colOrder)
Object	getValueForColumnPosition(int entityPointer, int columnIntoEntityPosition, int columnBufferRowPosition)
<E1 extends Entity> E1	insert(QueryInsert<E1> query, boolean transaction)
<E1 extends Entity> E1	insert(QueryInsert<E1> query, Propagation propagation)
boolean	isBuffer()
boolean	isBufferStatic()
boolean	isConnectedToDatabase()
boolean	isEmpty()
boolean	isLogQueriesEnabled()
boolean	isTransactionActive()
protected boolean	mayBeBitBuffered(Column col)
protected void	mergeIfNecessary()
Plate	readPlate(QueryPlate query)
Plates	readPlateList(QueryPlate query)
void	setBufferStatic(boolean bufferStatic)
int	size()
<E1 extends Entity> int	update(QueryUpdate<E1> query, boolean transaction)
<E1 extends Entity> int	update(QueryUpdate<E1> query, Propagation propagation)

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.QueryReceiver

readEntity, readEntityList, readField, readFieldList, toSqlQuery

Methods inherited from interface io.daobab.target.Target

aroundTransaction

Field Detail

bitBufferedClasses

protected static List<Class> bitBufferedClasses

pageMaxCapacityBytes

public int pageMaxCapacityBytes

totalEntitySpace

public int totalEntitySpace

pageMaxCapacity

protected int pageMaxCapacity

totalBufferActiveElements

protected AtomicInteger totalBufferActiveElements

totalBufferSize

protected int totalBufferSize

pages

protected List<ByteBuffer> pages

columnOrderIntoEntityHashMap

protected Map<String,Integer> columnOrderIntoEntityHashMap

columnsPositionsQueue

protected Integer[] columnsPositionsQueue

bitFieldOperations

protected BitField[] bitFieldOperations

columns

protected List<TableColumn> columns

indexRepository

protected BitBufferIndexBase[] indexRepository

isIndexRepositoryEmpty

protected boolean isIndexRepositoryEmpty

bufferStatic

protected boolean bufferStatic

locations

protected List<Integer> locations

removed

protected LinkedList<Integer> removed

additionalParameters

protected Map<Integer,HashMap<String,Object>> additionalParameters

Constructor Detail

BaseByteBuffer

public BaseByteBuffer()

Method Detail

mayBeBitBuffered

protected boolean mayBeBitBuffered(Column col)

adjustForCapacity

protected void adjustForCapacity(int capacity)

getBufferMemoryUsage

public long getBufferMemoryUsage()

mergeIfNecessary

protected void mergeIfNecessary()

getNextFreeLocation

protected Integer getNextFreeLocation()

size

public int size()

isEmpty

public boolean isEmpty()

getPlate

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

getValue

public Object getValue(int entityPosition,
                       int columnPositionIntoEntity,
                       int colOrder)

determineBitField

protected BitField determineBitField(Column column)

getColumnIntoEntityPosition

public Integer getColumnIntoEntityPosition(Column column)

getBufferPositionOfColumn

public Integer getBufferPositionOfColumn(Column column)

getValueForColumnPosition

public Object getValueForColumnPosition(int entityPointer,
                                        int columnIntoEntityPosition,
                                        int columnBufferRowPosition)

finalFilterField

public <F> List<F> finalFilterField(QueryField<?,F> query)

getLog

public org.slf4j.Logger getLog()

Specified by:

getLog in interface ILoggerBean

Overrides:

getLog in class BaseTarget

readPlate

public Plate readPlate(QueryPlate query)

Specified by:

readPlate in interface QueryReceiver

readPlateList

public Plates readPlateList(QueryPlate query)

Specified by:

readPlateList in interface QueryReceiver

delete

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

Specified by:

delete in interface QueryReceiver

update

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

Specified by:

update in interface QueryReceiver

insert

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

Specified by:

insert in interface QueryReceiver

delete

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

Specified by:

delete in interface QueryReceiver

update

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

Specified by:

update in interface QueryReceiver

insert

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

Specified by:

insert in interface QueryReceiver

isBuffer

public boolean isBuffer()

Specified by:

isBuffer in interface Target

isConnectedToDatabase

public boolean isConnectedToDatabase()

Specified by:

isConnectedToDatabase in interface Target

beginTransaction

public OpenedTransactionTarget beginTransaction()

Specified by:

beginTransaction in interface Target

getTables

public List<Entity> getTables()

Specified by:

getTables in interface Target

isTransactionActive

public boolean isTransactionActive()

Specified by:

isTransactionActive in interface Target

Overrides:

isTransactionActive in class BaseTarget

isLogQueriesEnabled

public boolean isLogQueriesEnabled()

Specified by:

isLogQueriesEnabled in interface Target

finalFilter

protected List<Integer> finalFilter(ResultBitBufferPositionWithSkipStepsWrapper rw,
                                    Query<?,?> query)

filterUsingIndexes

protected ResultBitBufferPositionWithSkipStepsWrapper filterUsingIndexes(List<Integer> entitiesToHandle,
                                                                         Where wrapper)

determineIndex

protected BitBufferIndexBase<?> determineIndex(TableColumn infocolumn)

getPages

public List<ByteBuffer> getPages()

isBufferStatic

public boolean isBufferStatic()

setBufferStatic

public void setBufferStatic(boolean bufferStatic)