Package com.orientechnologies.orient.core.db

Interface ODatabaseDocumentInternal

All Superinterfaces:
AutoCloseable, Closeable, OBackupable, ODatabase<ORecord>, ODatabaseDocument, ODatabaseInternal<ORecord>, ODatabaseSession
All Known Implementing Classes:
ODatabaseDocumentAbstract, ODatabaseDocumentDistributed, ODatabaseDocumentDistributedPooled, ODatabaseDocumentEmbedded, ODatabaseDocumentEmbeddedPooled, ODatabaseDocumentRemote, ODatabaseDocumentRemotePooled
public interface ODatabaseDocumentInternal extends ODatabaseSession, ODatabaseInternal<ORecord>

  • Method Details

    • getStorageVersions

      OCurrentStorageComponentsFactory getStorageVersions()
      Internal. Returns the factory that defines a set of components that current database should use to be compatible to current version of storage. So if you open a database create with old version of OrientDB it defines a components that should be used to provide backward compatibility with that version of database.

    • getSbTreeCollectionManager

      OSBTreeCollectionManager getSbTreeCollectionManager()
      Internal. Gets an instance of sb-tree collection manager for current database.

    • getSerializerFactory

      OBinarySerializerFactory getSerializerFactory()
      Returns:
      the factory of binary serializers.

    • getSerializer

      ORecordSerializer getSerializer()
      Returns:
      serializer which is used for document serialization.

    • setSerializer

      void setSerializer(ORecordSerializer serializer)

    • assignAndCheckCluster

      int assignAndCheckCluster(ORecord record, String iClusterName)

    • loadIfVersionIsNotLatest

      <RET extends ORecord> RET loadIfVersionIsNotLatest(ORID rid, int recordVersion, String fetchPlan, boolean ignoreCache) throws ORecordNotFoundException
      Throws:
      ORecordNotFoundException

    • reloadUser

      void reloadUser()

    • afterReadOperations

      void afterReadOperations(OIdentifiable identifiable)

    • beforeReadOperations

      boolean beforeReadOperations(OIdentifiable identifiable)
      Parameters:
      identifiable -
      Returns:
      true if the record should be skipped

    • beforeCreateOperations

      OIdentifiable beforeCreateOperations(OIdentifiable id, String iClusterName)
      Parameters:
      id -
      iClusterName -
      Returns:
      null if nothing changed the instance if has been modified or replaced

    • beforeUpdateOperations

      OIdentifiable beforeUpdateOperations(OIdentifiable id, String iClusterName)
      Parameters:
      id -
      iClusterName -
      Returns:
      null if nothing changed the instance if has been modified or replaced

    • beforeDeleteOperations

      void beforeDeleteOperations(OIdentifiable id, String iClusterName)

    • afterUpdateOperations

      void afterUpdateOperations(OIdentifiable id)

    • afterCreateOperations

      void afterCreateOperations(OIdentifiable id)

    • afterDeleteOperations

      void afterDeleteOperations(OIdentifiable id)

    • callbackHooks

      ORecordHook.RESULT callbackHooks(ORecordHook.TYPE type, OIdentifiable id)

    • executeReadRecord

      <RET extends ORecord> RET executeReadRecord(ORecordId rid, ORecord iRecord, int recordVersion, String fetchPlan, boolean ignoreCache, boolean iUpdateCache, RecordReader recordReader)

    • executeDeleteRecord

      void executeDeleteRecord(OIdentifiable record, int iVersion, boolean iRequired)

    • setDefaultTransactionMode

      void setDefaultTransactionMode(Map<ORID,OTransactionAbstract.LockedRecordMetadata> noTxLocks)

    • getMetadata

      OMetadataInternal getMetadata()
      Description copied from interface: ODatabase
      Return the OMetadata instance. Cannot be null.
      Specified by:
      getMetadata in interface ODatabase<ORecord>
      Returns:
      The OMetadata instance.

    • copy

      ODatabaseDocumentInternal copy()

    • checkIfActive

      void checkIfActive()

    • callOnOpenListeners

      void callOnOpenListeners()

    • callOnCloseListeners

      void callOnCloseListeners()

    • callOnDropListeners

      void callOnDropListeners()

    • setCustom

      <DB extends ODatabase> DB setCustom(String name, Object iValue)

    • setPrefetchRecords

      void setPrefetchRecords(boolean prefetchRecords)

    • isPrefetchRecords

      boolean isPrefetchRecords()

    • checkForClusterPermissions

      void checkForClusterPermissions(String name)

    • rawBegin

      void rawBegin(OTransaction transaction)

    • getActiveQuery

      default OResultSet getActiveQuery(String id)

    • getActiveQueries

      default Map<String,OQueryDatabaseState> getActiveQueries()

    • isUseLightweightEdges

      boolean isUseLightweightEdges()

    • newLightweightEdge

      OEdge newLightweightEdge(String iClassName, OVertex from, OVertex to)

    • newRegularEdge

      OEdge newRegularEdge(String iClassName, OVertex from, OVertex to)

    • setUseLightweightEdges

      void setUseLightweightEdges(boolean b)

    • cleanOutRecord

      ODatabaseDocumentInternal cleanOutRecord(ORID rid, int version)

    • realClose

      default void realClose()

    • reuse

      default void reuse()

    • sync

      default boolean sync(boolean forceDeployment, boolean tryWithDelta)
      synchronizes current database instance with the rest of the cluster (if in distributed mode).
      Returns:
      true if the database was synchronized, false otherwise

    • getHaStatus

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

    • removeHaServer

      default boolean removeHaServer(String serverName)

    • queryOnNode

      default OExecutionStream queryOnNode(String nodeName, OInternalExecutionPlan executionPlan, Map<Object,Object> inputParameters)
      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

    • internalCommit

      void internalCommit(OTransactionInternal transaction)
      Executed the commit on the storage hiding away storage concepts from the transaction
      Parameters:
      transaction -

    • isClusterVertex

      boolean isClusterVertex(int cluster)

    • isClusterEdge

      boolean isClusterEdge(int cluster)

    • isClusterView

      boolean isClusterView(int cluster)

    • swapTx

      default OTransaction swapTx(OTransaction newTx)

    • internalClose

      void internalClose(boolean recycle)

    • saveAll

      ORecord saveAll(ORecord iRecord, String iClusterName, boolean iForceCreate)

    • getClusterName

      String getClusterName(ORecord record)

    • indexQuery

      default OResultSet indexQuery(String indexName, String query, Object... args)

    • getViewFromCluster

      OView getViewFromCluster(int cluster)

    • internalLockRecord

      void internalLockRecord(OIdentifiable iRecord, OStorage.LOCKING_STRATEGY lockingStrategy)

    • internalUnlockRecord

      void internalUnlockRecord(OIdentifiable iRecord)

    • sendSequenceAction

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

    • isDistributed

      default boolean isDistributed()

    • isRemote

      default boolean isRemote()

    • getCollectionsChanges

      Map<UUID,OBonsaiCollectionPointer> getCollectionsChanges()

    • syncCommit

      default void syncCommit(OTransactionData data)

    • isLocalEnv

      default boolean isLocalEnv()

    • dropClusterInternal

      boolean dropClusterInternal(int clusterId)

    • getStorageId

      default String getStorageId()

    • getClusterDataRange

      long[] getClusterDataRange(int currentClusterId)

    • setDefaultClusterId

      void setDefaultClusterId(int addCluster)

    • getLastClusterPosition

      long getLastClusterPosition(int clusterId)

    • getClusterRecordConflictStrategy

      String getClusterRecordConflictStrategy(int clusterId)

    • getClustersIds

      int[] getClustersIds(Set<String> filterClusters)

    • startEsclusiveMetadataChange

      default void startEsclusiveMetadataChange()

    • endEsclusiveMetadataChange

      default void endEsclusiveMetadataChange()

    • queryStartUsingViewCluster

      default void queryStartUsingViewCluster(int cluster)

    • queryStartUsingViewIndex

      default void queryStartUsingViewIndex(String index)

    • truncateClass

      void truncateClass(String name)

    • truncateClass

      long truncateClass(String name, boolean polimorfic)

    • truncateClusterInternal

      long truncateClusterInternal(String name)

    • commitPreallocate

      void commitPreallocate()

    • internalCommitPreallocate

      void internalCommitPreallocate(OTransactionOptimistic oTransactionOptimistic)

    • remoteRollback

      default void remoteRollback(OTransactionOptimistic oTransactionOptimistic)

    • queryLikeLegacy

      default List<ODocument> queryLikeLegacy(String text, Map<Object,Object> params, int limit, String fetchPlan)

    • commandLikeLegacy

      default List<ODocument> commandLikeLegacy(String text, Map<Object,Object> parameters)

    • executeLikeLegacy

      default List<ODocument> executeLikeLegacy(String language, String text, Map<Object,Object> parameters)

    • higherPhysicalPositions

      OPhysicalPosition[] higherPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)

    • lowerPhysicalPositions

      OPhysicalPosition[] lowerPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)

    • ceilingPhysicalPositions

      OPhysicalPosition[] ceilingPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)

    • floorPhysicalPositions

      OPhysicalPosition[] floorPhysicalPositions(int clusterId, OPhysicalPosition physicalPosition)

    • countRecords

      long countRecords()

    • isReusable

      boolean isReusable()

    • createSBTree

      OBonsaiCollectionPointer createSBTree(int clusterId, UUID ownerUUID)

    • directRead

      ORawBuffer directRead(ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion)

    • readIfVersionIsNotLatest

      ORawBuffer readIfVersionIsNotLatest(ORecordId rid, String fetchPlan, boolean ignoreCache, int recordVersion)