ODatabaseDocumentEmbedded (OrientDB 3.0.44 API)

java.lang.Object
- com.orientechnologies.common.listener.OListenerManger<ODatabaseListener>
- - com.orientechnologies.orient.core.db.document.ODatabaseDocumentAbstract
  - - com.orientechnologies.orient.core.db.document.ODatabaseDocumentEmbedded

All Implemented Interfaces:

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

Direct Known Subclasses:

ODatabaseDocumentDistributed, ODatabaseDocumentEmbeddedPooled
```
public class ODatabaseDocumentEmbedded
extends ODatabaseDocumentAbstract
implements OQueryLifecycleListener
```
Created by tglman on 27/06/16.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

protected class ODatabaseDocumentEmbedded.InterruptTimerTask
- Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.db.ODatabase
  ODatabase.ATTRIBUTES, ODatabase.OPERATION_MODE, ODatabase.STATUS

Nested Classes
Modifier and Type	Class and Description
`protected class`	`ODatabaseDocumentEmbedded.InterruptTimerTask`

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

ODatabaseDocumentEmbedded(OStorage storage)

Constructors
Constructor and Description
`ODatabaseDocumentEmbedded(OStorage storage)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`int`	`addBlobCluster(String iClusterName, Object... iParameters)` Adds a new cluster for store blobs.
`protected void`	`afterCommitOperations()`
`void`	`afterCreateOperations(OIdentifiable id)`
`void`	`afterDeleteOperations(OIdentifiable id)`
`void`	`afterReadOperations(OIdentifiable identifiable)`
`protected void`	`afterRollbackOperations()`
`void`	`afterUpdateOperations(OIdentifiable id)`
`OIdentifiable`	`beforeCreateOperations(OIdentifiable id, String iClusterName)`
`void`	`beforeDeleteOperations(OIdentifiable id, String iClusterName)`
`boolean`	`beforeReadOperations(OIdentifiable identifiable)`
`OIdentifiable`	`beforeUpdateOperations(OIdentifiable id, String iClusterName)`
`protected OMicroTransaction`	`beginMicroTransaction()`
`void`	`callOnCreateListeners()`
`OResultSet`	`command(String query, Map args)` Executes a generic (idempotent or non idempotent) command.
`OResultSet`	`command(String query, Object[] args)` Executes a generic (idempotent or non idempotent) command.
`ODatabaseDocumentInternal`	`copy()` Returns a copy of current database if it's open.
`<DB extends ODatabase> DB`	`create()` Creates a new database.
`<DB extends ODatabase> DB`	`create(Map<OGlobalConfiguration,Object> iInitialSettings)` Creates a new database passing initial settings.
`<DB extends ODatabase> DB`	`create(String incrementalBackupPath)` Creates new database from database backup.
`TimerTask`	`createInterruptTimerTask()` creates an interrupt timer task for this db instance (without scheduling it!)
`protected void`	`createMetadata()`
`static void`	`deInit(OAbstractPaginatedStorage storage)`
`ODatabaseDocumentAbstract`	`delete(ORecord record)` Deletes a document.
`void`	`drop()` Drops a database.
`OResultSet`	`execute(String language, String script, Map<String,?> args)` Execute a script of a specified query language The result set has to be closed after usage Sample usage:
`OResultSet`	`execute(String language, String script, Object... args)` Execute a script in a specified query language.
`void`	`executeDeleteRecord(OIdentifiable record, int iVersion, boolean iRequired, ODatabase.OPERATION_MODE iMode, boolean prohibitTombstones)` This method is internal, it can be subject to signature change or be removed, do not use.
`<RET extends ORecord> RET`	`executeSaveRecord(ORecord record, String clusterName, int ver, ODatabase.OPERATION_MODE mode, boolean forceCreate, ORecordCallback<? extends Number> recordCreatedCallback, ORecordCallback<Integer> recordUpdatedCallback)` This method is internal, it can be subject to signature change or be removed, do not use.
`boolean`	`exists()` Checks if the database exists.
`int`	`getCommandInterruptionDepth()`
`OrientDBConfig`	`getConfig()`
`OStorage`	`getStorage()` Returns the underlying storage implementation.
`void`	`init(OrientDBConfig config)`
`protected void`	`installHooksEmbedded()`
`void`	`internalCreate(OrientDBConfig config)`
`void`	`internalOpen(String iUserName, String iUserPassword)`
`void`	`internalOpen(String iUserName, String iUserPassword, boolean checkPassword)`
`void`	`interruptExecution(Thread thread)`
`boolean`	`isClosed()` Checks if the database is closed.
`boolean`	`isCommandInterrupted()`
`boolean`	`isStorageCommitHappening()` needed for query interrupt
`OLiveQueryMonitor`	`live(String query, OLiveQueryResultListener listener, Map<String,?> args)` Subscribe a query as a live query for future create/update event with the referred conditions
`OLiveQueryMonitor`	`live(String query, OLiveQueryResultListener listener, Object... args)` Subscribe a query as a live query for future create/update event with the referred conditions
`protected void`	`loadMetadata()`
`<DB extends ODatabase> DB`	`open(OToken iToken)` Deprecated.
`<DB extends ODatabase> DB`	`open(String iUserName, String iUserPassword)` Opens a database using the user and password received as arguments.
`OLocalResultSetLifecycleDecorator`	`query(OExecutionPlan plan, Map<Object,Object> params)`
`OResultSet`	`query(String query, Map args)` Executes an SQL query (idempotent).
`OResultSet`	`query(String query, Object[] args)` Executes an SQL query.
`void`	`rebuildIndexes()`
`void`	`recycle(ORecord record)`
`void`	`replaceStorage(OStorage iNewStorage)` Internal only: replace the storage with a new one.
`<DB extends ODatabase> DB`	`set(ODatabase.ATTRIBUTES iAttribute, Object iValue)` Sets a database attribute value
`void`	`setCommandInterrupted(boolean commandInterrupted)`
`void`	`setCommandInterruptionDepth(int commandInterruptionDepth)`
`<DB extends ODatabase> DB`	`setCustom(String name, Object iValue)`
`void`	`setStorageCommitHappening(boolean val)`

Methods inherited from class com.orientechnologies.orient.core.db.document.ODatabaseDocumentAbstract
activateOnCurrentThread, addCluster, addCluster, addRidbagPrefetchStats, assignAndCheckCluster, 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, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, cleanOutRecord, clearDocumentTracking, close, closeActiveQueries, command, commit, commit, countClass, countClass, countClusterElements, countClusterElements, countClusterElements, countClusterElements, countClusterElements, declareIntent, delete, delete, delete, delete, dropCluster, dropCluster, executeHideRecord, executeReadRecord, executeSaveEmptyRecord, 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, getStats, getStatus, getStorageVersions, getTransaction, getType, getUnderlying, getURL, getUser, hide, incrementalBackup, init, internalClose, internalCommit, isActiveOnCurrentThread, isClusterEdge, isClusterVertex, isMVCC, isPooled, isPrefetchRecords, isRetainRecords, isUseLightweightEdges, isValidationEnabled, load, load, load, load, load, load, load, load, load, load, loadIfVersionIsNotLatest, newBlob, newBlob, newEdge, newEdge, newElement, newElement, newElement, newInstance, newInstance, newLightweightEdge, newRegularEdge, newVertex, newVertex, query, queryClosed, queryStarted, rawBegin, registerHook, registerHook, release, reload, reload, reload, reload, reload, reloadUser, resetInitialization, resetRecordLoadStats, 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
getHaStatus, indexQuery, queryOnNode, realClose, removeHaServer, 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

Methods inherited from interface com.orientechnologies.orient.core.db.ODatabaseInternal
getActiveClusterMap, getActiveDataCenterMap, getEnterpriseEndpoint, getLocalNodeName, isSharded

- Constructor Detail
  - ODatabaseDocumentEmbedded
```
public ODatabaseDocumentEmbedded(OStorage storage)
```
- Method Detail
  - open
```
public <DB extends ODatabase> DB open(String iUserName,
                                      String iUserPassword)
