Package com.orientechnologies.orient.distributed.db

Class OrientDBDistributed

java.lang.Object

com.orientechnologies.orient.core.db.OrientDBEmbedded

com.orientechnologies.orient.distributed.db.OrientDBDistributed

All Implemented Interfaces:

OrientDBInternal, OSchedulerInternal, OServerAware, AutoCloseable

public class OrientDBDistributed
extends OrientDBEmbedded
implements OServerAware

Created by tglman on 08/08/17.

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

OrientDBEmbedded.DatabaseFound

Field Summary

Fields inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

basePath, cachedPoolFactory, dbCount, orient, pools, sharedContexts, storages

Constructor Summary

Constructors

Constructor	Description
OrientDBDistributed(String directoryPath, OrientDBConfig config, Orient instance)

Method Summary

Modifier and Type	Method	Description
void	cancelRegisterPromise()
void	close()	Close the factory with all related databases and pools.
<T> T	configOp(ODistributedConfigurationManager cm, String database, com.orientechnologies.orient.distributed.db.OrientDBDistributed.ConfigOp<T> op)
void	connected(ONodeId node)
void	create(String name, String user, String password, ODatabaseType type, OrientDBConfig config, ODatabaseTask<Void> createOps)
protected OSharedContext	createSharedContext(OStorage storage)
boolean	deltaSync(String dbName, InputStream backupStream, OrientDBConfig config)
Optional<OAcceptResult>	distributedOperation(OOperationMessage operation)
void	distributedPauseDatabase(String database)
void	distributedSetOnline(String database)
void	drop(String name, String user, String password)	Drop a database
static void	dropStorageFiles(OStorage storage)
void	firstConnect(ONodeId nodeId, ONodeStateNetwork state)
void	fullSync(String dbName, InputStream backupStream, OrientDBConfig config)
int	getActiveDatabaseCount()
Set<String>	getActiveDatabases()
ODistributedConfigurationManager	getConfigurationManager(String database)
ODistributedDatabaseImpl	getDatabase(String iDatabaseName)
ODistributedConfiguration	getDefaultDistributedConfiguration(String database)
ODistributedConfiguration	getDistributedConfiguration(ODatabaseSession session)
ODistributedConfiguration	getDistributedConfiguration(String database)
Collection<ODistributedDatabaseImpl>	getDistributedDatabases()
ODistributedServerManager	getDistributedManager()
ODistributedConfiguration	getExistingDistributedConfiguration(String database)
ODistributedMessageService	getMessageService()
String	getNodeName()
ONodeState	getNodeState()
ODistributedConfigurationManager	getOrInitConfigurationManager(String database)
ODistributedConfiguration	getOrInitDistributedConfiguration(ODatabaseSession session)
ODistributedConfiguration	getOrInitDistributedConfiguration(String database)
ODistributedPlugin	getPlugin()
void	init(OServer server)
void	internalDrop(String name)
protected boolean	isDistributedDisabled(String storage)
void	loadAllDatabases()
protected ODatabaseDocumentEmbedded	newCreateSessionInstance(OStorage storage, OrientDBConfig config)
ONetworkMessage	newNetworkMessage()
protected ODatabaseDocumentEmbedded	newPooledSessionInstance(ODatabasePoolInternal pool, OStorage storage, OSharedContext sharedContext)
protected ODatabaseDocumentEmbedded	newSessionInstance(OStorage storage, OrientDBConfig config)
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
ODatabaseDocumentInternal	poolOpen(String name, String user, String password, ODatabasePoolInternal pool)	Internal api for request to open a database with a pool
void	receiveMessage(OStructuralMessage op)
void	registerNode(ONodeId node, long version)
void	saveDatabaseConfiguration(String database)
void	sendMessage(Set<ONodeId> set, OStructuralMessage op)
void	setDistributedConfiguration(String database, OModifiableDistributedConfiguration distributedConfiguration)
void	setPlugin(ODistributedPlugin plugin)
boolean	tryUpdatingDatabaseConfigurationLocally(String database, OModifiableDistributedConfiguration cfg)
ODistributedDatabaseImpl	unregisterDatabase(String iDatabaseName)

Methods inherited from class com.orientechnologies.orient.core.db.OrientDBEmbedded

buildName, cachedPool, cachedPool, checkOpen, create, create, createCachedDatabasePoolFactory, endCommand, execute, execute, execute, executeNoAuthorization, executeNoDb, executeServerStatement, executeServerStatement, exists, forceDatabaseClose, getAndOpenStorage, getBasePath, getConfigurations, getConnectionUrl, getDatabasePath, getDefaultEngine, getEngine, getIoExecutor, getOrCreateSharedContext, getScriptManager, getSecuritySystem, getStorage, getStorages, getSystemDatabase, initAutoClose, initCustomStorage, initEngines, internalClose, internalCreate, isEmbedded, isMemoryOnly, isOpen, listDatabases, listLodadedDatabases, networkRestore, open, openNoAuthenticate, openNoAuthorization, openPool, openPool, preClose, removePool, removeShutdownHook, restore, restore, schedule, scheduleOnce, solveConfig, startCommand

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

newOrientDB, newOrientDBNoClose

Constructor Details

OrientDBDistributed

