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, ODatabaseStateChangeListener, OServerAware, AutoCloseable

public class OrientDBDistributed
extends OrientDBEmbedded
implements OServerAware, ODatabaseStateChangeListener

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

Modifier and Type	Field	Description
protected AtomicLong	localMessageIdCounter

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	acceptSync(ONodeId receiver, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	cancelDeclare(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	cancelRegisterPromise()
void	canSync(ONodeId sender, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	close()	Close the factory with all related databases and pools.
void	closeRemoteServer(String node)
<T> T	configOp(ODistributedConfigurationManager cm, String database, com.orientechnologies.orient.distributed.db.OrientDBDistributed.ConfigOp<T> op)
void	connected(ONodeId node, String url, String user, String password)
ORemoteServerController	connectRemoteServer(String rNodeName, String url, String replicatorUser, String userPassword)
void	coordinatedOperation(OOperationMessage operation, OCompleteExecution execution)
void	create(String name, String user, String password, ODatabaseType type, ODatabaseId id, OrientDBConfig config, ODatabaseTask<Void> createOps)
protected OSharedContext	createSharedContext(OStorage storage)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum)
boolean	deltaSync(String dbName, InputStream backupStream, OrientDBConfig config)
void	distributedOperation(OOperationMessage operation, OCompleteExecution retry)
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	enstablish(OGroupId groupId, Set<ONodeId> candidates)
void	firstConnect(ONodeId nodeId, ONodeStateNetwork state)
void	fullSync(String dbName, InputStream backupStream, OrientDBConfig config)
int	getActiveDatabaseCount()
Set<String>	getActiveDatabases()
Set<String>	getAvailableNodeNames(String name)
Set<String>	getAvailableNodeNotLocalNames(String name)
ODistributedConfigurationManager	getConfigurationManager(String database)
ODistributedDatabaseImpl	getDatabase(String iDatabaseName)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(ONodeId nodeId, String dbName)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String dbName)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String node, String dbName)
ODistributedConfiguration	getDefaultDistributedConfiguration(String database)
ODistributedConfiguration	getDistributedConfiguration(ODatabaseSession session)
ODistributedConfiguration	getDistributedConfiguration(String database)
Collection<ODistributedDatabaseImpl>	getDistributedDatabases()
ODistributedServerManager	getDistributedManager()
ODistributedConfiguration	getExistingDistributedConfiguration(String database)
ODistributedMessageService	getMessageService()
long	getNextMessageIdCounter()
ONodeId	getNodeId()
String	getNodeName()
ONodeState	getNodeState()
int	getNodesWithStatus(Collection<String> iNodes, String databaseName, ODistributedServerManager.DB_STATUS... statuses)	Returns the nodes with the requested status.
int	getOnlineMasters(String databaseName)
List<String>	getOnlineNodesNotLocal(String dbName)
ODistributedConfigurationManager	getOrInitConfigurationManager(String database)
ODistributedConfiguration	getOrInitDistributedConfiguration(ODatabaseSession session)
ODistributedPlugin	getPlugin()
ORemoteServerController	getRemoteServer(String rNodeName)
OServer	getServer()
void	incrementalsSync(String dbName, InputStream backupStream, OrientDBConfig config)
void	init(OServer server)
void	initDistributed(ONodeConfiguration config)
void	initDistributed(String nodeName, String groupIdPar, int miminumQuorum, ORemoteServerAvailabilityCheck check)
boolean	installDatabase(boolean iStartup, String databaseName, boolean forceDeployment, boolean tryWithDeltaFirst)
void	internalDrop(String name)
protected boolean	isDistributedDisabled(String storage)
boolean	isNodeAvailable(String targetNode, String databaseName)
boolean	isNodeOnline(String targetNode, String databaseName)
void	loadAllDatabases()
OStandardCompleteAction	newCompleteAction(OOperationMessage operation, OCompleteExecution execution)
protected ODatabaseDocumentEmbedded	newCreateSessionInstance(OStorage storage, OrientDBConfig config)
ONetworkMessage	newNetworkMessage()
protected ODatabaseDocumentEmbedded	newPooledSessionInstance(ODatabasePoolInternal pool, OStorage storage, OSharedContext sharedContext)
ORetryInfo	newRetryInfo()
protected ODatabaseDocumentEmbedded	newSessionInstance(OStorage storage, OrientDBConfig config)
void	nextBuffer(OSyncId syncId, boolean close)
void	onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state)
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
Optional<OAcceptResult>	promiseDeclare(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum)
void	receiveMessage(OStructuralMessage op)
void	receiveSync(String dbName, OSyncState state, InputStream input, OrientDBConfig conf)
void	receiveSyncData(OSyncId syncId, byte[] data, boolean finished)
void	registerNode(ONodeId node, long version)
void	requestNext(OSyncState state, boolean close)
void	retryExecution(ORetryOperation operation, OCompleteExecution exec, int delay)
void	retryOperation(OOperationMessage operation, OCompleteAction action, int delay)
Future<Optional<OAcceptResult>>	retryOperation(ORetryOperation operation)
void	saveDatabaseConfiguration(String database)
void	sendBuffer(OSyncState state, byte[] data, boolean finished)
void	sendDatabase(ONodeId receiver, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	sendFirstConnects(Set<ONodeId> nodes)
void	sendMergeOperation(Set<ONodeId> members, OCompleteExecution execution, ONodeStateNetwork otherState)
void	sendMessage(ONodeId node, OStructuralMessage op)
void	sendMessage(Set<ONodeId> set, OStructuralMessage op)
void	setDatabaseStatus(ONodeId nodeId, String dbName, ODistributedServerManager.DB_STATUS status)
void	setDatabaseStatus(String dbName, ODistributedServerManager.DB_STATUS status)
void	setDistributedConfiguration(String database, OModifiableDistributedConfiguration distributedConfiguration)
void	setPlugin(ODistributedPlugin plugin)
void	syncBackup(String name, OSyncState state, OutputStream output)
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, delayExecute, 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, periodicExecute, preClose, removePool, removeShutdownHook, restore, restore, schedule, scheduleExecuteFrom, 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

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

delayExecute, scheduleFrom

Field Details

localMessageIdCounter

protected AtomicLong localMessageIdCounter

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

initDistributed

public void initDistributed(ONodeConfiguration config)

initDistributed

public void initDistributed(String nodeName,
 String groupIdPar,
 int miminumQuorum,
 ORemoteServerAvailabilityCheck check)

onStateChange

public void onStateChange(ODatabaseId dbId,
 ONodeId nodeId,
 ODatabaseState state)

Specified by:

onStateChange in interface ODatabaseStateChangeListener

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)

