Package com.orientechnologies.orient.core.db

Class OrientDBEmbedded

java.lang.Object

com.orientechnologies.orient.core.db.OrientDBEmbedded

All Implemented Interfaces:

OrientDBInternal, OSchedulerInternal, AutoCloseable

Direct Known Subclasses:

OrientDBDistributed

public class OrientDBEmbedded
extends Object
implements OrientDBInternal

Created by tglman on 08/04/16.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	OrientDBEmbedded.DatabaseFound

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	basePath
protected final OCachedDatabasePoolFactory	cachedPoolFactory
protected final OrientDBConfig	configurations
protected final AtomicInteger	dbCount
protected final Orient	orient
protected final Set<ODatabasePoolInternal>	pools
protected final Map<String,OSharedContext>	sharedContexts
protected final Map<String,OStorage>	storages

Constructor Summary

Constructors

Constructor	Description
OrientDBEmbedded(String directoryPath, OrientDBConfig configurations, Orient orient)

Method Summary

Modifier and Type	Method	Description
protected String	buildName(String name)
ODatabasePoolInternal	cachedPool(String database, String user, String password)
ODatabasePoolInternal	cachedPool(String database, String user, String password, OrientDBConfig config)
protected void	checkOpen()
void	close()	Close the factory with all related databases and pools.
void	create(String name, String user, String password, ODatabaseType type)	Create a new database
void	create(String name, String user, String password, ODatabaseType type, OrientDBConfig config)	Create a new database
void	create(String name, String user, String password, ODatabaseType type, OrientDBConfig config, ODatabaseTask<Void> createOps)
protected OCachedDatabasePoolFactory	createCachedDatabasePoolFactory(OrientDBConfig config)
protected OSharedContext	createSharedContext(OStorage storage)
void	drop(String name, String user, String password)	Drop a database
void	endCommand()
Future<?>	execute(Runnable task)
<X> Future<X>	execute(String database, String user, ODatabaseTask<X> task)
<X> Future<X>	execute(Callable<X> task)
<X> Future<X>	executeNoAuthorization(String database, ODatabaseTask<X> task)
<X> Future<X>	executeNoDb(Callable<X> callable)
OResultSet	executeServerStatement(String script, String username, String pw, Object... args)
OResultSet	executeServerStatement(String script, String username, String pw, Map<String,Object> args)
boolean	exists(String name, String user, String password)	Check if a database exists
void	forceDatabaseClose(String iDatabaseName)
protected OStorage	getAndOpenStorage(String name, OrientDBConfig config)
String	getBasePath()
OrientDBConfig	getConfigurations()
String	getConnectionUrl()
String	getDatabasePath(String iDatabaseName)
OStorageEngine	getDefaultEngine()
OStorageEngine	getEngine(String engine)
ExecutorService	getIoExecutor()
protected OSharedContext	getOrCreateSharedContext(OStorage storage)
OScriptManager	getScriptManager()
ODefaultSecuritySystem	getSecuritySystem()
OStorage	getStorage(String name)
Collection<OStorage>	getStorages()
OSystemDatabase	getSystemDatabase()
void	initAutoClose(long delay)
void	initCustomStorage(String name, String path, String userName, String userPassword)
protected void	initEngines()
void	internalClose()	Should be called only by shutdown listeners
protected ODatabaseDocumentEmbedded	internalCreate(OrientDBConfig config, OStorage storage)
void	internalDrop(String database)
boolean	isEmbedded()
boolean	isMemoryOnly()
boolean	isOpen()	Check if the current instance is open
Set<String>	listDatabases(String user, String password)	List of database exiting in the current environment
Set<String>	listLodadedDatabases()
void	loadAllDatabases()
void	networkRestore(String name, InputStream in, Callable<Object> callable)
protected ODatabaseDocumentEmbedded	newCreateSessionInstance(OStorage storage, OrientDBConfig config)
protected ODatabaseDocumentEmbedded	newPooledSessionInstance(ODatabasePoolInternal pool, OStorage storage, OSharedContext sharedContext)
protected ODatabaseDocumentEmbedded	newSessionInstance(OStorage storage, OrientDBConfig config)
ODatabaseDocumentInternal	open(OAuthenticationInfo authenticationInfo, OrientDBConfig config)	Open a database specified by name using the authentication info provided, with specific configuration
ODatabaseDocumentInternal	open(String name, String user, String password)	Open a database specified by name using the username and password if needed
ODatabaseDocumentInternal	open(String name, String user, String password, OrientDBConfig config)	Open a database specified by name using the username and password if needed, with specific configuration
ODatabaseDocumentEmbedded	openNoAuthenticate(String name, String user)
ODatabaseDocumentEmbedded	openNoAuthorization(String name)
ODatabasePoolInternal	openPool(String name, String user, String password)	Open a pool of databases, similar to open but with multiple instances.
ODatabasePoolInternal	openPool(String name, String user, String password, OrientDBConfig config)	Open a pool of databases, similar to open but with multiple instances.
ODatabaseDocumentInternal	poolOpen(String name, String user, String password, ODatabasePoolInternal pool)	Internal api for request to open a database with a pool
void	preClose()
void	removePool(ODatabasePoolInternal pool)	Internal API for pool close
void	removeShutdownHook()
void	restore(String name, InputStream in, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener)
void	restore(String name, String user, String password, ODatabaseType type, String path, OrientDBConfig config)
void	schedule(TimerTask task, long delay, long period)
void	scheduleOnce(TimerTask task, long delay)
protected OrientDBConfig	solveConfig(OrientDBConfig config)
void	startCommand(Optional<Long> timeout)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.db.OrientDBInternal

