com.orientechnologies.orient.core.db.document

Class ODatabaseDocumentTxPooled

java.lang.Object

com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx

com.orientechnologies.orient.core.db.document.ODatabaseDocumentTxPooled

All Implemented Interfaces:

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

public class ODatabaseDocumentTxPooled
extends ODatabaseDocumentTx
implements ODatabasePooled

Pooled wrapper to the ODatabaseDocumentTx class. Allows to being reused across calls. The close() method does not close the database for real but release it to the owner pool. The database born as opened and will leave open until the pool is closed.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

See Also:

ODatabasePoolBase

Nested Class Summary

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.ODatabaseDocumentTx

embedded, internal, owner, remote

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

TYPE

Constructor Summary

Constructors

Constructor and Description
ODatabaseDocumentTxPooled(ODatabaseDocumentPool iOwnerPool, String iURL, String iUserName, String iUserPassword)

Method Summary

Modifier and Type	Method and Description
protected void	checkOpenness()
void	close() Avoid to close it but rather release itself to the owner pool.
ODatabaseDocumentTxPooled	create() Creates a new database.
<DB extends ODatabase> DB	create(String incrementalBackupPath) Creates new database from database backup.
void	forceClose() Force closing the current instance avoiding to being reused.
boolean	isClosed() Checks if the database is closed.
boolean	isPooled()
boolean	isUnderlyingOpen() Tells if the underlying database is closed.
ODatabaseDocumentTxPooled	open(OToken iToken) Opens a database using an authentication token received as an argument.
ODatabaseDocumentTxPooled	open(String iUserName, String iUserPassword) Opens a database using the user and password received as arguments.
void	reuse(Object iOwner, Object[] iAdditionalArgs) Reuses current instance.

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

activateOnCurrentThread, addBlobCluster, addCluster, addCluster, afterCreateOperations, afterDeleteOperations, afterReadOperations, afterUpdateOperations, assignAndCheckCluster, backup, beforeCreateOperations, beforeDeleteOperations, beforeReadOperations, beforeUpdateOperations, begin, begin, begin, browseClass, browseClass, browseCluster, browseCluster, browseCluster, browseCluster, browseCluster, callbackHooks, callOnCloseListeners, callOnDropListeners, callOnOpenListeners, checkForClusterPermissions, checkIfActive, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, checkSecurity, cleanOutRecord, clearOwner, closeAll, command, command, command, commit, commit, copy, countClass, countClass, countClusterElements, countClusterElements, countClusterElements, countClusterElements, countClusterElements, countView, create, declareIntent, delete, delete, delete, drop, dropCluster, dropCluster, execute, execute, executeDeleteRecord, executeReadRecord, exists, existsCluster, freeze, freeze, get, getActiveIntent, getBlobClusterIds, getClusterIdByName, getClusterName, getClusterNameById, getClusterNames, getClusterRecordSizeById, getClusterRecordSizeByName, getClusters, getCollectionsChanges, getConfiguration, getConflictStrategy, getDatabaseOwner, getDefaultClusterId, getDefaultSerializer, getDictionary, getHooks, getListeners, getLocalCache, getMetadata, getMicroOrRegularTransaction, getName, getOrCreateEmbeddedFactory, getOrCreateRemoteFactory, getProperties, getProperty, getRecord, getRecordMetadata, getRecordType, getSbTreeCollectionManager, getSerializer, getSerializerFactory, getSharedContext, getSize, getStatus, getStorage, getStorageInfo, getStorageVersions, getTransaction, getType, getUnderlying, getURL, getUser, getViewFromCluster, incrementalBackup, internalClose, internalCommit, internalLockRecord, internalUnlockRecord, isActiveOnCurrentThread, isClusterEdge, isClusterVertex, isClusterView, isMVCC, isPrefetchRecords, isRemote, isRetainRecords, isUseLightweightEdges, isValidationEnabled, live, live, load, load, load, load, load, load, loadIfVersionIsNotLatest, lock, lock, newBlob, newBlob, newEdge, newEdge, newElement, newElement, newEmbeddedElement, newEmbeddedElement, newInstance, newInstance, newLightweightEdge, newRegularEdge, newVertex, newVertex, query, query, query, rawBegin, recycle, registerHook, registerHook, registerListener, release, reload, reload, reload, reloadUser, replaceStorage, resetInitialization, restore, rollback, rollback, save, save, save, save, saveAll, sendSequenceAction, set, setConflictStrategy, setConflictStrategy, setCustom, setDatabaseOwner, setDefaultSerializer, setDefaultTransactionMode, setInternal, setMVCC, setPrefetchRecords, setProperty, setRetainRecords, setSerializer, setStatus, setupThreadOwner, setUseLightweightEdges, setUser, setValidationEnabled, truncateCluster, unlock, unregisterHook, 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.ODatabaseDocumentInternal

