com.orientechnologies.orient.core

Class Orient

java.lang.Object

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

com.orientechnologies.orient.core.Orient

public class Orient
extends OListenerManger<OOrientListener>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Orient.OShutdownOrientDBInstancesHandler Closes all storages and shutdown all engines.
class	Orient.OShutdownWorkersHandler Shutdown thread group which is used in methods submit(Callable) and submit(Runnable).

Field Summary

Fields

Modifier and Type	Field and Description
static String	ORIENTDB_HOME
static String	URL_SYNTAX

Method Summary

Modifier and Type	Method and Description
void	addDbLifecycleListener(ODatabaseLifecycleListener iListener)
void	addOrientDB(OrientDBInternal internal)
void	addShutdownHandler(OShutdownHandler shutdownHandler) Add handler which will be executed during shutdown() call.
ODatabaseThreadLocalFactory	getDatabaseThreadFactory()
Iterator<ODatabaseLifecycleListener>	getDbLifecycleListeners()
OEngine	getEngine(String engineName) Returns the engine by its name.
OEngine	getEngineIfRunning(String engineName) Obtains an engine instance with the given engineName, if it is running.
Set<String>	getEngines()
static String	getHomePath()
OLocalRecordCacheFactory	getLocalRecordCache()
OProfiler	getProfiler()
ORecordConflictStrategyFactory	getRecordConflictStrategy()
ORecordFactoryManager	getRecordFactoryManager()
OEngine	getRunningEngine(String engineName) Obtains a running engine instance with the given engineName.
OSecuritySystem	getSecurity()
OSignalHandler	getSignalHandler()
Collection<OStorage>	getStorages()
static String	getTempPath()
ThreadGroup	getThreadGroup()
ThreadPoolExecutor	getWorkers() Deprecated. This method is not thread safe. Use submit(java.util.concurrent.Callable) instead.
static Orient	instance()
boolean	isActive()
boolean	isInsideWebContainer()
static boolean	isRegisterDatabaseByPath() Tells if to register database by path.
boolean	isRunningDistributed()
boolean	isSelfManagedShutdown()
boolean	isWindowsOS()
void	onEmbeddedFactoryClose(OrientDBEmbedded embeddedFactory)
void	onEmbeddedFactoryInit(OrientDBEmbedded embeddedFactory)
void	registerEngine(OEngine iEngine)
void	registerListener(OOrientListener listener)
void	registerOrientStartupListener(OOrientStartupListener listener)
void	registerThreadDatabaseFactory(ODatabaseThreadLocalFactory iDatabaseFactory)
void	registerWeakOrientShutdownListener(OOrientShutdownListener listener)
void	registerWeakOrientStartupListener(OOrientStartupListener listener)
void	removeDbLifecycleListener(ODatabaseLifecycleListener iListener)
void	removeOrientDB(OrientDBInternal internal)
void	removeShutdownHook()
void	removeSignalHandler()
void	resetListeners()
TimerTask	scheduleTask(Runnable task, Date firstTime, long period)
TimerTask	scheduleTask(Runnable task, long delay, long period)
void	setProfiler(OAbstractProfiler iProfiler)
void	setRecordFactoryManager(ORecordFactoryManager iRecordFactoryManager)
static void	setRegisterDatabaseByPath(boolean iValue) Register database by path.
void	setRunningDistributed(boolean runningDistributed)
void	setSecurity(OSecuritySystem security)
Orient	shutdown()
Orient	startup()
static Orient	startUp(boolean insideWebContainer)
<V> Future<V>	submit(Callable<V> callable)
Future<?>	submit(Runnable runnable)
void	unregisterListener(OOrientListener listener)
void	unregisterOrientStartupListener(OOrientStartupListener listener)
void	unregisterWeakOrientShutdownListener(OOrientShutdownListener listener)
void	unregisterWeakOrientStartupListener(OOrientStartupListener listener)

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

browseListeners, getListenersCopy

Methods inherited from class java.lang.Object

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

Field Detail

ORIENTDB_HOME

public static final String ORIENTDB_HOME

See Also:

Constant Field Values

URL_SYNTAX

public static final String URL_SYNTAX

See Also:

Constant Field Values

Method Detail

isInsideWebContainer

public boolean isInsideWebContainer()

instance

public static Orient instance()

startUp

public static Orient startUp(boolean insideWebContainer)

getHomePath

public static String getHomePath()

getTempPath

public static String getTempPath()

isRegisterDatabaseByPath

public static boolean isRegisterDatabaseByPath()

Tells if to register database by path. Default is false. Setting to true allows to have multiple databases in different path with the same name.

See Also:

setRegisterDatabaseByPath(boolean)

setRegisterDatabaseByPath

public static void setRegisterDatabaseByPath(boolean iValue)

Register database by path. Default is false. Setting to true allows to have multiple databases in different path with the same name.

getRecordConflictStrategy