```
    Description copied from interface: ODatabase
    
    Opens a database using the user and password received as arguments.
    
    Specified by:
    
    open in interface ODatabase<ORecord>
    
    Parameters:
    
    iUserName - Username to login
    
    iUserPassword - Password associated to the user
    
    Returns:
    
    The Database instance itself giving a "fluent interface". Useful to call multiple methods in chain.
  - init
```
public void init(OrientDBConfig config)
```
  - internalOpen
```
public void internalOpen(String iUserName,
                         String iUserPassword)
```
  - internalOpen
```
public void internalOpen(String iUserName,
                         String iUserPassword,
                         boolean checkPassword)
```
  - open
```
@Deprecated
public <DB extends ODatabase> DB open(OToken iToken)
```
    Deprecated.
    
    Opens a database using an authentication token received as an argument.
    
    Specified by:
    
    open in interface ODatabaseInternal<ORecord>
    
    Parameters:
    
    iToken - Authentication token
    
    Returns:
    
    The Database instance itself giving a "fluent interface". Useful to call multiple methods in chain.
  - create
```
public <DB extends ODatabase> DB create()
```
    Description copied from interface: ODatabase
    
    Creates a new database.
    
    Specified by:
    
    create in interface ODatabase<ORecord>
    
    Returns:
    
    The Database instance itself giving a "fluent interface". Useful to call multiple methods in chain.
  - internalCreate
```
public void internalCreate(OrientDBConfig config)
```
  - callOnCreateListeners
```
public void callOnCreateListeners()
```
  - createMetadata
```
protected void createMetadata()
```
  - loadMetadata
```
protected void loadMetadata()
```
    Specified by:
    
    loadMetadata in class ODatabaseDocumentAbstract
  - set
```
public <DB extends ODatabase> DB set(ODatabase.ATTRIBUTES iAttribute,
                                     Object iValue)
