Package com.orientechnologies.orient.server.distributed.impl

Class ODatabaseDocumentDistributedPooled

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

com.orientechnologies.orient.server.distributed.impl.ODatabaseDocumentDistributedPooled

All Implemented Interfaces:

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

public class ODatabaseDocumentDistributedPooled
extends ODatabaseDocumentDistributed

Created by tglman on 30/03/17.

Nested Class Summary

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

ODatabase.ATTRIBUTES, ODatabase.STATUS

Field Summary

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

activeQueries, componentsFactory, currentTx, databaseOwner, hooks, hooksByScope, inHook, initialized, loadedRecordsCount, localCache, maxRecordLoadMs, maxRidbagPrefetchMs, metadata, minRecordLoadMs, minRidbagPrefetchMs, properties, queryState, 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	Description
ODatabaseDocumentDistributedPooled(ODatabasePoolInternal pool, OStorage storage, ODistributedPlugin distributedPlugin)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes an opened database, if the database is already closed does nothing, if a transaction is active will be rollback.
ODatabaseDocumentInternal	copy()	Returns a copy of current database if it's open.
void	realClose()
void	reuse()

Methods inherited from class com.orientechnologies.orient.server.distributed.impl.ODatabaseDocumentDistributed

acquireLocksForTx, addCluster, addCluster, assignAndCheckCluster, backup, beginDistributedTx, checkNodeIsMaster, commit2pc, commit2pcLocal, createMetadata, distributedCommitV1, dropClusterInternal, dropClusterInternal, executeTaskOnNode, firstPhaseDDL, forceRsync, freeze, getActiveDataCenterMap, getDistributedConfiguration, getDistributedManager, getDistributedShared, getEnterpriseEndpoint, getHaStatus, getInvolvedClusters, getLocalNodeName, getStorageId, getViewFromCluster, handleDistributedException, init, internalBegin2pc, internalBegin2pc, internalCommit, internalCommit2pc, internalCommitPreallocate, isDistributed, isLocalEnv, isSharded, queryOnNode, register, release, removeHaServer, rollback2pc, secondPhaseDDL, sendDDLCommand, sendSequenceAction, sync, syncCommit, twoPhaseDDL

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

addBlobCluster, addRidbagPrefetchStats, afterCommitOperations, afterCreateOperations, afterDeleteOperations, afterReadOperations, afterRollbackOperations, afterUpdateOperations, beforeCreateOperations, beforeDeleteOperations, beforeReadOperations, beforeUpdateOperations, callOnCreateListeners, ceilingPhysicalPositions, checkSecurity, checkSecurity, checkSecurity, command, command, commandLikeLegacy, commitPreallocate, countClusterElements, countClusterElements, countClusterElements, countRecords, createSBTree, delete, directRead, dropCluster, dropCluster, endEsclusiveMetadataChange, execute, execute, executeDeleteRecord, executeLikeLegacy, executeReadRecord, floorPhysicalPositions, freeze, getClusterDataRange, getClusterName, getClusterRecordConflictStrategy, getClusterRecordSizeById, getClusterRecordSizeByName, getClustersIds, getConfig, getConflictStrategy, getLastClusterPosition, getRecordMetadata, getSbTreeCollectionManager, getSize, getStats, getStorage, getStorageInfo, higherPhysicalPositions, incrementalBackup, installHooksEmbedded, internalClose, internalCreate, internalLockRecord, internalLockRecord, internalOpen, internalOpen, internalOpen, internalUnlockRecord, isClosed, isReusable, live, live, loadMetadata, lock, lock, lowerPhysicalPositions, query, query, query, queryLikeLegacy, queryStarted, queryStartUsingViewCluster, queryStartUsingViewIndex, readIfVersionIsNotLatest, rebuildIndexes, reload, replaceStorage, resetRecordLoadStats, restore, saveAll, set, setConflictStrategy, setConflictStrategy, setCustom, setDefaultClusterId, startEsclusiveMetadataChange, truncateClass, truncateClass, truncateCluster, truncateClusterInternal, unlock

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

activateOnCurrentThread, beforeCommitOperations, beforeRollbackOperations, begin, begin, browseClass, browseClass, browseCluster, browseCluster, browseCluster, callbackHookFailure, callbackHookFinalize, callbackHooks, callbackHookSuccess, callOnCloseListeners, callOnDropListeners, callOnOpenListeners, checkForClusterPermissions, checkIfActive, checkOpenness, checkRecordClass, checkSecurity, cleanOutRecord, clearDocumentTracking, closeActiveQueries, commit, commit, countClass, countClass, countClass, countView, delete, delete, executeWithRetries, executeWithRetries, executeWithRetries, existsCluster, get, getActiveQueries, getActiveQuery, getBlobClusterIds, getClusterIdByName, getClusterNameById, getClusterNames, getClusters, getCollectionsChanges, getConfiguration, getDatabaseOwner, getDefaultClusterId, getDefaultSerializer, getDictionary, getHooks, getListeners, getLocalCache, getMetadata, getName, getProperties, getProperty, getRecord, getRecordType, getSerializer, getSerializerFactory, getSharedContext, getStatus, getStorageVersions, getTransaction, getType, getUnderlying, getURL, getUser, init, isActiveOnCurrentThread, isClusterEdge, isClusterVertex, isClusterView, isPooled, isPrefetchRecords, 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, queryClosed, queryStarted, rawBegin, registerHook, registerHook, reload, reload, reload, reload, reloadUser, resetInitialization, rollback, rollback, save, save, save, setCurrentDatabaseInThreadLocal, setDatabaseOwner, setDefaultSerializer, setDefaultTransactionMode, setInternal, setPrefetchRecords, setProperty, setSerializer, setStatus, setStatusInternal, setUseLightweightEdges, setUser, setValidationEnabled, swapTx, 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.ODatabase

createClass, executeWithRetry, getClass, registerListener, unregisterListener

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

createClassIfNotExist, createEdgeClass, createVertexClass, newEdge, newVertex, reload

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

indexQuery, isRemote, remoteRollback

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

createInterruptTimerTask

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

queryClosed

Constructor Details

ODatabaseDocumentDistributedPooled

public ODatabaseDocumentDistributedPooled(ODatabasePoolInternal pool,
 OStorage storage,
 ODistributedPlugin distributedPlugin)

Method Details

close

public void close()

Description copied from interface: ODatabase

Closes an opened database, if the database is already closed does nothing, if a transaction is active will be rollback.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ODatabase<ORecord>

Overrides:

close in class ODatabaseDocumentAbstract

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 ODatabaseDocumentDistributed

reuse

public void reuse()

realClose

public void realClose()