public OrientDBDistributed(String directoryPath,
 OrientDBConfig config,
 Orient instance)

Method Details

init

public void init(OServer server)

Specified by:

init in interface OServerAware

loadAllDatabases

public void loadAllDatabases()

Specified by:

loadAllDatabases in interface OrientDBInternal

Overrides:

loadAllDatabases in class OrientDBEmbedded

getPlugin

public ODistributedPlugin getPlugin()

createSharedContext

protected OSharedContext createSharedContext(OStorage storage)

Overrides:

createSharedContext in class OrientDBEmbedded

newSessionInstance

protected ODatabaseDocumentEmbedded newSessionInstance(OStorage storage,
 OrientDBConfig config)

Overrides:

newSessionInstance in class OrientDBEmbedded

isDistributedDisabled

protected boolean isDistributedDisabled(String storage)

newCreateSessionInstance

protected ODatabaseDocumentEmbedded newCreateSessionInstance(OStorage storage,
 OrientDBConfig config)

Overrides:

newCreateSessionInstance in class OrientDBEmbedded

newPooledSessionInstance

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

Overrides:

newPooledSessionInstance in class OrientDBEmbedded

setPlugin

public void setPlugin(ODistributedPlugin plugin)

fullSync

public void fullSync(String dbName,
 InputStream backupStream,
 OrientDBConfig config)

Specified by:

fullSync in interface OrientDBInternal

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

Overrides:

poolOpen in class OrientDBEmbedded

internalDrop

public void internalDrop(String name)

Specified by:

internalDrop in interface OrientDBInternal

Overrides:

internalDrop in class OrientDBEmbedded

drop

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

Description copied from interface: OrientDBInternal

Drop a database

Specified by:

drop in interface OrientDBInternal

Overrides:

drop in class OrientDBEmbedded

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

sendMessage

public void sendMessage(Set<ONodeId> set,
 OStructuralMessage op)

receiveMessage

public void receiveMessage(OStructuralMessage op)

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

Overrides:

open in class OrientDBEmbedded

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

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

Overrides:

open in class OrientDBEmbedded

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

dropStorageFiles

public static void dropStorageFiles(OStorage storage)

getDistributedManager

public ODistributedServerManager getDistributedManager()

Specified by:

getDistributedManager in interface OServerAware

deltaSync

public boolean deltaSync(String dbName,
 InputStream backupStream,
 OrientDBConfig config)

Specified by:

deltaSync in interface OrientDBInternal

getNodeName

public String getNodeName()

getDatabase

public ODistributedDatabaseImpl getDatabase(String iDatabaseName)

unregisterDatabase

public ODistributedDatabaseImpl unregisterDatabase(String iDatabaseName)

create

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

Specified by:

create in interface OrientDBInternal

Overrides:

create in class OrientDBEmbedded

distributedSetOnline

public void distributedSetOnline(String database)

Specified by:

distributedSetOnline in interface OrientDBInternal

distributedPauseDatabase

public void distributedPauseDatabase(String database)

getActiveDatabases

public Set<String> getActiveDatabases()

getDistributedDatabases

public Collection<ODistributedDatabaseImpl> getDistributedDatabases()

getOrInitDistributedConfiguration

public ODistributedConfiguration getOrInitDistributedConfiguration(ODatabaseSession session)

getOrInitConfigurationManager

public ODistributedConfigurationManager getOrInitConfigurationManager(String database)

getConfigurationManager

public ODistributedConfigurationManager getConfigurationManager(String database)

getDistributedConfiguration

public ODistributedConfiguration getDistributedConfiguration(ODatabaseSession session)

configOp

public <T> T configOp(ODistributedConfigurationManager cm,
 String database,
 com.orientechnologies.orient.distributed.db.OrientDBDistributed.ConfigOp<T> op)

getExistingDistributedConfiguration

public ODistributedConfiguration getExistingDistributedConfiguration(String database)

getDefaultDistributedConfiguration

public ODistributedConfiguration getDefaultDistributedConfiguration(String database)

getDistributedConfiguration

public ODistributedConfiguration getDistributedConfiguration(String database)

setDistributedConfiguration

public void setDistributedConfiguration(String database,
 OModifiableDistributedConfiguration distributedConfiguration)

saveDatabaseConfiguration

public void saveDatabaseConfiguration(String database)

getOrInitDistributedConfiguration

public ODistributedConfiguration getOrInitDistributedConfiguration(String database)

tryUpdatingDatabaseConfigurationLocally

public boolean tryUpdatingDatabaseConfigurationLocally(String database,
 OModifiableDistributedConfiguration cfg)

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

Overrides:

close in class OrientDBEmbedded

getActiveDatabaseCount

public int getActiveDatabaseCount()

getMessageService

public ODistributedMessageService getMessageService()

distributedOperation

public Optional<OAcceptResult> distributedOperation(OOperationMessage operation)

getNodeState

public ONodeState getNodeState()

newNetworkMessage

public ONetworkMessage newNetworkMessage()

Specified by:

newNetworkMessage in interface OrientDBInternal

firstConnect

public void firstConnect(ONodeId nodeId,
 ONodeStateNetwork state)

connected

public void connected(ONodeId node)

registerNode

public void registerNode(ONodeId node,
 long version)

cancelRegisterPromise

public void cancelRegisterPromise()