deltaSync, distributedSetOnline, fullSync, newNetworkMessage, newOrientDB, newOrientDBNoClose

Field Details

storages

protected final Map<String,OStorage> storages

sharedContexts

protected final Map<String,OSharedContext> sharedContexts

pools

protected final Set<ODatabasePoolInternal> pools

configurations

protected final OrientDBConfig configurations

basePath

protected final String basePath

orient

protected final Orient orient

cachedPoolFactory

protected final OCachedDatabasePoolFactory cachedPoolFactory

dbCount

protected final AtomicInteger dbCount

Constructor Details

OrientDBEmbedded

public OrientDBEmbedded(String directoryPath,
 OrientDBConfig configurations,
 Orient orient)

Method Details

initEngines

protected void initEngines()

getEngine

public OStorageEngine getEngine(String engine)

getDefaultEngine

public OStorageEngine getDefaultEngine()

createCachedDatabasePoolFactory

protected OCachedDatabasePoolFactory createCachedDatabasePoolFactory(OrientDBConfig config)

initAutoClose

public void initAutoClose(long delay)

open

public ODatabaseDocumentInternal open(String name,
 String user,
 String password)

Description copied from interface: OrientDBInternal

Open a database specified by name using the username and password if needed

Specified by:

open in interface OrientDBInternal

Parameters:

name - of the database to open

user - the username allowed to open the database

password - related to the specified username

Returns:

the opened database

openNoAuthenticate

public ODatabaseDocumentEmbedded openNoAuthenticate(String name,
 String user)

Specified by:

openNoAuthenticate in interface OrientDBInternal

newSessionInstance

protected ODatabaseDocumentEmbedded newSessionInstance(OStorage storage,
 OrientDBConfig config)

newCreateSessionInstance

protected ODatabaseDocumentEmbedded newCreateSessionInstance(OStorage storage,
 OrientDBConfig config)

openNoAuthorization

public ODatabaseDocumentEmbedded openNoAuthorization(String name)

Specified by:

openNoAuthorization in interface OrientDBInternal

open

public ODatabaseDocumentInternal open(String name,
 String user,
 String password,
 OrientDBConfig config)

Description copied from interface: OrientDBInternal

Open a database specified by name using the username and password if needed, with specific configuration

Specified by:

open in interface OrientDBInternal

Parameters:

name - of the database to open

user - the username allowed to open the database

password - related to the specified username

config - database specific configuration that override the factory global settings where needed.

Returns:

the opened database

open

public ODatabaseDocumentInternal open(OAuthenticationInfo authenticationInfo,
 OrientDBConfig config)

Description copied from interface: OrientDBInternal

Open a database specified by name using the authentication info provided, with specific configuration

Specified by:

open in interface OrientDBInternal

Parameters:

authenticationInfo - authentication informations provided for the authentication.

config - database specific configuration that override the factory global settings where needed.

Returns:

the opened database

getAndOpenStorage

protected OStorage getAndOpenStorage(String name,
 OrientDBConfig config)

solveConfig

protected OrientDBConfig solveConfig(OrientDBConfig config)