```
    Description copied from interface: ODatabase
    
    Sets a database attribute value
    
    Specified by:
    
    set in interface ODatabase<ORecord>
    
    Parameters:
    
    iAttribute - Attributes between #ATTRIBUTES enum
    
    iValue - Value to set
    
    Returns:
    
    underlying
  - setCustom
```
public <DB extends ODatabase> DB setCustom(String name,
                                           Object iValue)
```
    Specified by:
    
    setCustom in interface ODatabaseDocumentInternal
  - create
```
public <DB extends ODatabase> DB create(String incrementalBackupPath)
```
    Creates new database from database backup. Only incremental backups are supported.
    
    Specified by:
    
    create in interface ODatabase<ORecord>
    
    Type Parameters:
    
    DB - Concrete database instance type.
    
    Parameters:
    
    incrementalBackupPath - Path to incremental backup
    
    Returns:
    
    he Database instance itself giving a "fluent interface". Useful to call multiple methods in chain.
  - create
```
public <DB extends ODatabase> DB create(Map<OGlobalConfiguration,Object> iInitialSettings)
```
    Description copied from interface: ODatabase
    
    Creates a new database passing initial settings.
    
    Specified by:
    
    create in interface ODatabase<ORecord>
    
    Returns:
    
    The Database instance itself giving a "fluent interface". Useful to call multiple methods in chain.
  - drop
```
public void drop()
```
    Drops a database.
    
    Specified by:
    
    drop in interface ODatabase<ORecord>
  - copy
```
public ODatabaseDocumentInternal copy()
```
    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
  - exists
```
public boolean exists()
```
    Description copied from interface: ODatabase
    
    Checks if the database exists.
    
    Specified by:
    
    exists in interface ODatabase<ORecord>
    
    Returns:
    
    True if already exists, otherwise false.
  - isClosed
```
public boolean isClosed()
```
    Description copied from interface: ODatabase
    
    Checks if the database is closed.
    
    Specified by:
    
    isClosed in interface ODatabase<ORecord>
    
    Overrides:
    
    isClosed in class ODatabaseDocumentAbstract
    
    Returns:
    
    true if is closed, otherwise false.
  - rebuildIndexes
```
public void rebuildIndexes()
```
  - installHooksEmbedded
```
protected void installHooksEmbedded()
```
  - getStorage
```
public OStorage getStorage()
```
    Description copied from interface: ODatabaseInternal
    
    Returns the underlying storage implementation.
    
    Specified by:
    
    getStorage in interface ODatabaseInternal<ORecord>
    
    Returns:
    
    The underlying storage implementation
    
    See Also:
    
    OStorage
  - replaceStorage
```
public void replaceStorage(OStorage iNewStorage)
```
    Description copied from interface: ODatabaseInternal
    
    Internal only: replace the storage with a new one.
    
    Specified by:
    
    replaceStorage in interface ODatabaseInternal<ORecord>
    
    Parameters:
    
    iNewStorage - The new storage to use. Usually it's a wrapped instance of the current cluster.
  - query
```
public OResultSet query(String query,
                        Object[] args)
