com.orientechnologies.orient.object.db

Class OObjectDatabaseTxPooled

java.lang.Object

com.orientechnologies.orient.core.db.ODatabaseWrapperAbstract<ODatabaseDocumentInternal,Object>

com.orientechnologies.orient.object.db.OObjectDatabaseTx

com.orientechnologies.orient.object.db.OObjectDatabaseTxPooled

All Implemented Interfaces:

ODatabaseObject, ODatabase<Object>, ODatabaseInternal<Object>, ODatabasePooled, OUserObject2RecordHandler, OBackupable, Closeable, AutoCloseable

public class OObjectDatabaseTxPooled
extends OObjectDatabaseTx
implements ODatabasePooled

Pooled wrapper to the OObjectDatabaseTx 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.object.db.OObjectDatabaseTx

automaticSchemaGeneration, dictionary, entityManager, lazyLoading, metadata, saveOnlyDirty, TYPE

Fields inherited from class com.orientechnologies.orient.core.db.ODatabaseWrapperAbstract

databaseOwner, underlying

Constructor Summary

Constructors

Constructor and Description
OObjectDatabaseTxPooled(OObjectDatabasePool 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.
OObjectDatabaseTxPooled	create() Creates a new database.
<THISDB extends ODatabase> THISDB	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	isUnderlyingOpen() Tells if the underlying database is closed.
OObjectDatabaseTxPooled	open(OToken iToken) Opens a database using an authentication token received as an argument.
OObjectDatabaseTxPooled	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.object.db.OObjectDatabaseTx

addBlobCluster, attach, attachAndSave, begin, begin, begin, browseClass, browseClass, browseClass, browseClass, browseCluster, callbackHooks, checkSecurity, checkSecurity, checkSecurity, command, command, command, commit, commit, convertParameter, convertParameters, countClass, countClass, countClass, delete, delete, delete, delete, deleteCascade, deleteOrphans, deregisterClassMethodFilter, detach, detach, detachAll, detachAll, execute, execute, executeWithRetry, existsUserObjectByRID, getBlobClusterIds, getConflictStrategy, getDictionary, getEntityManager, getHooks, getIdentity, getListeners, getMetadata, getRecordByUserObject, getSharedContext, getStorageInfo, getTransaction, getType, getUnderlying, getUser, getUserObjectByRecord, getUserObjectByRecord, getVersion, incrementalBackup, init, isAutomaticSchemaGeneration, isLazyLoading, isManaged, isMVCC, isRetainObjects, isSaveOnlyDirty, live, live, load, load, load, load, load, load, lock, lock, newInstance, newInstance, newInstance, newInstance, newInstance, newInstance, objectCommand, objectCommand, objectQuery, objectQuery, pojo2Stream, query, query, query, registerClassMethodFilter, registerHook, registerHook, registerUserObject, registerUserObjectAfterLinkSave, reload, reload, reload, reload, resetInitialization, rollback, rollback, save, save, save, save, setAutomaticSchemaGeneration, setConflictStrategy, setConflictStrategy, setDirty, setInternal, setLazyLoading, setMVCC, setRetainObjects, setSaveOnlyDirty, setUser, stream2pojo, stream2pojo, unlock, unregisterHook, unregisterPojo, unsetDirty

Methods inherited from class com.orientechnologies.orient.core.db.ODatabaseWrapperAbstract

activateOnCurrentThread, addCluster, addCluster, backup, countClusterElements, countClusterElements, countClusterElements, countClusterElements, countClusterElements, create, declareIntent, drop, dropCluster, dropCluster, equals, exists, existsCluster, freeze, freeze, get, getActiveIntent, getClusterIdByName, getClusterNameById, getClusterNames, getClusterRecordSizeById, getClusterRecordSizeByName, getClusters, getConfiguration, getDatabaseOwner, getDefaultClusterId, getLocalCache, getMicroOrRegularTransaction, getName, getProperties, getProperty, getRecordMetadata, getSize, getStatus, getStorage, getURL, isActiveOnCurrentThread, registerListener, release, reload, replaceStorage, restore, set, setDatabaseOwner, setProperty, setStatus, toString, truncateCluster, unregisterListener

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.orientechnologies.orient.core.db.object.ODatabaseObject

detachAll

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

activateOnCurrentThread, addCluster, addCluster, countClusterElements, countClusterElements, countClusterElements, countClusterElements, countClusterElements, create, createClass, declareIntent, drop, dropCluster, dropCluster, exists, existsCluster, freeze, freeze, get, getActiveIntent, getClass, getClusterIdByName, getClusterNameById, getClusterNames, getClusterRecordSizeById, getClusterRecordSizeByName, getClusters, getConfiguration, getDefaultClusterId, getLocalCache, getName, getProperties, getProperty, getRecordMetadata, getSize, getStatus, getURL, isActiveOnCurrentThread, registerListener, release, reload, set, setProperty, setStatus, truncateCluster, unregisterListener

Methods inherited from interface com.orientechnologies.orient.core.util.OBackupable

backup, restore

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

getActiveClusterMap, getActiveDataCenterMap, getEnterpriseEndpoint, getLocalNodeName, isSharded

Constructor Detail

OObjectDatabaseTxPooled

public OObjectDatabaseTxPooled(OObjectDatabasePool 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 OObjectDatabaseTxPooled 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<Object>

Overrides:

open in class OObjectDatabaseTx

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 OObjectDatabaseTxPooled 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<Object>

Overrides:

open in class OObjectDatabaseTx

Parameters:

iToken - Authentication token

Returns:

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

create

public OObjectDatabaseTxPooled create()

Description copied from interface: ODatabase

Creates a new database.

Specified by:

create in interface ODatabase<Object>

Overrides:

create in class ODatabaseWrapperAbstract<ODatabaseDocumentInternal,Object>

Returns:

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

create

public <THISDB extends ODatabase> THISDB 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<Object>

Overrides:

create in class ODatabaseWrapperAbstract<ODatabaseDocumentInternal,Object>

Type Parameters:

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

isClosed

public boolean isClosed()

Description copied from interface: ODatabase

Checks if the database is closed.

Specified by:

isClosed in interface ODatabase<Object>

Overrides:

isClosed in class ODatabaseWrapperAbstract<ODatabaseDocumentInternal,Object>

Returns:

true if is closed, otherwise false.

close

public void close()

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

Specified by:

close in interface ODatabase<Object>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class ODatabaseWrapperAbstract<ODatabaseDocumentInternal,Object>

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 ODatabaseWrapperAbstract<ODatabaseDocumentInternal,Object>

isUnderlyingOpen

public boolean isUnderlyingOpen()

Description copied from interface: ODatabasePooled

Tells if the underlying database is closed.

Specified by:

isUnderlyingOpen in interface ODatabasePooled