public ORecordConflictStrategyFactory getRecordConflictStrategy()

startup

public Orient startup()

addShutdownHandler

public void addShutdownHandler(OShutdownHandler shutdownHandler)

Add handler which will be executed during shutdown() call.

Parameters:

shutdownHandler - Shutdown handler instance.

shutdown

public Orient shutdown()

scheduleTask

public TimerTask scheduleTask(Runnable task,
                              long delay,
                              long period)

scheduleTask

public TimerTask scheduleTask(Runnable task,
                              Date firstTime,
                              long period)

isActive

public boolean isActive()

getWorkers

@Deprecated
public ThreadPoolExecutor getWorkers()

Deprecated. This method is not thread safe. Use submit(java.util.concurrent.Callable) instead.

submit

public Future<?> submit(Runnable runnable)

submit

public <V> Future<V> submit(Callable<V> callable)

isWindowsOS

public boolean isWindowsOS()

registerEngine

public void registerEngine(OEngine iEngine)
                    throws IllegalArgumentException

Throws:

IllegalArgumentException

getEngine

public OEngine getEngine(String engineName)

Returns the engine by its name.

Parameters:

engineName - Engine name to retrieve

Returns:

OEngine instance of found, otherwise null

getEngineIfRunning

public OEngine getEngineIfRunning(String engineName)

Obtains an engine instance with the given engineName, if it is running.

Parameters:

engineName - the name of the engine to obtain.

Returns:

the obtained engine instance or null if no such engine known or the engine is not running.

getRunningEngine

public OEngine getRunningEngine(String engineName)

Obtains a running engine instance with the given engineName. If engine is not running, starts it.

Parameters:

engineName - the name of the engine to obtain.

Returns:

the obtained running engine instance, never null.

Throws:

IllegalStateException - if an engine with the given is not found or failed to start.

getEngines

public Set<String> getEngines()

getStorages

public Collection<OStorage> getStorages()

removeShutdownHook

public void removeShutdownHook()

getSignalHandler

public OSignalHandler getSignalHandler()

removeSignalHandler

public void removeSignalHandler()

isSelfManagedShutdown

public boolean isSelfManagedShutdown()

getDbLifecycleListeners

public Iterator<ODatabaseLifecycleListener> getDbLifecycleListeners()

addDbLifecycleListener

public void addDbLifecycleListener(ODatabaseLifecycleListener iListener)

removeDbLifecycleListener

public void removeDbLifecycleListener(ODatabaseLifecycleListener iListener)

getThreadGroup

public ThreadGroup getThreadGroup()

getDatabaseThreadFactory

public ODatabaseThreadLocalFactory getDatabaseThreadFactory()

getRecordFactoryManager

public ORecordFactoryManager getRecordFactoryManager()

setRecordFactoryManager

public void setRecordFactoryManager(ORecordFactoryManager iRecordFactoryManager)

getProfiler

public OProfiler getProfiler()

setProfiler

public void setProfiler(OAbstractProfiler iProfiler)

getSecurity

public OSecuritySystem getSecurity()

setSecurity

public void setSecurity(OSecuritySystem security)

registerThreadDatabaseFactory

public void registerThreadDatabaseFactory(ODatabaseThreadLocalFactory iDatabaseFactory)

registerListener

public void registerListener(OOrientListener listener)

Overrides:

registerListener in class OListenerManger<OOrientListener>

unregisterListener

public void unregisterListener(OOrientListener listener)

Overrides:

unregisterListener in class OListenerManger<OOrientListener>

registerOrientStartupListener

public void registerOrientStartupListener(OOrientStartupListener listener)

registerWeakOrientStartupListener

public void registerWeakOrientStartupListener(OOrientStartupListener listener)

unregisterOrientStartupListener

public void unregisterOrientStartupListener(OOrientStartupListener listener)

unregisterWeakOrientStartupListener

public void unregisterWeakOrientStartupListener(OOrientStartupListener listener)

registerWeakOrientShutdownListener

public void registerWeakOrientShutdownListener(OOrientShutdownListener listener)

unregisterWeakOrientShutdownListener

public void unregisterWeakOrientShutdownListener(OOrientShutdownListener listener)

resetListeners

public void resetListeners()

Overrides:

resetListeners in class OListenerManger<OOrientListener>

getLocalRecordCache

public OLocalRecordCacheFactory getLocalRecordCache()

isRunningDistributed

public boolean isRunningDistributed()

setRunningDistributed

public void setRunningDistributed(boolean runningDistributed)

onEmbeddedFactoryInit

public void onEmbeddedFactoryInit(OrientDBEmbedded embeddedFactory)

onEmbeddedFactoryClose

public void onEmbeddedFactoryClose(OrientDBEmbedded embeddedFactory)

addOrientDB

public void addOrientDB(OrientDBInternal internal)

removeOrientDB

public void removeOrientDB(OrientDBInternal internal)