```
    Description copied from interface: ODatabase
    
    Executes an SQL query. The result set has to be closed after usage
    
    Sample usage:
    OResultSet rs = db.query("SELECT FROM V where name = ?", "John"); while(rs.hasNext()){ OResult item = rs.next(); ... } rs.close();
    
    Specified by:
    
    query in interface ODatabase<ORecord>
    
    Parameters:
    
    query - the query string
    
    args - query parameters (positional)
    
    Returns:
    
    the query result set
  - query
```
public OResultSet query(String query,
                        Map args)
```
    Description copied from interface: ODatabase
    
    Executes an SQL query (idempotent). The result set has to be closed after usage
    
    Sample usage:
    Map<String, Object> params = new HashMapMap<>(); params.put("name", "John"); OResultSet rs = db.query("SELECT FROM V where name = :name", params); while(rs.hasNext()){ OResult item = rs.next(); ... } rs.close();
    
    Specified by:
    
    query in interface ODatabase<ORecord>
    
    Parameters:
    
    query - the query string
    
    args - query parameters (named)
    
    Returns:
  - command
```
public OResultSet command(String query,
                          Object[] args)
```
    Description copied from interface: ODatabase
    
    Executes a generic (idempotent or non idempotent) command. The result set has to be closed after usage
    
    Sample usage:
    OResultSet rs = db.command("INSERT INTO Person SET name = ?", "John"); ... rs.close();
    
    Specified by:
    
    command in interface ODatabase<ORecord>
    
    args - query arguments
    
    Returns:
  - command
```
public OResultSet command(String query,
                          Map args)
```
    Description copied from interface: ODatabase
    
    Executes a generic (idempotent or non idempotent) command. The result set has to be closed after usage
    
    Sample usage:
    Map<String, Object> params = new HashMapMap<>(); params.put("name", "John"); OResultSet rs = db.query("INSERT INTO Person SET name = :name", params); ... rs.close();
    
    Specified by:
    
    command in interface ODatabase<ORecord>
    
    Returns:
  - execute
```
public OResultSet execute(String language,
                          String script,
                          Object... args)
```
    Description copied from interface: ODatabase
    
    Execute a script in a specified query language. The result set has to be closed after usage
    
    Sample usage:
    String script = "INSERT INTO Person SET name = 'foo', surname = ?;"+ "INSERT INTO Person SET name = 'bar', surname = ?;"+ "INSERT INTO Person SET name = 'baz', surname = ?;";
    OResultSet rs = db.execute("sql", script, "Surname1", "Surname2", "Surname3"); ... rs.close();
    
    Specified by:
    
    execute in interface ODatabase<ORecord>
    
    Returns:
  - execute
```
public OResultSet execute(String language,
                          String script,
                          Map<String,?> args)
```
    Description copied from interface: ODatabase
    
    Execute a script of a specified query language The result set has to be closed after usage
    
    Sample usage:
    Map<String, Object> params = new HashMapMap<>(); params.put("surname1", "Jones"); params.put("surname2", "May"); params.put("surname3", "Ali");
    String script = "INSERT INTO Person SET name = 'foo', surname = :surname1;"+ "INSERT INTO Person SET name = 'bar', surname = :surname2;"+ "INSERT INTO Person SET name = 'baz', surname = :surname3;";
    OResultSet rs = db.execute("sql", script, params); ... rs.close();
    
    Specified by:
    
    execute in interface ODatabase<ORecord>
    
    Returns:
  - query
```
public OLocalResultSetLifecycleDecorator query(OExecutionPlan plan,
                                               Map<Object,Object> params)
```
  - getConfig
```
public OrientDBConfig getConfig()
```
  - live
```
public OLiveQueryMonitor live(String query,
                              OLiveQueryResultListener listener,
                              Object... args)
```
    Description copied from interface: ODatabase
    
    Subscribe a query as a live query for future create/update event with the referred conditions
    
    Specified by:
    
    live in interface ODatabase<ORecord>
    
    Parameters:
    
    query - live query
    
    listener - the listener that receive the query results
    
    args - the live query args
  - live
```
public OLiveQueryMonitor live(String query,
                              OLiveQueryResultListener listener,
                              Map<String,?> args)
