Package com.orientechnologies.orient.core.db

Class OSharedContextEmbedded

java.lang.Object

com.orientechnologies.common.listener.OListenerManger<OMetadataUpdateListener>

com.orientechnologies.orient.core.db.OSharedContext

com.orientechnologies.orient.core.db.OSharedContextEmbedded

Direct Known Subclasses:

OSharedContextDistributed

public class OSharedContextEmbedded
extends OSharedContext

Created by tglman on 13/06/17.

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<String,DistributedQueryContext>	activeDistributedQueries
protected OExecutionPlanCache	executionPlanCache
protected OFunctionLibraryImpl	functionLibrary
protected OIndexManagerAbstract	indexManager
protected OLiveQueryHook.OLiveQueryOps	liveQueryOps
protected OLiveQueryHookV2.OLiveQueryOps	liveQueryOpsV2
protected boolean	loaded
protected OrientDBEmbedded	orientDB
protected static final OProfiler	PROFILER
protected OQueryStats	queryStats
protected Map<String,Object>	resources
protected OSchedulerImpl	scheduler
protected OSchemaShared	schema
protected OSecurityInternal	security
protected OSequenceLibraryImpl	sequenceLibrary
protected OStatementCache	statementCache
protected OStorage	storage
protected OStringCache	stringCache
protected ODistributedSynchronizedSequence	transactionSequence
protected ViewManager	viewManager

Constructor Summary

Constructors

Constructor	Description
OSharedContextEmbedded(OStorage storage, OrientDBEmbedded orientDB)

Method Summary

Modifier and Type	Method	Description
void	close()
void	create(ODatabaseDocumentInternal database)
void	endSession()
Map<String,DistributedQueryContext>	getActiveDistributedQueries()
OExecutionPlanCache	getExecutionPlanCache()
OFunctionLibraryImpl	getFunctionLibrary()
OIndexManagerAbstract	getIndexManager()
long	getLastCloseTime()
OLiveQueryHook.OLiveQueryOps	getLiveQueryOps()
OLiveQueryHookV2.OLiveQueryOps	getLiveQueryOpsV2()
OrientDBInternal	getOrientDB()
OQueryStats	getQueryStats()
<T> T	getResource(String name, Callable<T> factory)
OSchedulerImpl	getScheduler()
OSchemaShared	getSchema()
OSecurityInternal	getSecurity()
OSequenceLibraryImpl	getSequenceLibrary()
int	getSessionCount()
OStatementCache	getStatementCache()
OStorage	getStorage()
OStringCache	getStringCache()
ODistributedSynchronizedSequence	getTransactionSequence()
ViewManager	getViewManager()
protected void	init(OStorage storage)
protected void	internalClose()
protected void	internalCreate(ODatabaseDocumentInternal database)
protected void	internalLoad(ODatabaseDocumentInternal database)
protected void	internalReload(ODatabaseDocumentInternal database)
protected Optional<Future<Void>>	internalUnload()
boolean	isLoaded()
void	load(ODatabaseDocumentInternal database)
ODocument	loadConfig(ODatabaseSession session, String name)
ODocument	loadDistributedConfig(ODatabaseSession session)
void	reInit(OStorage storage, ODatabaseDocumentInternal database)
void	reload(ODatabaseDocumentInternal database)
void	saveConfig(ODatabaseSession session, String name, ODocument value)	Store a configuration with a key, without checking eventual update version.
void	startSession()
void	unload()

Methods inherited from class com.orientechnologies.common.listener.OListenerManger

browseListeners, getListenersCopy, registerListener, resetListeners, unregisterListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

PROFILER

protected static final OProfiler PROFILER

orientDB

protected OrientDBEmbedded orientDB

storage

protected OStorage storage

schema

protected OSchemaShared schema

security

protected OSecurityInternal security

indexManager

protected OIndexManagerAbstract indexManager

functionLibrary

protected OFunctionLibraryImpl functionLibrary

scheduler

protected OSchedulerImpl scheduler

sequenceLibrary

protected OSequenceLibraryImpl sequenceLibrary

liveQueryOps

protected OLiveQueryHook.OLiveQueryOps liveQueryOps

liveQueryOpsV2