poolOpen

public ODatabaseDocumentInternal poolOpen(String name,
 String user,
 String password,
 ODatabasePoolInternal pool)

Description copied from interface: OrientDBInternal

Internal api for request to open a database with a pool

Specified by:

poolOpen in interface OrientDBInternal

newPooledSessionInstance

protected ODatabaseDocumentEmbedded newPooledSessionInstance(ODatabasePoolInternal pool,
 OStorage storage,
 OSharedContext sharedContext)

getStorage

public OStorage getStorage(String name)

buildName

protected String buildName(String name)

create

public void create(String name,
 String user,
 String password,
 ODatabaseType type)

Description copied from interface: OrientDBInternal

Create a new database

Specified by:

create in interface OrientDBInternal

Parameters:

name - database name

user - the username of a user allowed to create a database, in case of remote is a server user for embedded it can be left empty

password - the password relative to the user

type - can be plocal or memory

create

public void create(String name,
 String user,
 String password,
 ODatabaseType type,
 OrientDBConfig config)

Description copied from interface: OrientDBInternal

Create a new database

Specified by:

create in interface OrientDBInternal

Parameters:

name - database name

user - the username of a user allowed to create a database, in case of remote is a server user for embedded it can be left empty

password - the password relative to the user

type - can be plocal or memory

config - database specific configuration that override the factory global settings where needed.

create

public void create(String name,
 String user,
 String password,
 ODatabaseType type,
 OrientDBConfig config,
 ODatabaseTask<Void> createOps)

Specified by:

create in interface OrientDBInternal

networkRestore

public void networkRestore(String name,
 InputStream in,
 Callable<Object> callable)

Specified by:

networkRestore in interface OrientDBInternal

restore

public void restore(String name,
 String user,
 String password,
 ODatabaseType type,
 String path,
 OrientDBConfig config)

Specified by:

restore in interface OrientDBInternal

restore

public void restore(String name,
 InputStream in,
 Map<String,Object> options,
 Callable<Object> callable,
 OCommandOutputListener iListener)

Specified by:

restore in interface OrientDBInternal

internalCreate

protected ODatabaseDocumentEmbedded internalCreate(OrientDBConfig config,
 OStorage storage)

getOrCreateSharedContext

protected OSharedContext getOrCreateSharedContext(OStorage storage)

createSharedContext

protected OSharedContext createSharedContext(OStorage storage)

exists

public boolean exists(String name,
 String user,
 String password)

Description copied from interface: OrientDBInternal

Check if a database exists

Specified by:

exists in interface OrientDBInternal

Parameters:

name - database name to check

user - the username of a user allowed to check the database existence, in case of remote is a server user for embedded it can be left empty.

password - the password relative to the user

Returns:

boolean true if exist false otherwise.

internalDrop

public void internalDrop(String database)

Specified by:

internalDrop in interface OrientDBInternal

drop

public void drop(String name,
 String user,
 String password)

Description copied from interface: OrientDBInternal

Drop a database

Specified by:

drop in interface OrientDBInternal

Parameters:

name - database name

user - the username of a user allowed to drop a database, in case of remote is a server user for embedded it can be left empty

password - the password relative to the user

listDatabases

public Set<String> listDatabases(String user,
 String password)

Description copied from interface: OrientDBInternal

List of database exiting in the current environment

Specified by:

listDatabases in interface OrientDBInternal

Parameters:

user - the username of a user allowed to list databases, in case of remote is a server user for embedded it can be left empty

password - the password relative to the user

Returns:

a set of databases names.

loadAllDatabases

public void loadAllDatabases()

Specified by:

loadAllDatabases in interface OrientDBInternal

openPool

public ODatabasePoolInternal openPool(String name,
 String user,
 String password)

Description copied from interface: OrientDBInternal

Open a pool of databases, similar to open but with multiple instances.

Specified by:

openPool in interface OrientDBInternal

Parameters:

name - database name

user - the username allowed to open the database

password - the password relative to the user

Returns:

a new pool of databases.

openPool

public ODatabasePoolInternal openPool(String name,
 String user,
 String password,
 OrientDBConfig config)

Description copied from interface: OrientDBInternal

Open a pool of databases, similar to open but with multiple instances.

Specified by:

openPool in interface OrientDBInternal

Parameters:

name - database name

user - the username allowed to open the database

password - the password relative to the user

