org.neodatis.odb.impl

Class DefaultCoreProvider

java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
DefaultCoreProvider()

Method Summary

Modifier and Type	Method and Description
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

equals, 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