protected OLiveQueryHookV2.OLiveQueryOps liveQueryOpsV2

statementCache

protected OStatementCache statementCache

executionPlanCache

protected OExecutionPlanCache executionPlanCache

queryStats

protected OQueryStats queryStats

loaded

protected volatile boolean loaded

resources

protected Map<String,Object> resources

stringCache

protected OStringCache stringCache

activeDistributedQueries

protected Map<String,DistributedQueryContext> activeDistributedQueries

viewManager

protected ViewManager viewManager

transactionSequence

protected ODistributedSynchronizedSequence transactionSequence

Constructor Details

OSharedContextEmbedded

public OSharedContextEmbedded(OStorage storage,
 OrientDBEmbedded orientDB)

Method Details

init

protected void init(OStorage storage)

load

public void load(ODatabaseDocumentInternal database)

Specified by:

load in class OSharedContext

internalLoad

protected void internalLoad(ODatabaseDocumentInternal database)

close

public void close()

Specified by:

close in class OSharedContext

internalClose

protected void internalClose()

unload

public void unload()

Specified by:

unload in class OSharedContext

internalUnload

protected Optional<Future<Void>> internalUnload()

reload

public void reload(ODatabaseDocumentInternal database)

Specified by:

reload in class OSharedContext

internalReload

protected void internalReload(ODatabaseDocumentInternal database)

create

public void create(ODatabaseDocumentInternal database)

internalCreate

protected void internalCreate(ODatabaseDocumentInternal database)

getActiveDistributedQueries

public Map<String,DistributedQueryContext> getActiveDistributedQueries()

getViewManager

public ViewManager getViewManager()

reInit

public void reInit(OStorage storage,
 ODatabaseDocumentInternal database)

Specified by:

reInit in class OSharedContext

loadConfig

public ODocument loadConfig(ODatabaseSession session,
 String name)

saveConfig

public void saveConfig(ODatabaseSession session,
 String name,
 ODocument value)

Store a configuration with a key, without checking eventual update version.

Parameters:

session -

name -

value -

loadDistributedConfig

public ODocument loadDistributedConfig(ODatabaseSession session)

getTransactionSequence

public ODistributedSynchronizedSequence getTransactionSequence()

isLoaded

public boolean isLoaded()

Specified by:

isLoaded in class OSharedContext

getSchema

public OSchemaShared getSchema()

Specified by:

getSchema in class OSharedContext

getSecurity

public OSecurityInternal getSecurity()

Specified by:

getSecurity in class OSharedContext

getIndexManager

public OIndexManagerAbstract getIndexManager()

Specified by:

getIndexManager in class OSharedContext

getFunctionLibrary

public OFunctionLibraryImpl getFunctionLibrary()

Specified by:

getFunctionLibrary in class OSharedContext

getScheduler

public OSchedulerImpl getScheduler()

Specified by:

getScheduler in class OSharedContext

getSequenceLibrary

public OSequenceLibraryImpl getSequenceLibrary()

Specified by:

getSequenceLibrary in class OSharedContext

getLiveQueryOps

public OLiveQueryHook.OLiveQueryOps getLiveQueryOps()

getLiveQueryOpsV2

public OLiveQueryHookV2.OLiveQueryOps getLiveQueryOpsV2()

getStatementCache

public OStatementCache getStatementCache()

getExecutionPlanCache

public OExecutionPlanCache getExecutionPlanCache()

getQueryStats

public OQueryStats getQueryStats()

getStorage

public OStorage getStorage()

Specified by:

getStorage in class OSharedContext

getOrientDB

public OrientDBInternal getOrientDB()

Specified by:

getOrientDB in class OSharedContext

getResource

public <T> T getResource(String name,
 Callable<T> factory)

Specified by:

getResource in class OSharedContext

getStringCache

public OStringCache getStringCache()

Specified by:

getStringCache in class OSharedContext

startSession

public void startSession()

Specified by:

startSession in class OSharedContext

endSession

public void endSession()

Specified by:

endSession in class OSharedContext

getSessionCount

public int getSessionCount()

Specified by:

getSessionCount in class OSharedContext

getLastCloseTime

public long getLastCloseTime()

Specified by:

getLastCloseTime in class OSharedContext