```
    Description copied from interface: ODatabase
    
    Subscribe a query as a live query for future create/update event with the referred conditions
    
    Specified by:
    
    live in interface ODatabase<ORecord>
    
    Parameters:
    
    query - live query
    
    listener - the listener that receive the query results
    
    args - the live query args
  - recycle
```
public void recycle(ORecord record)
```
    Specified by:
    
    recycle in interface ODatabaseDocumentInternal
  - beginMicroTransaction
```
protected OMicroTransaction beginMicroTransaction()
```
  - deInit
```
public static void deInit(OAbstractPaginatedStorage storage)
```
  - addBlobCluster
```
public int addBlobCluster(String iClusterName,
                          Object... iParameters)
```
    Description copied from interface: ODatabase
    
    Adds a new cluster for store blobs.
    
    Specified by:
    
    addBlobCluster in interface ODatabaseDocument
    
    Specified by:
    
    addBlobCluster in interface ODatabase<ORecord>
    
    Parameters:
    
    iClusterName - Cluster name
    
    iParameters - Additional parameters to pass to the factories
    
    Returns:
    
    Cluster id
  - executeDeleteRecord
```
public void executeDeleteRecord(OIdentifiable record,
                                int iVersion,
                                boolean iRequired,
                                ODatabase.OPERATION_MODE iMode,
                                boolean prohibitTombstones)
```
    This method is internal, it can be subject to signature change or be removed, do not use.
    
    Specified by:
    
    executeDeleteRecord in interface ODatabaseDocumentInternal
    
    Specified by:
    
    executeDeleteRecord in class ODatabaseDocumentAbstract
  - executeSaveRecord
```
public <RET extends ORecord> RET executeSaveRecord(ORecord record,
                                                   String clusterName,
                                                   int ver,
                                                   ODatabase.OPERATION_MODE mode,
                                                   boolean forceCreate,
                                                   ORecordCallback<? extends Number> recordCreatedCallback,
                                                   ORecordCallback<Integer> recordUpdatedCallback)
```
    This method is internal, it can be subject to signature change or be removed, do not use.
    
    Specified by:
    
    executeSaveRecord in interface ODatabaseDocumentInternal
    
    Specified by:
    
    executeSaveRecord in class ODatabaseDocumentAbstract
  - delete
```
public ODatabaseDocumentAbstract delete(ORecord record)
```
    Deletes a document. Behavior depends by the current running transaction if any. If no transaction is running then the record is deleted immediately. If an Optimistic transaction is running then the record will be deleted at commit time. The current transaction will continue to see the record as deleted, while others not. If a Pessimistic transaction is running, then an exclusive lock is acquired against the record. Current transaction will continue to see the record as deleted, while others cannot access to it since it's locked.
    If MVCC is enabled and the version of the document is different by the version stored in the database, then a OConcurrentModificationException exception is thrown.
    
    Specified by:
    
    delete in interface ODatabase<ORecord>
    
    Parameters:
    
    record - record to delete
    
    Returns:
    
    The Database instance itself giving a "fluent interface". Useful to call multiple methods in chain.
    
    See Also:
    
    #setMVCC(boolean), {@link #isMVCC()}
  - beforeCreateOperations
```
public OIdentifiable beforeCreateOperations(OIdentifiable id,
                                            String iClusterName)
```
    Specified by:
    
    beforeCreateOperations in interface ODatabaseDocumentInternal
    
    Returns:
    
    null if nothing changed the instance if has been modified or replaced
  - beforeUpdateOperations
```
public OIdentifiable beforeUpdateOperations(OIdentifiable id,
                                            String iClusterName)
```
    Specified by:
    
    beforeUpdateOperations in interface ODatabaseDocumentInternal
    
    Returns:
    
    null if nothing changed the instance if has been modified or replaced
  - beforeDeleteOperations
```
public void beforeDeleteOperations(OIdentifiable id,
                                   String iClusterName)
