|
|||||||||
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
org.neodatis.odb.impl.core.server.layers.layer3.engine.ClientStorageEngine
public class ClientStorageEngine
Field Summary | |
---|---|
protected java.lang.String |
connectionId
|
protected IIntrospectionCallback |
introspectionCallbackForInsert
This is a visitor used to execute some specific action(like calling 'Before Insert Trigger') when introspecting an object |
protected IIntrospectionCallback |
introspectionCallbackForUpdate
This is a visitor used to execute some specific action when introspecting an object |
static java.lang.String |
LOG_ID
|
protected IMessageStreamer |
messageStreamer
|
static int |
nbcalls
|
static int |
nbdiffcalls
|
protected IOSocketParameter |
parameters
|
protected ICoreProvider |
provider
|
protected java.util.List<ReturnValueProcessor> |
returnValueProcessors
|
Fields inherited from class org.neodatis.odb.impl.core.layers.layer3.engine.StorageEngineAdapter |
---|
currentTransactionId, isClosed, triggerManager |
Constructor Summary | |
---|---|
|
ClientStorageEngine(IOSocketParameter parameters)
|
protected |
ClientStorageEngine(java.lang.String hostName,
int port,
java.lang.String baseId)
|
protected |
ClientStorageEngine(java.lang.String hostName,
int port,
java.lang.String baseId,
java.lang.String user,
java.lang.String password)
|
Method Summary | ||
---|---|---|
ClassInfoList |
addClasses(ClassInfoList classInfoList)
TODO Remove comment public ClassInfo addClass(ClassInfo newClassInfo, boolean addDependentClasses) { ClassInfoList ciList = new ClassInfoList(newClassInfo); ciList = addClasses(ciList); return session.getMetaModel ().getClassInfo(newClassInfo.getFullClassName(),true); } |
|
void |
addCommitListener(ICommitListener commitListener)
|
|
void |
addDeleteTrigger(java.lang.Class clazz,
DeleteTrigger trigger)
|
|
void |
addDeleteTrigger(DeleteTrigger trigger)
|
|
void |
addIndexOn(java.lang.String className,
java.lang.String indexName,
java.lang.String[] indexFields,
boolean verbose,
boolean acceptMultipleValuesForSameKey)
|
|
void |
addInsertTrigger(java.lang.Class clazz,
InsertTrigger trigger)
|
|
void |
addInsertTrigger(InsertTrigger trigger)
|
|
void |
addOidTrigger(java.lang.Class clazz,
OIDTrigger trigger)
|
|
void |
addOidTrigger(OIDTrigger trigger)
|
|
void |
addSelectTrigger(java.lang.Class clazz,
SelectTrigger trigger)
|
|
void |
addSelectTrigger(SelectTrigger trigger)
|
|
void |
addSession(ISession session,
boolean readMetamodel)
|
|
void |
addUpdateTrigger(java.lang.Class clazz,
UpdateTrigger trigger)
|
|
void |
addUpdateTrigger(UpdateTrigger trigger)
|
|
ISession |
buildDefaultSession()
|
|
IObjectIntrospector |
buildObjectIntrospector()
|
|
IObjectReader |
buildObjectReader()
|
|
IObjectWriter |
buildObjectWriter()
|
|
ITriggerManager |
buildTriggerManager()
|
|
void |
close()
|
|
void |
commit()
|
|
long |
count(CriteriaQuery query)
|
|
void |
defragmentTo(java.lang.String newFileName)
|
|
OID |
delete(java.lang.Object object,
boolean cascade)
Actually deletes an object database |
|
void |
deleteIndex(java.lang.String className,
java.lang.String indexName,
boolean verbose)
|
|
void |
deleteObjectWithOid(OID oid,
boolean cascade)
Delete an object from the database with the id |
|
void |
disconnect(java.lang.Object object)
Used to disconnect the object from the current session. |
|
IBaseIdentification |
getBaseIdentification()
|
|
ClassRepresentation |
getClassRepresentation(java.lang.Class clazz)
|
|
IOdbList<ICommitListener> |
getCommitListeners()
|
|
NonNativeObjectInfo |
getMetaObjectFromOid(OID oid)
FIXME : not very efficient because it retrieves the full object |
|
java.lang.Object |
getObjectFromOid(OID oid)
|
|
OID |
getObjectId(java.lang.Object object,
boolean throwExceptionIfDoesNotExist)
|
|
ObjectInfoHeader |
getObjectInfoHeaderFromOid(OID oid,
boolean useCache)
|
|
|
getObjectInfos(IQuery query,
boolean inMemory,
int startIndex,
int endIndex,
boolean returnOjects)
Return Meta representation of objects |
|
|
getObjectInfos(java.lang.String fullClassName,
boolean inMemory,
int startIndex,
int endIndex,
boolean returnOjects)
|
|
IObjectIntrospector |
getObjectIntrospector()
|
|
|
getObjects(java.lang.Class clazz)
|
|
|
getObjects(java.lang.Class clazz,
boolean inMemory)
|
|
|
getObjects(java.lang.Class clazz,
boolean inMemory,
int startIndex,
int endIndex)
|
|
|
getObjects(IQuery query)
|
|
|
getObjects(IQuery query,
boolean inMemory)
|
|
|
getObjects(IQuery query,
boolean inMemory,
int startIndex,
int endIndex)
|
|
IRefactorManager |
getRefactorManager()
Returns the object used to refactor the database |
|
ISession |
getSession(boolean throwExceptionIfDoesNotExist)
|
|
ITriggerManager |
getTriggerManager()
|
|
Values |
getValues(IValuesQuery query,
int startIndex,
int endIndex)
|
|
protected void |
initMessageStreamer()
|
|
protected void |
initODBConnection()
|
|
void |
internalDeleteObjectWithOid(OID oid,
boolean cascade)
Delete an object from the database with the id |
|
OID |
internalStore(OID oid,
java.lang.Object object,
boolean forceUpdate)
This method is synchronized to allow multi-threading. |
|
boolean |
isLocal()
Used to know if the storage engine is executed in local mode (embedded mode) or client server mode |
|
void |
rebuildIndex(java.lang.String className,
java.lang.String indexName,
boolean verbose)
|
|
void |
reconnect(java.lang.Object object,
OID oid)
Reconnect an object to the current session. |
|
void |
resetCommitListeners()
|
|
void |
rollback()
|
|
void |
run()
or shutdown hook |
|
Message |
sendMessage(Message msg)
Opens socket send message and close. |
|
OID |
store(java.lang.Object object)
Store an object in an database. |
|
OID |
store(OID oid,
java.lang.Object object)
|
|
OID |
updateObject(NonNativeObjectInfo nnoi2,
boolean forceUpdate)
Updates an object already transformed into meta representation! |
|
OID |
writeObjectInfo(OID oid,
NonNativeObjectInfo aoi,
long position,
boolean updatePointers)
Write an object already transformed into meta representation! |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String LOG_ID
public static int nbcalls
public static int nbdiffcalls
protected IMessageStreamer messageStreamer
protected java.lang.String connectionId
protected IOSocketParameter parameters
protected ICoreProvider provider
protected IIntrospectionCallback introspectionCallbackForInsert
protected IIntrospectionCallback introspectionCallbackForUpdate
protected java.util.List<ReturnValueProcessor> returnValueProcessors
Constructor Detail |
---|
protected ClientStorageEngine(java.lang.String hostName, int port, java.lang.String baseId)
protected ClientStorageEngine(java.lang.String hostName, int port, java.lang.String baseId, java.lang.String user, java.lang.String password)
public ClientStorageEngine(IOSocketParameter parameters)
Method Detail |
---|
public ISession buildDefaultSession()
protected void initMessageStreamer()
protected void initODBConnection()
public Message sendMessage(Message msg)
msg
-
public void commit()
commit
in interface IStorageEngine
commit
in class StorageEngineAdapter
public void close()
close
in interface IStorageEngine
close
in class StorageEngineAdapter
public void rollback()
rollback
in interface IStorageEngine
rollback
in class StorageEngineAdapter
public OID store(java.lang.Object object)
IStorageEngine
public OID store(OID oid, java.lang.Object object)
public OID internalStore(OID oid, java.lang.Object object, boolean forceUpdate)
public ClassInfoList addClasses(ClassInfoList classInfoList)
addClasses
in interface IStorageEngine
addClasses
in class StorageEngineAdapter
public <T> Objects<T> getObjects(java.lang.Class clazz)
public <T> Objects<T> getObjects(java.lang.Class clazz, boolean inMemory)
public <T> Objects<T> getObjects(java.lang.Class clazz, boolean inMemory, int startIndex, int endIndex)
getObjects
in interface IStorageEngine
getObjects
in class StorageEngineAdapter
public long count(CriteriaQuery query)
public OID delete(java.lang.Object object, boolean cascade)
IStorageEngine
delete
in interface IStorageEngine
delete
in class StorageEngineAdapter
public void deleteObjectWithOid(OID oid, boolean cascade)
oid
- The object id to be deleted @public void internalDeleteObjectWithOid(OID oid, boolean cascade)
oid
- The object id to be deleted @public <T> Objects<T> getObjects(IQuery query)
public <T> Objects<T> getObjects(IQuery query, boolean inMemory)
public <T> Objects<T> getObjects(IQuery query, boolean inMemory, int startIndex, int endIndex)
getObjects
in interface IStorageEngine
getObjects
in class StorageEngineAdapter
public Values getValues(IValuesQuery query, int startIndex, int endIndex)
public OID getObjectId(java.lang.Object object, boolean throwExceptionIfDoesNotExist)
getObjectId
in interface IStorageEngine
getObjectId
in class StorageEngineAdapter
public java.lang.Object getObjectFromOid(OID oid)
public NonNativeObjectInfo getMetaObjectFromOid(OID oid)
public ObjectInfoHeader getObjectInfoHeaderFromOid(OID oid, boolean useCache)
public void defragmentTo(java.lang.String newFileName)
defragmentTo
in interface IStorageEngine
defragmentTo
in class StorageEngineAdapter
public ClassRepresentation getClassRepresentation(java.lang.Class clazz)
public void run()
public void addUpdateTrigger(UpdateTrigger trigger)
public void addInsertTrigger(InsertTrigger trigger)
public void addOidTrigger(OIDTrigger trigger)
public void addDeleteTrigger(DeleteTrigger trigger)
public void addSelectTrigger(SelectTrigger trigger)
public IBaseIdentification getBaseIdentification()
public <T> Objects<T> getObjectInfos(IQuery query, boolean inMemory, int startIndex, int endIndex, boolean returnOjects)
IStorageEngine
getObjectInfos
in interface IStorageEngine
getObjectInfos
in class StorageEngineAdapter
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 <T> Objects<T> getObjectInfos(java.lang.String fullClassName, boolean inMemory, int startIndex, int endIndex, boolean returnOjects)
public ISession getSession(boolean throwExceptionIfDoesNotExist)
getSession
in interface IStorageEngine
getSession
in class StorageEngineAdapter
public OID updateObject(NonNativeObjectInfo nnoi2, boolean forceUpdate)
IStorageEngine
nnoi2
- The Object Meta representation
public OID writeObjectInfo(OID oid, NonNativeObjectInfo aoi, long position, boolean updatePointers)
IStorageEngine
public void addSession(ISession session, boolean readMetamodel)
public void addIndexOn(java.lang.String className, java.lang.String indexName, java.lang.String[] indexFields, boolean verbose, boolean acceptMultipleValuesForSameKey)
className
- The class name on which the index must be createdindexName
- The name of the indexindexFields
- The list of fields of the indexverbose
- A boolean value to indicate of ODB must describe what it is
doing @ @public void rebuildIndex(java.lang.String className, java.lang.String indexName, boolean verbose)
public void deleteIndex(java.lang.String className, java.lang.String indexName, boolean verbose)
public void addCommitListener(ICommitListener commitListener)
public IOdbList<ICommitListener> getCommitListeners()
public IRefactorManager getRefactorManager()
IStorageEngine
public void resetCommitListeners()
public boolean isLocal()
IStorageEngine
public ITriggerManager getTriggerManager()
getTriggerManager
in interface IStorageEngine
getTriggerManager
in class StorageEngineAdapter
public void disconnect(java.lang.Object object)
IStorageEngine
disconnect
in interface IStorageEngine
disconnect
in class StorageEngineAdapter
public void reconnect(java.lang.Object object, OID oid)
This code is duplicated here because we don't have ObjectReader on client side, so all needed object reader methods are implement in the ClientStorageEngine class
public void addDeleteTrigger(java.lang.Class clazz, DeleteTrigger trigger)
addDeleteTrigger
in class StorageEngineAdapter
public void addInsertTrigger(java.lang.Class clazz, InsertTrigger trigger)
addInsertTrigger
in class StorageEngineAdapter
public void addOidTrigger(java.lang.Class clazz, OIDTrigger trigger)
addOidTrigger
in class StorageEngineAdapter
public void addSelectTrigger(java.lang.Class clazz, SelectTrigger trigger)
addSelectTrigger
in class StorageEngineAdapter
public void addUpdateTrigger(java.lang.Class clazz, UpdateTrigger trigger)
addUpdateTrigger
in class StorageEngineAdapter
public IObjectIntrospector buildObjectIntrospector()
public IObjectReader buildObjectReader()
public IObjectWriter buildObjectWriter()
public ITriggerManager buildTriggerManager()
public IObjectIntrospector getObjectIntrospector()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |