org.neodatis.odb.impl
Class DefaultCoreProvider

java.lang.Object
  extended by org.neodatis.odb.impl.DefaultCoreProvider
All Implemented Interfaces:
ICoreProvider, ITwoPhaseInit

public class DefaultCoreProvider
extends java.lang.Object
implements ICoreProvider

The is the default implementation of ODB

Author:
olivier

Constructor Summary
DefaultCoreProvider()
           
 
Method Summary
 IByteArrayConverter getByteArrayConverter()
           
 IClassIntrospector getClassIntrospector()
           
 OID getClassOID(long oid)
           
 IClassPool getClassPool()
           
 IIdManager getClientIdManager(IStorageEngine engine)
           
 IClientObjectIntrospector getClientObjectIntrospector(IStorageEngine engine, java.lang.String connectionId)
           
 IObjectReader getClientObjectReader(IStorageEngine engine)
           
 IObjectWriter getClientObjectWriter(IStorageEngine engine)
           
 ISessionManager getClientServerSessionManager()
           
 ISession getClientSession(IStorageEngine engine)
           
 IStorageEngine getClientStorageEngine(IBaseIdentification baseIdentification)
           
 IMatchingObjectAction getCollectionQueryResultAction(IStorageEngine engine, IQuery query, boolean inMemory, boolean returnObjects)
          Returns the query result handler for normal query result (that return a collection of objects)
 OID getExternalClassOID(long oid)
           
 OID getExternalObjectOID(long objectOid, long classOid)
           
 IBufferedIO getIO(java.lang.String name, IBaseIdentification parameters, int bufferSize)
          TODO Return a list of IO to enable replication or other IO mechanism Used by the FileSystemInterface to actual write/read byte to underlying storage
 IInstanceBuilder getLocalInstanceBuilder(IStorageEngine engine)
          Returns the Local Instance Builder
 IObjectIntrospector getLocalObjectIntrospector(IStorageEngine engine)
           
 ISession getLocalSession(IStorageEngine engine)
           
 ITriggerManager getLocalTriggerManager(IStorageEngine engine)
           
 IMessageStreamer getMessageStreamer(java.net.Socket socket)
          (non-Javadoc)
 IMessageStreamer getMessageStreamer(java.lang.String host, int port, java.lang.String name)
           
 OID getObjectOID(long objectOid, long classOid)
           
 IRefactorManager getRefactorManager(IStorageEngine engine)
           
 IIdManager getServerIdManager(IStorageEngine engine)
           
 IInstanceBuilder getServerInstanceBuilder(IStorageEngine engine)
          Returns the Server Instance Builder
 IObjectIntrospector getServerObjectIntrospector(IStorageEngine engine)
           
 IObjectReader getServerObjectReader(IStorageEngine engine)
           
 IObjectWriter getServerObjectWriter(IStorageEngine engine)
           
 ISession getServerSession(IStorageEngine engine, java.lang.String sessionId)
           
 IServerStorageEngine getServerStorageEngine(IBaseIdentification baseIdentification)
           
 ITriggerManager getServerTriggerManager(IStorageEngine engine)
           
 ITransaction getTransaction(ISession session, IFileSystemInterface fsi)
           
 IWriteAction getWriteAction(long position, byte[] bytes)
           
 void init2()
          The second init phase
 void removeLocalTriggerManager(IStorageEngine engine)
           
 void resetClassDefinitions()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultCoreProvider

public DefaultCoreProvider()
Method Detail

init2

public void init2()
Description copied from interface: ITwoPhaseInit
The second init phase

Specified by:
init2 in interface ITwoPhaseInit

resetClassDefinitions

public void resetClassDefinitions()
Specified by:
resetClassDefinitions in interface ICoreProvider

getClientStorageEngine

public IStorageEngine getClientStorageEngine(IBaseIdentification baseIdentification)
Specified by:
getClientStorageEngine in interface ICoreProvider

getClientObjectWriter

public IObjectWriter getClientObjectWriter(IStorageEngine engine)
Specified by:
getClientObjectWriter in interface ICoreProvider

getClientObjectReader

public IObjectReader getClientObjectReader(IStorageEngine engine)
Specified by:
getClientObjectReader in interface ICoreProvider

getServerObjectWriter

public IObjectWriter getServerObjectWriter(IStorageEngine engine)
Specified by:
getServerObjectWriter in interface ICoreProvider

getServerObjectReader

public IObjectReader getServerObjectReader(IStorageEngine engine)
Specified by:
getServerObjectReader in interface ICoreProvider

getServerStorageEngine

public IServerStorageEngine getServerStorageEngine(IBaseIdentification baseIdentification)
Specified by:
getServerStorageEngine in interface ICoreProvider

getByteArrayConverter

public IByteArrayConverter getByteArrayConverter()
Specified by:
getByteArrayConverter in interface ICoreProvider

getIO

