public abstract class BaseByteBuffer<E> extends BaseTarget implements QueryTarget
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 |
entityAny, log
Constructor and Description |
---|
BaseByteBuffer() |
addInterceptor, addInterceptorForAllEntities, afterDelete, afterInsert, afterUpdate, areInterceptorInUse, beforeDelete, beforeInsert, beforeUpdate, enableStatisticCollecting, getAccessProtector, getInterceptorsForEntity, getInterceptorsMap, getStatisticCollector, getStatistics, handleTransactionalTarget, isStatisticCollectingEnabled, setAccessProtector
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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
readEntity, readEntityList, readField, readFieldList, toSqlQuery
aroundTransaction
public int pageMaxCapacityBytes
public int totalEntitySpace
protected int pageMaxCapacity
protected AtomicInteger totalBufferActiveElements
protected int totalBufferSize
protected List<ByteBuffer> pages
protected Integer[] columnsPositionsQueue
protected BitField[] bitFieldOperations
protected List<TableColumn> columns
protected BitBufferIndexBase[] indexRepository
protected boolean isIndexRepositoryEmpty
protected boolean bufferStatic
protected LinkedList<Integer> removed
protected boolean mayBeBitBuffered(Column col)
protected void adjustForCapacity(int capacity)
public long getBufferMemoryUsage()
protected void mergeIfNecessary()
protected Integer getNextFreeLocation()
public int size()
public boolean isEmpty()
public Plate getPlate(int i, Collection<TableColumn> chosenColumns)
public Object getValue(int entityPosition, int columnPositionIntoEntity, int colOrder)
public Object getValueForColumnPosition(int entityPointer, int columnIntoEntityPosition, int columnBufferRowPosition)
public <F> List<F> finalFilterField(QueryField<?,F> query)
public org.slf4j.Logger getLog()
getLog
in interface ILoggerBean
getLog
in class BaseTarget
public Plate readPlate(QueryPlate query)
readPlate
in interface QueryReceiver
public Plates readPlateList(QueryPlate query)
readPlateList
in interface QueryReceiver
public <E1 extends Entity> int delete(QueryDelete<E1> query, boolean transaction)
delete
in interface QueryReceiver
public <E1 extends Entity> int update(QueryUpdate<E1> query, boolean transaction)
update
in interface QueryReceiver
public <E1 extends Entity> E1 insert(QueryInsert<E1> query, boolean transaction)
insert
in interface QueryReceiver
public <E1 extends Entity> int delete(QueryDelete<E1> query, Propagation propagation)
delete
in interface QueryReceiver
public <E1 extends Entity> int update(QueryUpdate<E1> query, Propagation propagation)
update
in interface QueryReceiver
public <E1 extends Entity> E1 insert(QueryInsert<E1> query, Propagation propagation)
insert
in interface QueryReceiver
public boolean isConnectedToDatabase()
isConnectedToDatabase
in interface Target
public OpenedTransactionTarget beginTransaction()
beginTransaction
in interface Target
public boolean isTransactionActive()
isTransactionActive
in interface Target
isTransactionActive
in class BaseTarget
public boolean isLogQueriesEnabled()
isLogQueriesEnabled
in interface Target
protected List<Integer> finalFilter(ResultBitBufferPositionWithSkipStepsWrapper rw, Query<?,?> query)
protected ResultBitBufferPositionWithSkipStepsWrapper filterUsingIndexes(List<Integer> entitiesToHandle, Where wrapper)
protected BitBufferIndexBase<?> determineIndex(TableColumn infocolumn)
public List<ByteBuffer> getPages()
public boolean isBufferStatic()
public void setBufferStatic(boolean bufferStatic)
Copyright © 2021. All rights reserved.