config - database specific configuration that override the factory global settings where needed.

Returns:

a new pool of databases.

cachedPool

public ODatabasePoolInternal cachedPool(String database,
 String user,
 String password)

Specified by:

cachedPool in interface OrientDBInternal

cachedPool

public ODatabasePoolInternal cachedPool(String database,
 String user,
 String password,
 OrientDBConfig config)

Specified by:

cachedPool in interface OrientDBInternal

close

public void close()

Description copied from interface: OrientDBInternal

Close the factory with all related databases and pools.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface OrientDBInternal

preClose

public void preClose()

internalClose

public void internalClose()

Description copied from interface: OrientDBInternal

Should be called only by shutdown listeners

Specified by:

internalClose in interface OrientDBInternal

getConfigurations

public OrientDBConfig getConfigurations()

Specified by:

getConfigurations in interface OrientDBInternal

removePool

public void removePool(ODatabasePoolInternal pool)

Description copied from interface: OrientDBInternal

Internal API for pool close

Specified by:

removePool in interface OrientDBInternal

initCustomStorage

public void initCustomStorage(String name,
 String path,
 String userName,
 String userPassword)

Specified by:

initCustomStorage in interface OrientDBInternal

removeShutdownHook

public void removeShutdownHook()

Specified by:

removeShutdownHook in interface OrientDBInternal

getStorages

public Collection<OStorage> getStorages()

Specified by:

getStorages in interface OrientDBInternal

forceDatabaseClose

public void forceDatabaseClose(String iDatabaseName)

Specified by:

forceDatabaseClose in interface OrientDBInternal

getDatabasePath

public String getDatabasePath(String iDatabaseName)

checkOpen

protected void checkOpen()

isOpen

public boolean isOpen()

Description copied from interface: OrientDBInternal

Check if the current instance is open

Specified by:

isOpen in interface OrientDBInternal

isEmbedded

public boolean isEmbedded()

Specified by:

isEmbedded in interface OrientDBInternal

schedule

public void schedule(TimerTask task,
 long delay,
 long period)

Specified by:

schedule in interface OSchedulerInternal

scheduleOnce

public void scheduleOnce(TimerTask task,
 long delay)

Specified by:

scheduleOnce in interface OSchedulerInternal

execute

public <X> Future<X> execute(String database,
 String user,
 ODatabaseTask<X> task)

Specified by:

execute in interface OrientDBInternal

execute

public Future<?> execute(Runnable task)

Specified by:

execute in interface OrientDBInternal

execute

public <X> Future<X> execute(Callable<X> task)

Specified by:

execute in interface OrientDBInternal

executeNoAuthorization

public <X> Future<X> executeNoAuthorization(String database,
 ODatabaseTask<X> task)

Specified by:

executeNoAuthorization in interface OrientDBInternal

executeNoDb

public <X> Future<X> executeNoDb(Callable<X> callable)

getScriptManager

public OScriptManager getScriptManager()

Specified by:

getScriptManager in interface OrientDBInternal

executeServerStatement

public OResultSet executeServerStatement(String script,
 String username,
 String pw,
 Map<String,Object> args)

Specified by:

executeServerStatement in interface OrientDBInternal

executeServerStatement

public OResultSet executeServerStatement(String script,
 String username,
 String pw,
 Object... args)

Specified by:

executeServerStatement in interface OrientDBInternal

getSystemDatabase

public OSystemDatabase getSystemDatabase()

Specified by:

getSystemDatabase in interface OrientDBInternal

getSecuritySystem

public ODefaultSecuritySystem getSecuritySystem()

Specified by:

getSecuritySystem in interface OrientDBInternal

getBasePath

public String getBasePath()

Specified by:

getBasePath in interface OrientDBInternal

isMemoryOnly

public boolean isMemoryOnly()

Specified by:

isMemoryOnly in interface OrientDBInternal

listLodadedDatabases

public Set<String> listLodadedDatabases()

Specified by:

listLodadedDatabases in interface OrientDBInternal

startCommand

public void startCommand(Optional<Long> timeout)

Specified by:

startCommand in interface OrientDBInternal

endCommand

public void endCommand()

Specified by:

endCommand in interface OrientDBInternal

getConnectionUrl

public String getConnectionUrl()

Specified by:

getConnectionUrl in interface OrientDBInternal

getIoExecutor

public ExecutorService getIoExecutor()