public IBufferedIO getIO(java.lang.String name,
                         IBaseIdentification parameters,
                         int bufferSize)
TODO Return a list of IO to enable replication or other IO mechanism Used by the FileSystemInterface to actual write/read byte to underlying storage

Specified by:
getIO in interface ICoreProvider
Parameters:
name - The name of the buffered io
parameters - The parameters that define the buffer
bufferSize - The size of the buffers
Returns:
The buffer implementation @

getLocalInstanceBuilder

public IInstanceBuilder getLocalInstanceBuilder(IStorageEngine engine)
Returns the Local Instance Builder

Specified by:
getLocalInstanceBuilder in interface ICoreProvider

getServerInstanceBuilder

public IInstanceBuilder getServerInstanceBuilder(IStorageEngine engine)
Returns the Server Instance Builder

Specified by:
getServerInstanceBuilder in interface ICoreProvider

getLocalObjectIntrospector

public IObjectIntrospector getLocalObjectIntrospector(IStorageEngine engine)
Specified by:
getLocalObjectIntrospector in interface ICoreProvider

getClientObjectIntrospector

public IClientObjectIntrospector getClientObjectIntrospector(IStorageEngine engine,
                                                             java.lang.String connectionId)
Specified by:
getClientObjectIntrospector in interface ICoreProvider

getServerObjectIntrospector

public IObjectIntrospector getServerObjectIntrospector(IStorageEngine engine)
Specified by:
getServerObjectIntrospector in interface ICoreProvider

getLocalTriggerManager

public ITriggerManager getLocalTriggerManager(IStorageEngine engine)
Specified by:
getLocalTriggerManager in interface ICoreProvider

removeLocalTriggerManager

public void removeLocalTriggerManager(IStorageEngine engine)
Specified by:
removeLocalTriggerManager in interface ICoreProvider

getServerTriggerManager

public ITriggerManager getServerTriggerManager(IStorageEngine engine)
Specified by:
getServerTriggerManager in interface ICoreProvider

getClassIntrospector

public IClassIntrospector getClassIntrospector()
Specified by:
getClassIntrospector in interface ICoreProvider

getClientIdManager

public IIdManager getClientIdManager(IStorageEngine engine)
Specified by:
getClientIdManager in interface ICoreProvider

getServerIdManager

public IIdManager getServerIdManager(IStorageEngine engine)
Specified by:
getServerIdManager in interface ICoreProvider

getClientServerSessionManager

public ISessionManager getClientServerSessionManager()
Specified by:
getClientServerSessionManager in interface ICoreProvider

getWriteAction

public IWriteAction getWriteAction(long position,
                                   byte[] bytes)
Specified by:
getWriteAction in interface ICoreProvider

getTransaction

public ITransaction getTransaction(ISession session,
                                   IFileSystemInterface fsi)
Specified by:
getTransaction in interface ICoreProvider

getLocalSession

public ISession getLocalSession(IStorageEngine engine)
Specified by:
getLocalSession in interface ICoreProvider

getClientSession

public ISession getClientSession(IStorageEngine engine)
Specified by:
getClientSession in interface ICoreProvider

getServerSession

public ISession getServerSession(IStorageEngine engine,
                                 java.lang.String sessionId)
Specified by:
getServerSession in interface ICoreProvider

getRefactorManager

public IRefactorManager getRefactorManager(IStorageEngine engine)
Specified by:
getRefactorManager in interface ICoreProvider

getCollectionQueryResultAction

public IMatchingObjectAction getCollectionQueryResultAction(IStorageEngine engine,
                                                            IQuery query,
                                                            boolean inMemory,
                                                            boolean returnObjects)
Description copied from interface: ICoreProvider
Returns the query result handler for normal query result (that return a collection of objects)

Specified by:
getCollectionQueryResultAction in interface ICoreProvider

getObjectOID

public OID getObjectOID(long objectOid,
                        long classOid)
Specified by:
getObjectOID in interface ICoreProvider

getClassOID

public OID getClassOID(long oid)
Specified by:
getClassOID in interface ICoreProvider

getExternalObjectOID

public OID getExternalObjectOID(long objectOid,
                                long classOid)
Specified by:
getExternalObjectOID in interface ICoreProvider

getExternalClassOID

public OID getExternalClassOID(long oid)
Specified by:
getExternalClassOID in interface ICoreProvider

getClassPool

public IClassPool getClassPool()
Specified by:
getClassPool in interface ICoreProvider

getMessageStreamer

public IMessageStreamer getMessageStreamer(java.net.Socket socket)
(non-Javadoc)

Specified by:
getMessageStreamer in interface ICoreProvider
Returns:
See Also:
ICoreProvider.getMessageStreamer(java.net.Socket)

getMessageStreamer

public IMessageStreamer getMessageStreamer(java.lang.String host,
                                           int port,
                                           java.lang.String name)
Specified by:
getMessageStreamer in interface ICoreProvider