getActiveQueries, getActiveQuery, getCommandInterruptionDepth, getHaStatus, indexQuery, isCommandInterrupted, isDistributed, queryOnNode, realClose, removeHaServer, reuse, setCommandInterrupted, setCommandInterruptionDepth, swapTx, sync, syncCommit

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

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

addRidbagPrefetchStats, createInterruptTimerTask, getActiveClusterMap, getActiveDataCenterMap, getEnterpriseEndpoint, getLocalNodeName, getStats, isSharded, resetRecordLoadStats

Constructor Detail

ODatabaseDocumentTxPooled

public ODatabaseDocumentTxPooled(ODatabaseDocumentPool iOwnerPool,
                                 String iURL,
                                 String iUserName,
                                 String iUserPassword)

Method Detail

reuse

public void reuse(Object iOwner,
                  Object[] iAdditionalArgs)

Description copied from interface: ODatabasePooled

Reuses current instance.

Specified by:

reuse in interface ODatabasePooled

open

public ODatabaseDocumentTxPooled 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>

Overrides:

open in class ODatabaseDocumentTx

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.

open

public ODatabaseDocumentTxPooled open(OToken iToken)

Description copied from interface: ODatabaseInternal

Opens a database using an authentication token received as an argument.

Specified by:

open in interface ODatabaseInternal<ORecord>

Overrides:

open in class ODatabaseDocumentTx

Parameters:

iToken - Authentication token

Returns:

The Database instance itself giving a "fluent interface". Useful to call multiple methods in chain.

create

public ODatabaseDocumentTxPooled create()

Description copied from interface: ODatabase

Creates a new database.

Specified by:

create in interface ODatabase<ORecord>

Overrides:

create in class ODatabaseDocumentTx

Returns:

The Database instance itself giving a "fluent interface". Useful to call multiple methods in chain.

create

public <DB extends ODatabase> DB create(String incrementalBackupPath)

Description copied from interface: ODatabase

Creates new database from database backup. Only incremental backups are supported.

Specified by:

create in interface ODatabase<ORecord>

Overrides:

create in class ODatabaseDocumentTx

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.

isUnderlyingOpen

public boolean isUnderlyingOpen()

Description copied from interface: ODatabasePooled

Tells if the underlying database is closed.

Specified by:

isUnderlyingOpen in interface ODatabasePooled

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 ODatabaseDocumentTx

Returns:

true if is closed, otherwise false.

isPooled

public boolean isPooled()

Specified by:

isPooled in interface ODatabaseDocument

Overrides:

isPooled in class ODatabaseDocumentTx

Returns:

true if database is obtained from the pool and false otherwise.

close

public void close()

Avoid to close it but rather release itself to the owner pool.

Specified by:

close in interface ODatabase<ORecord>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class ODatabaseDocumentTx

forceClose

public void forceClose()

Description copied from interface: ODatabasePooled

Force closing the current instance avoiding to being reused.

Specified by:

forceClose in interface ODatabasePooled

checkOpenness

protected void checkOpenness()

Overrides:

checkOpenness in class ODatabaseDocumentTx