incrementalsSync

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

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)

sendMessage

public void sendMessage(ONodeId node,
 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,
 ODatabaseId id,
 OrientDBConfig config,
 ODatabaseTask<Void> createOps)

Specified by:

create in interface OrientDBInternal

Overrides:

create in class OrientDBEmbedded

retryOperation

public Future<Optional<OAcceptResult>> retryOperation(ORetryOperation operation)

retryExecution

public void retryExecution(ORetryOperation operation,
 OCompleteExecution exec,
 int delay)

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)

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 void distributedOperation(OOperationMessage operation,
 OCompleteExecution retry)

newCompleteAction

public OStandardCompleteAction newCompleteAction(OOperationMessage operation,
 OCompleteExecution execution)

newRetryInfo

public ORetryInfo newRetryInfo()

retryOperation

public void retryOperation(OOperationMessage operation,
 OCompleteAction action,
 int delay)

coordinatedOperation

public void coordinatedOperation(OOperationMessage operation,
 OCompleteExecution execution)

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,
 String url,
 String user,
 String password)

registerNode

public void registerNode(ONodeId node,
 long version)

cancelRegisterPromise

public void cancelRegisterPromise()

promiseDeclare

public Optional<OAcceptResult> promiseDeclare(OTransactionIdPromise promise,
 ODatabaseId databaseId,
 String database,
 Set<ONodeId> partecipants,
 int minimumQuorum)

declareDatabase

public void declareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database,
 Set<ONodeId> partecipants,
 int minimumQuorum)

cancelDeclare

public void cancelDeclare(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database)

acceptSync

public void acceptSync(ONodeId receiver,
 ODatabaseId dbId,
 OSyncId syncId,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

canSync

public void canSync(ONodeId sender,
 ODatabaseId dbId,
 OSyncId syncId,
 boolean canSync,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

receiveSync

public void receiveSync(String dbName,
 OSyncState state,
 InputStream input,
 OrientDBConfig conf)

sendDatabase

public void sendDatabase(ONodeId receiver,
 ODatabaseId dbId,
 OSyncId syncId,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

syncBackup

public void syncBackup(String name,
 OSyncState state,
 OutputStream output)

sendBuffer

public void sendBuffer(OSyncState state,
 byte[] data,
 boolean finished)

receiveSyncData

public void receiveSyncData(OSyncId syncId,
 byte[] data,
 boolean finished)

requestNext

public void requestNext(OSyncState state,
 boolean close)

nextBuffer

public void nextBuffer(OSyncId syncId,
 boolean close)

getNodeId

public ONodeId getNodeId()

closeRemoteServer

public void closeRemoteServer(String node)

getRemoteServer

public ORemoteServerController getRemoteServer(String rNodeName)

connectRemoteServer

public ORemoteServerController connectRemoteServer(String rNodeName,
 String url,
 String replicatorUser,
 String userPassword)
                                            throws IOException

Throws:

IOException

setDatabaseStatus

public void setDatabaseStatus(ONodeId nodeId,
 String dbName,
 ODistributedServerManager.DB_STATUS status)

setDatabaseStatus

public void setDatabaseStatus(String dbName,
 ODistributedServerManager.DB_STATUS status)

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(ONodeId nodeId,
 String dbName)

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String node,
 String dbName)

getDatabaseStatus

public ODistributedServerManager.DB_STATUS getDatabaseStatus(String dbName)

getServer

public OServer getServer()

getNextMessageIdCounter

public long getNextMessageIdCounter()

installDatabase

public boolean installDatabase(boolean iStartup,
 String databaseName,
 boolean forceDeployment,
 boolean tryWithDeltaFirst)

getAvailableNodeNotLocalNames

public Set<String> getAvailableNodeNotLocalNames(String name)

getAvailableNodeNames

public Set<String> getAvailableNodeNames(String name)

getOnlineMasters

public int getOnlineMasters(String databaseName)

enstablish

public void enstablish(OGroupId groupId,
 Set<ONodeId> candidates)

sendFirstConnects

public void sendFirstConnects(Set<ONodeId> nodes)

getOnlineNodesNotLocal

public List<String> getOnlineNodesNotLocal(String dbName)

getNodesWithStatus

public int getNodesWithStatus(Collection<String> iNodes,
 String databaseName,
 ODistributedServerManager.DB_STATUS... statuses)

Returns the nodes with the requested status.

isNodeOnline

public boolean isNodeOnline(String targetNode,
 String databaseName)

isNodeAvailable

public boolean isNodeAvailable(String targetNode,
 String databaseName)

sendMergeOperation

public void sendMergeOperation(Set<ONodeId> members,
 OCompleteExecution execution,
 ONodeStateNetwork otherState)