|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.neodatis.odb.impl.core.layers.layer3.engine.StorageEngineAdapter
public abstract class StorageEngineAdapter
An Adapter for IStorageEngine interface.
Field Summary | |
---|---|
protected TransactionId |
currentTransactionId
To keep track of current transaction Id |
protected boolean |
isClosed
|
protected ITriggerManager |
triggerManager
To manage triggers |
Constructor Summary | |
---|---|
StorageEngineAdapter()
|
Method Summary | ||
---|---|---|
ClassInfo |
addClass(ClassInfo newClassInfo,
boolean addDependentClasses)
|
|
ClassInfoList |
addClasses(ClassInfoList classInfoList)
|
|
abstract void |
addDeleteTrigger(java.lang.Class clazz,
DeleteTrigger trigger)
|
|
void |
addDeleteTriggerFor(java.lang.String className,
DeleteTrigger trigger)
|
|
abstract void |
addInsertTrigger(java.lang.Class clazz,
InsertTrigger trigger)
|
|
void |
addInsertTriggerFor(java.lang.String className,
InsertTrigger trigger)
|
|
abstract void |
addOidTrigger(java.lang.Class clazz,
OIDTrigger trigger)
|
|
void |
addOidTriggerFor(java.lang.String className,
OIDTrigger trigger)
|
|
abstract void |
addSelectTrigger(java.lang.Class clazz,
SelectTrigger trigger)
|
|
void |
addSelectTriggerFor(java.lang.String className,
SelectTrigger trigger)
|
|
abstract void |
addUpdateTrigger(java.lang.Class clazz,
UpdateTrigger trigger)
|
|
void |
addUpdateTriggerFor(java.lang.String className,
UpdateTrigger trigger)
|
|
CheckMetaModelResult |
checkMetaModelCompatibility(java.util.Map<java.lang.String,ClassInfo> currentCIs)
Receive the current class info (loaded from current java classes present on classpath and check against the persisted meta model |
|
void |
close()
|
|
void |
commit()
|
|
long |
count(java.lang.Class clazz)
|
|
long |
count(java.lang.String fullClassName)
|
|
CriteriaQuery |
criteriaQuery(java.lang.Class clazz)
|
|
CriteriaQuery |
criteriaQuery(java.lang.Class clazz,
ICriterion criterion)
|
|
void |
defragmentTo(java.lang.String newFileName)
|
|
OID |
delete(java.lang.Object object,
boolean cascade)
Actually deletes an object database |
|
void |
deleteObjectWithOid(long oid)
|
|
void |
disconnect(java.lang.Object object)
Used to disconnect the object from the current session. |
|
MetaModel |
get2MetaModel()
|
|
java.util.List<FullIDInfo> |
getAllObjectIdInfos(java.lang.String objectType,
boolean displayObjects)
|
|
java.util.List<java.lang.Long> |
getAllObjectIds()
|
|
OID |
getCurrentIdBlockMaxOid()
|
|
int |
getCurrentIdBlockNumber()
|
|
long |
getCurrentIdBlockPosition()
|
|
TransactionId |
getCurrentTransactionId()
|
|
DatabaseId |
getDatabaseId()
|
|
IFileSystemInterface |
getFsi()
|
|
OID |
getMaxOid()
|
|
java.lang.Object |
getObjectFromId(OID id)
|
|
OID |
getObjectId(java.lang.Object object,
boolean throwExceptionIfDoesNotExist)
|
|
|
getObjectInfos(IQuery query,
boolean inMemory,
int startIndex,
int endIndex,
boolean returnOjects)
Return Meta representation of objects |
|
|
getObjectInfos(java.lang.String fullClassName,
IQuery query,
boolean inMemory,
int startIndex,
int endIndex,
boolean returnOjects)
|
|
IObjectReader |
getObjectReader()
|
|
abstract
|
getObjects(java.lang.Class clazz,
boolean inMemory,
int startIndex,
int endIndex)
|
|
|
getObjects(IQuery query,
boolean inMemory,
int startIndex,
int endIndex)
|
|
|
getObjects(java.lang.String fullClassName,
IQuery query,
boolean inMemory,
int startIndex,
int endIndex)
|
|
IObjectWriter |
getObjectWriter()
|
|
ISession |
getSession(boolean throwExceptionIfDoesNotExist)
|
|
ITriggerManager |
getTriggerManager()
|
|
int |
getVersion()
|
|
OID |
internalDelete(ObjectInfoHeader header)
|
|
boolean |
isClosed()
|
|
long |
mainStoreObject(java.lang.Object object)
|
|
ClassInfo |
persistClass(ClassInfo newClassInfo,
int lastClassInfoIndex,
boolean addClass,
boolean addDependentClasses)
|
|
void |
reconnect(java.lang.Object object)
Used to reconnect an object to the current session |
|
void |
rollback()
|
|
void |
setCurrentIdBlockInfos(long currentBlockPosition,
int currentBlockNumber,
OID maxId)
|
|
void |
setCurrentTransactionId(TransactionId transactionId)
|
|
void |
setDatabaseId(DatabaseId databaseId)
|
|
void |
setDatabaseId(long[] databaseId)
|
|
void |
setLastODBCloseStatus(boolean lastCloseStatus)
|
|
void |
setMetaModel(MetaModel metaModel)
|
|
void |
setNbClasses(long nbClasses)
|
|
void |
setVersion(int version)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.neodatis.odb.core.layers.layer3.IStorageEngine |
---|
addCommitListener, addIndexOn, addSession, buildDefaultSession, buildObjectIntrospector, buildObjectReader, buildObjectWriter, buildTriggerManager, count, deleteIndex, deleteObjectWithOid, getBaseIdentification, getCommitListeners, getMetaObjectFromOid, getObjectFromOid, getObjectInfoHeaderFromOid, getObjectIntrospector, getRefactorManager, getValues, isLocal, rebuildIndex, resetCommitListeners, store, store, updateObject, writeObjectInfo |
Field Detail |
---|
protected TransactionId currentTransactionId
protected ITriggerManager triggerManager
protected boolean isClosed
Constructor Detail |
---|
public StorageEngineAdapter()
Method Detail |
---|
public ClassInfo addClass(ClassInfo newClassInfo, boolean addDependentClasses)
public ClassInfoList addClasses(ClassInfoList classInfoList)
addClasses
in interface IStorageEngine
public abstract void addDeleteTrigger(java.lang.Class clazz, DeleteTrigger trigger)
public abstract void addInsertTrigger(java.lang.Class clazz, InsertTrigger trigger)
public abstract void addOidTrigger(java.lang.Class clazz, OIDTrigger trigger)
public abstract void addSelectTrigger(java.lang.Class clazz, SelectTrigger trigger)
public abstract void addUpdateTrigger(java.lang.Class clazz, UpdateTrigger trigger)
public void close()
close
in interface IStorageEngine
public void commit()
commit
in interface IStorageEngine
public long count(java.lang.String fullClassName)
public long count(java.lang.Class clazz) throws java.lang.Exception
java.lang.Exception
public void defragmentTo(java.lang.String newFileName)
defragmentTo
in interface IStorageEngine
public OID delete(java.lang.Object object, boolean cascade)
IStorageEngine
delete
in interface IStorageEngine
public OID internalDelete(ObjectInfoHeader header)
public void deleteObjectWithOid(long oid) throws java.lang.Exception
java.lang.Exception
public java.util.List<FullIDInfo> getAllObjectIdInfos(java.lang.String objectType, boolean displayObjects)
getAllObjectIdInfos
in interface IStorageEngine
public java.util.List<java.lang.Long> getAllObjectIds()
getAllObjectIds
in interface IStorageEngine
public OID getCurrentIdBlockMaxOid()
getCurrentIdBlockMaxOid
in interface IStorageEngine
public int getCurrentIdBlockNumber()
getCurrentIdBlockNumber
in interface IStorageEngine
public long getCurrentIdBlockPosition()
getCurrentIdBlockPosition
in interface IStorageEngine
public IFileSystemInterface getFsi()
public OID getMaxOid()
getMaxOid
in interface IStorageEngine
public MetaModel get2MetaModel()
public java.lang.Object getObjectFromId(OID id) throws java.lang.Exception
java.lang.Exception
public OID getObjectId(java.lang.Object object, boolean throwExceptionIfDoesNotExist)
getObjectId
in interface IStorageEngine
public <T> Objects<T> getObjectInfos(java.lang.String fullClassName, IQuery query, boolean inMemory, int startIndex, int endIndex, boolean returnOjects) throws java.lang.Exception
java.lang.Exception
public <T> Objects<T> getObjectInfos(IQuery query, boolean inMemory, int startIndex, int endIndex, boolean returnOjects)
IStorageEngine
getObjectInfos
in interface IStorageEngine
query
- The query to select objectsinMemory
- To indicate if object must be all loaded in memorystartIndex
- First object indexendIndex
- Last object indexreturnOjects
- To indicate if object instances must be created
public IObjectReader getObjectReader()
getObjectReader
in interface IStorageEngine
public IObjectWriter getObjectWriter()
getObjectWriter
in interface IStorageEngine
public <T> Objects<T> getObjects(IQuery query, boolean inMemory, int startIndex, int endIndex)
getObjects
in interface IStorageEngine
public <T> Objects<T> getObjects(java.lang.String fullClassName, IQuery query, boolean inMemory, int startIndex, int endIndex) throws java.lang.Exception
java.lang.Exception
public ISession getSession(boolean throwExceptionIfDoesNotExist)
getSession
in interface IStorageEngine
public int getVersion()
getVersion
in interface IStorageEngine
public boolean isClosed()
isClosed
in interface IStorageEngine
public long mainStoreObject(java.lang.Object object) throws java.lang.Exception
java.lang.Exception
public ClassInfo persistClass(ClassInfo newClassInfo, int lastClassInfoIndex, boolean addClass, boolean addDependentClasses)
public void rollback()
rollback
in interface IStorageEngine
public void setCurrentIdBlockInfos(long currentBlockPosition, int currentBlockNumber, OID maxId)
setCurrentIdBlockInfos
in interface IStorageEngine
public void setDatabaseId(long[] databaseId)
public void setLastODBCloseStatus(boolean lastCloseStatus)
setLastODBCloseStatus
in interface IStorageEngine
public void setMetaModel(MetaModel metaModel)
setMetaModel
in interface IStorageEngine
public void setNbClasses(long nbClasses)
setNbClasses
in interface IStorageEngine
public void setVersion(int version)
setVersion
in interface IStorageEngine
public TransactionId getCurrentTransactionId()
getCurrentTransactionId
in interface IStorageEngine
public void setCurrentTransactionId(TransactionId transactionId)
setCurrentTransactionId
in interface IStorageEngine
public void setDatabaseId(DatabaseId databaseId)
setDatabaseId
in interface IStorageEngine
public DatabaseId getDatabaseId()
getDatabaseId
in interface IStorageEngine
public void disconnect(java.lang.Object object)
IStorageEngine
disconnect
in interface IStorageEngine
public void reconnect(java.lang.Object object)
IStorageEngine
reconnect
in interface IStorageEngine
public ITriggerManager getTriggerManager()
getTriggerManager
in interface IStorageEngine
public void addDeleteTriggerFor(java.lang.String className, DeleteTrigger trigger)
addDeleteTriggerFor
in interface IStorageEngine
public void addInsertTriggerFor(java.lang.String className, InsertTrigger trigger)
addInsertTriggerFor
in interface IStorageEngine
public void addOidTriggerFor(java.lang.String className, OIDTrigger trigger)
addOidTriggerFor
in interface IStorageEngine
public void addSelectTriggerFor(java.lang.String className, SelectTrigger trigger)
addSelectTriggerFor
in interface IStorageEngine
public void addUpdateTriggerFor(java.lang.String className, UpdateTrigger trigger)
addUpdateTriggerFor
in interface IStorageEngine
public abstract <T> Objects<T> getObjects(java.lang.Class clazz, boolean inMemory, int startIndex, int endIndex)
getObjects
in interface IStorageEngine
public CheckMetaModelResult checkMetaModelCompatibility(java.util.Map<java.lang.String,ClassInfo> currentCIs)
IStorageEngine
checkMetaModelCompatibility
in interface IStorageEngine
public CriteriaQuery criteriaQuery(java.lang.Class clazz, ICriterion criterion)
criteriaQuery
in interface IStorageEngine
public CriteriaQuery criteriaQuery(java.lang.Class clazz)
criteriaQuery
in interface IStorageEngine
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |