com.orientechnologies.orient.server.distributed.impl

Class ODatabaseDocumentDistributed

java.lang.Object

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

com.orientechnologies.orient.core.db.document.ODatabaseDocumentAbstract

com.orientechnologies.orient.core.db.document.ODatabaseDocumentEmbedded

com.orientechnologies.orient.server.distributed.impl.ODatabaseDocumentDistributed

All Implemented Interfaces:

ODatabaseDocument, OQueryLifecycleListener, ODatabase<ORecord>, ODatabaseDocumentInternal, ODatabaseInternal<ORecord>, ODatabaseSession, OBackupable, Closeable, AutoCloseable

Direct Known Subclasses:

ODatabaseDocumentDistributedPooled

public class ODatabaseDocumentDistributed
extends ODatabaseDocumentEmbedded

Created by tglman on 30/03/17.

Nested Class Summary

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

ODatabaseDocumentEmbedded.InterruptTimerTask

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.ODatabase

ODatabase.ATTRIBUTES, ODatabase.OPERATION_MODE, ODatabase.STATUS

Field Summary

Fields inherited from class com.orientechnologies.orient.core.db.document.ODatabaseDocumentAbstract

activeQueries, componentsFactory, currentIntent, currentTx, databaseOwner, hooks, hooksByScope, inHook, initialized, loadedRecordsCount, localCache, maxRecordLoadMs, maxRidbagPrefetchMs, metadata, microTransaction, minRecordLoadMs, minRidbagPrefetchMs, properties, recordType, retainRecords, ridbagPrefetchCount, serializer, sharedContext, status, totalRecordLoadMs, totalRidbagPrefetchMs, unmodifiableHooks, url, user

Fields inherited from interface com.orientechnologies.orient.core.db.document.ODatabaseDocument

TYPE

Constructor Summary

Constructors

Constructor and Description
ODatabaseDocumentDistributed(OStorage storage, OHazelcastPlugin hazelcastPlugin)

Method Summary