```
    Specified by:
    
    beforeDeleteOperations in interface ODatabaseDocumentInternal
  - afterCreateOperations
```
public void afterCreateOperations(OIdentifiable id)
```
    Specified by:
    
    afterCreateOperations in interface ODatabaseDocumentInternal
  - afterUpdateOperations
```
public void afterUpdateOperations(OIdentifiable id)
```
    Specified by:
    
    afterUpdateOperations in interface ODatabaseDocumentInternal
  - afterDeleteOperations
```
public void afterDeleteOperations(OIdentifiable id)
```
    Specified by:
    
    afterDeleteOperations in interface ODatabaseDocumentInternal
  - afterReadOperations
```
public void afterReadOperations(OIdentifiable identifiable)
```
    Specified by:
    
    afterReadOperations in interface ODatabaseDocumentInternal
  - beforeReadOperations
```
public boolean beforeReadOperations(OIdentifiable identifiable)
```
    Specified by:
    
    beforeReadOperations in interface ODatabaseDocumentInternal
    
    Returns:
    
    true if the record should be skipped
  - afterCommitOperations
```
protected void afterCommitOperations()
```
    Overrides:
    
    afterCommitOperations in class ODatabaseDocumentAbstract
  - afterRollbackOperations
```
protected void afterRollbackOperations()
```
    Overrides:
    
    afterRollbackOperations in class ODatabaseDocumentAbstract
  - interruptExecution
```
public void interruptExecution(Thread thread)
```
    Specified by:
    
    interruptExecution in interface ODatabaseInternal<ORecord>
  - isCommandInterrupted
```
public boolean isCommandInterrupted()
```
    Specified by:
    
    isCommandInterrupted in interface ODatabaseDocumentInternal
  - setCommandInterrupted
```
public void setCommandInterrupted(boolean commandInterrupted)
```
    Specified by:
    
    setCommandInterrupted in interface ODatabaseDocumentInternal
  - getCommandInterruptionDepth
```
public int getCommandInterruptionDepth()
```
    Specified by:
    
    getCommandInterruptionDepth in interface ODatabaseDocumentInternal
  - setCommandInterruptionDepth
```
public void setCommandInterruptionDepth(int commandInterruptionDepth)
```
    Specified by:
    
    setCommandInterruptionDepth in interface ODatabaseDocumentInternal
  - isStorageCommitHappening
```
public boolean isStorageCommitHappening()
```
    Description copied from interface: ODatabaseDocumentInternal
    
    needed for query interrupt
    
    Specified by:
    
    isStorageCommitHappening in interface ODatabaseDocumentInternal
    
    Returns:
  - setStorageCommitHappening
```
public void setStorageCommitHappening(boolean val)
```
    Specified by:
    
    setStorageCommitHappening in interface ODatabaseDocumentInternal
  - createInterruptTimerTask
```
public TimerTask createInterruptTimerTask()
```
    Description copied from interface: ODatabaseInternal
    
    creates an interrupt timer task for this db instance (without scheduling it!)
    
    Specified by:
    
    createInterruptTimerTask in interface ODatabaseInternal<ORecord>
    
    Returns:
    
    the timer task. Null if this operation is not supported for current db impl.

Class ODatabaseDocumentEmbedded

Nested Class Summary

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

Field Summary

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

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

Constructor Summary

Method Summary

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

Methods inherited from class com.orientechnologies.common.listener.OListenerManger

Methods inherited from class java.lang.Object

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

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

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

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

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

Constructor Detail

ODatabaseDocumentEmbedded

Method Detail

open

init

internalOpen

internalOpen

open

create

internalCreate

callOnCreateListeners

createMetadata

loadMetadata

set

setCustom

create

create

drop

copy

exists

isClosed

rebuildIndexes

installHooksEmbedded

getStorage

replaceStorage

query

query

command

command

execute

execute

query

getConfig

live

live

recycle

beginMicroTransaction

deInit

addBlobCluster

executeDeleteRecord

executeSaveRecord

delete

beforeCreateOperations

beforeUpdateOperations

beforeDeleteOperations

afterCreateOperations

afterUpdateOperations

afterDeleteOperations

afterReadOperations

beforeReadOperations

afterCommitOperations

afterRollbackOperations

interruptExecution

isCommandInterrupted

setCommandInterrupted

getCommandInterruptionDepth

setCommandInterruptionDepth

isStorageCommitHappening

setStorageCommitHappening

createInterruptTimerTask