Modifier and Type	Method and Description
void	acquireLocksForTx(OTransactionInternal tx, ODistributedTxContext txContext)
int	addCluster(String iClusterName, int iRequestedId) Adds a new cluster.
int	addCluster(String iClusterName, Object... iParameters) Adds a new cluster.
int	assignAndCheckCluster(ORecord record, String iClusterName)
boolean	beginDistributedTx(ODistributedRequestId requestId, OTransactionId id, OTransactionInternal tx, boolean local, int retryCount)
boolean	commit2pc(ODistributedRequestId transactionId, boolean local, ODistributedRequestId requestId)
void	commit2pcLocal(ODistributedRequestId transactionId) The Local commit is different from a remote commit due to local rid pre-allocation
ODatabaseDocumentInternal	copy() Returns a copy of current database if it's open.
protected void	createMetadata(OSharedContext ctx)
void	distributedCommitV1(OTransactionInternal iTx)
protected boolean	dropClusterInternal(int clusterId)
protected boolean	dropClusterInternal(String clusterName)
ODistributedResponse	executeTaskOnNode(ORemoteTask task, String nodeName)
OTransactionResultPayload	firstPhaseDDL(String query, OTransactionId preChangeId, OTransactionId afterChangeId, ODistributedRequestId requestId)
Map<String,Set<String>>	getActiveClusterMap() returns the cluster map for current deploy.
Map<String,Set<String>>	getActiveDataCenterMap() returns the data center map for current deploy.
Set<String>	getClustersOnServer(ODistributedConfiguration cfg, String server)
ODistributedConfiguration	getDistributedConfiguration()
ODistributedServerManager	getDistributedManager()
OEnterpriseEndpoint	getEnterpriseEndpoint()
Map<String,Object>	getHaStatus(boolean servers, boolean db, boolean latency, boolean messages)
String	getLocalNodeName() return the name of local node in the cluster
ODistributedStorage	getStorageDistributed()
OView	getViewFromCluster(int cluster)
void	init(OrientDBConfig config, OSharedContext sharedContext)
void	internalBegin2pc(ONewDistributedTxContextImpl txContext, boolean local)
void	internalCommit(OTransactionInternal iTx) Executed the commit on the storage hiding away storage concepts from the transaction
void	internalCommit2pc(ONewDistributedTxContextImpl txContext)
boolean	isDistributed()
boolean	isSharded() checks the cluster map and tells whether this is a sharded database (ie.
protected void	loadMetadata()
protected void	loadMetadata(OSharedContext ctx)
OResultSet	queryOnNode(String nodeName, OExecutionPlan executionPlan, Map<Object,Object> inputParameters) sends an execution plan to a remote node for a remote query execution
void	register(ODistributedRequestId requestId, ODistributedDatabase localDistributedDatabase, ODistributedTxContext txContext)
boolean	removeHaServer(String serverName)
boolean	rollback2pc(ODistributedRequestId transactionId)
void	secondPhaseDDL(ODistributedRequestId confirmSentRequest, boolean apply)
void	sendDDLCommand(String command, boolean excludeLocal)
<T> T	sendSequenceAction(OSequenceAction action)
boolean	sync(boolean forceDeployment, boolean tryWithDelta) synchronizes current database instance with the rest of the cluster (if in distributed mode).
void	syncCommit(OTransactionData data)
void	twoPhaseDDL(String command)

Methods inherited from class com.orientechnologies.orient.core.db.document.ODatabaseDocumentEmbedded

addBlobCluster, addRidbagPrefetchStats, afterCommitOperations, afterCreateOperations, afterDeleteOperations, afterReadOperations, afterRollbackOperations, afterUpdateOperations, beforeCreateOperations, beforeDeleteOperations, beforeReadOperations, beforeUpdateOperations, beginMicroTransaction, callOnCreateListeners, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, command, command, create, create, create, createInterruptTimerTask, delete, drop, execute, execute, executeDeleteRecord, executeReadRecord, exists, getClusterName, getCommandInterruptionDepth, getConfig, getStats, getStorage, getStorageInfo, installHooksEmbedded, internalCreate, internalLockRecord, internalLockRecord, internalOpen, internalOpen, internalUnlockRecord, isClosed, isCommandInterrupted, live, live, lock, lock, open, open, query, query, query, rebuildIndexes, recycle, replaceStorage, resetRecordLoadStats, saveAll, set, setCommandInterrupted, setCommandInterruptionDepth, setCustom, unlock

Methods inherited from class com.orientechnologies.orient.core.db.document.ODatabaseDocumentAbstract

activateOnCurrentThread, backup, beforeCommitOperations, beforeRollbackOperations, begin, begin, begin, browseClass, browseClass, browseCluster, browseCluster, browseCluster, browseCluster, browseCluster, callbackHookFailure, callbackHookFinalize, callbackHooks, callbackHookSuccess, callOnCloseListeners, callOnDropListeners, callOnOpenListeners, checkForClusterPermissions, checkIfActive, checkOpenness, checkRecordClass, checkSecurity, cleanOutRecord, clearDocumentTracking, close, closeActiveQueries, command, commit, commit, countClass, countClass, countClass, countClusterElements, countClusterElements, countClusterElements, countClusterElements, countClusterElements, countView, declareIntent, delete, delete, dropCluster, dropCluster, executeWithRetries, executeWithRetries, executeWithRetries, existsCluster, freeze, freeze, get, getActiveIntent, getActiveQueries, getActiveQuery, getBlobClusterIds, getClusterIdByName, getClusterNameById, getClusterNames, getClusterRecordSizeById, getClusterRecordSizeByName, getClusters, getCollectionsChanges, getConfiguration, getConflictStrategy, getDatabaseOwner, getDefaultClusterId, getDefaultSerializer, getDictionary, getHooks, getListeners, getLocalCache, getMetadata, getMicroOrRegularTransaction, getName, getProperties, getProperty, getRecord, getRecordMetadata, getRecordType, getSbTreeCollectionManager, getSerializer, getSerializerFactory, getSharedContext, getSize, getStatus, getStorageVersions, getTransaction, getType, getUnderlying, getURL, getUser, incrementalBackup, init, internalClose, isActiveOnCurrentThread, isClusterEdge, isClusterVertex, isClusterView, isMVCC, isPooled, isPrefetchRecords, isRetainRecords, isUseLightweightEdges, isValidationEnabled, load, load, load, load, load, load, loadIfVersionIsNotLatest, newBlob, newBlob, newEdge, newEdge, newElement, newElement, newElement, newEmbeddedElement, newEmbeddedElement, newInstance, newInstance, newLightweightEdge, newRegularEdge, newVertex, newVertex, pessimisticLockChecks, query, queryClosed, queryStarted, rawBegin, registerHook, registerHook, release, reload, reload, reload, reload, reload, reloadUser, resetInitialization, restore, rollback, rollback, save, save, save, save, setConflictStrategy, setConflictStrategy, setCurrentDatabaseInThreadLocal, setDatabaseOwner, setDefaultClusterIdInternal, setDefaultSerializer, setDefaultTransactionMode, setInternal, setMVCC, setPrefetchRecords, setProperty, setRetainRecords, setSerializer, setStatus, setStatusInternal, setUseLightweightEdges, setUser, setValidationEnabled, swapTx, truncateCluster, unregisterHook

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

Methods inherited from interface com.orientechnologies.orient.core.db.document.OQueryLifecycleListener

queryClosed, queryStarted

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

indexQuery, isRemote, realClose, reuse

Methods inherited from interface com.orientechnologies.orient.core.db.document.ODatabaseDocument

createClassIfNotExist, createEdgeClass, createVertexClass, newEdge, newVertex

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

createClass, executeWithRetry, getClass, registerListener, unregisterListener

Constructor Detail

ODatabaseDocumentDistributed

public ODatabaseDocumentDistributed(OStorage storage,
                                    OHazelcastPlugin hazelcastPlugin)

Method Detail

getStorageDistributed

public ODistributedStorage getStorageDistributed()

getLocalNodeName

public String getLocalNodeName()

return the name of local node in the cluster

Returns:

the name of local node in the cluster

getActiveClusterMap

public Map<String,Set<String>> getActiveClusterMap()

returns the cluster map for current deploy. The keys of the map are node names, the values contain names of clusters (data files) available on the single node.

Returns:

the cluster map for current deploy

getClustersOnServer

public Set<String> getClustersOnServer(ODistributedConfiguration cfg,
                                       String server)

loadMetadata

protected void loadMetadata()

Overrides:

loadMetadata in class ODatabaseDocumentEmbedded

loadMetadata

protected void loadMetadata(OSharedContext ctx)

Overrides:

loadMetadata in class ODatabaseDocumentEmbedded

getActiveDataCenterMap

public Map<String,Set<String>> getActiveDataCenterMap()

returns the data center map for current deploy. The keys are data center names, the values are node names per data center

Returns:

data center map for current deploy

isSharded

public boolean isSharded()

Description copied from interface: ODatabaseInternal

checks the cluster map and tells whether this is a sharded database (ie. a distributed DB where at least two nodes contain distinct subsets of data) or not

Returns:

true if the database is sharded, false otherwise

isDistributed

public boolean isDistributed()

copy

public ODatabaseDocumentInternal copy()

Description copied from class: ODatabaseDocumentEmbedded

Returns a copy of current database if it's open. The returned instance can be used by another thread without affecting current instance. The database copy is not set in thread local.

Specified by:

copy in interface ODatabaseDocumentInternal

Overrides:

copy in class ODatabaseDocumentEmbedded

sync

public boolean sync(boolean forceDeployment,
                    boolean tryWithDelta)

Description copied from interface: ODatabaseDocumentInternal

synchronizes current database instance with the rest of the cluster (if in distributed mode).

Returns:

true if the database was synchronized, false otherwise

getHaStatus

public Map<String,Object> getHaStatus(boolean servers,
                                      boolean db,
                                      boolean latency,
                                      boolean messages)

removeHaServer

public boolean removeHaServer(String serverName)

queryOnNode

public OResultSet queryOnNode(String nodeName,
                              OExecutionPlan executionPlan,
                              Map<Object,Object> inputParameters)

Description copied from interface: ODatabaseDocumentInternal

sends an execution plan to a remote node for a remote query execution

Parameters:

nodeName - the node name

executionPlan - the execution plan

inputParameters - the input parameters for execution

Returns:

an OResultSet to fetch the results of the query execution

executeTaskOnNode

public ODistributedResponse executeTaskOnNode(ORemoteTask task,
                                              String nodeName)

init

public void init(OrientDBConfig config,
                 OSharedContext sharedContext)

Overrides:

init in class ODatabaseDocumentEmbedded

createMetadata

protected void createMetadata(OSharedContext ctx)

Overrides:

createMetadata in class ODatabaseDocumentEmbedded

assignAndCheckCluster

public int assignAndCheckCluster(ORecord record,
                                 String iClusterName)

Specified by:

assignAndCheckCluster in interface ODatabaseDocumentInternal

Overrides:

assignAndCheckCluster in class ODatabaseDocumentAbstract

internalCommit

public void internalCommit(OTransactionInternal iTx)

Description copied from interface: ODatabaseDocumentInternal

Executed the commit on the storage hiding away storage concepts from the transaction

Specified by:

internalCommit in interface ODatabaseDocumentInternal

Overrides:

internalCommit in class ODatabaseDocumentAbstract

sendSequenceAction

public <T> T sendSequenceAction(OSequenceAction action)
                         throws ExecutionException,
                                InterruptedException

Specified by:

sendSequenceAction in interface ODatabaseDocumentInternal

Overrides:

sendSequenceAction in class ODatabaseDocumentEmbedded

Throws:

ExecutionException

InterruptedException

distributedCommitV1

public void distributedCommitV1(OTransactionInternal iTx)

acquireLocksForTx

public void acquireLocksForTx(OTransactionInternal tx,
                              ODistributedTxContext txContext)

beginDistributedTx

public boolean beginDistributedTx(ODistributedRequestId requestId,
                                  OTransactionId id,
                                  OTransactionInternal tx,
                                  boolean local,
                                  int retryCount)

register

public void register(ODistributedRequestId requestId,
                     ODistributedDatabase localDistributedDatabase,
                     ODistributedTxContext txContext)

commit2pcLocal

public void commit2pcLocal(ODistributedRequestId transactionId)

The Local commit is different from a remote commit due to local rid pre-allocation

Parameters:

transactionId -

commit2pc

public boolean commit2pc(ODistributedRequestId transactionId,
                         boolean local,
                         ODistributedRequestId requestId)

Parameters:

transactionId -

Returns:

null returned means that commit failed

rollback2pc

public boolean rollback2pc(ODistributedRequestId transactionId)

internalCommit2pc

public void internalCommit2pc(ONewDistributedTxContextImpl txContext)

internalBegin2pc

public void internalBegin2pc(ONewDistributedTxContextImpl txContext,
                             boolean local)

getViewFromCluster

public OView getViewFromCluster(int cluster)

Specified by:

getViewFromCluster in interface ODatabaseDocumentInternal

Overrides:

getViewFromCluster in class ODatabaseDocumentEmbedded

getEnterpriseEndpoint

public OEnterpriseEndpoint getEnterpriseEndpoint()

Returns:

an endpoint for Enterprise features. Null in Community Edition

getDistributedManager

public ODistributedServerManager getDistributedManager()

getDistributedConfiguration

public ODistributedConfiguration getDistributedConfiguration()

sendDDLCommand

public void sendDDLCommand(String command,
                           boolean excludeLocal)

twoPhaseDDL

public void twoPhaseDDL(String command)

addCluster

public int addCluster(String iClusterName,
                      Object... iParameters)

Description copied from interface: ODatabase

Adds a new cluster.

Specified by:

addCluster in interface ODatabase<ORecord>

Overrides:

addCluster in class ODatabaseDocumentAbstract

Parameters:

iClusterName - Cluster name

iParameters - Additional parameters to pass to the factories

Returns:

Cluster id

addCluster

public int addCluster(String iClusterName,
                      int iRequestedId)

Description copied from interface: ODatabase

Adds a new cluster.

Specified by:

addCluster in interface ODatabase<ORecord>

Overrides:

addCluster in class ODatabaseDocumentAbstract

Parameters:

iClusterName - Cluster name

iRequestedId - requested id of the cluster

Returns:

Cluster id

dropClusterInternal

protected boolean dropClusterInternal(String clusterName)

Overrides:

dropClusterInternal in class ODatabaseDocumentAbstract

dropClusterInternal

protected boolean dropClusterInternal(int clusterId)

Overrides:

dropClusterInternal in class ODatabaseDocumentAbstract

syncCommit

public void syncCommit(OTransactionData data)

firstPhaseDDL

public OTransactionResultPayload firstPhaseDDL(String query,
                                               OTransactionId preChangeId,
                                               OTransactionId afterChangeId,
                                               ODistributedRequestId requestId)

secondPhaseDDL

public void secondPhaseDDL(ODistributedRequestId confirmSentRequest,
                           boolean apply)