com.orientechnologies.orient.core.db

Class ODatabaseWrapperAbstract<DB extends ODatabaseInternal,T>

java.lang.Object

com.orientechnologies.orient.core.db.ODatabaseWrapperAbstract<DB,T>

All Implemented Interfaces:

ODatabase<T>, ODatabaseInternal<T>, OBackupable, Closeable, AutoCloseable

Direct Known Subclasses:

OObjectDatabaseTx

public abstract class ODatabaseWrapperAbstract<DB extends ODatabaseInternal,T>
extends Object
implements ODatabaseInternal<T>

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

Modifier and Type	Field and Description
protected ODatabaseInternal<?>	databaseOwner
protected DB	underlying

Constructor Summary

Constructors

Constructor and Description
ODatabaseWrapperAbstract(DB iDatabase)

Method Summary

Modifier and Type	Method and Description
ODatabase	activateOnCurrentThread() Activate current database instance on current thread.
int	addCluster(String iClusterName, int iRequestedId, Object... iParameters) Adds a new cluster.
int	addCluster(String iClusterName, Object... iParameters) Adds a new cluster.
List<String>	backup(OutputStream out, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener, int compressionLevel, int bufferSize) Executes a backup of the database.
protected void	checkOpenness()
void	close() Closes an opened database, if the database is already closed does nothing, if a transaction is active will be rollback.
long	countClusterElements(int iClusterId) Counts all the entities in the specified cluster id.
long	countClusterElements(int[] iClusterIds) Counts all the entities in the specified cluster ids.
long	countClusterElements(int[] iClusterIds, boolean countTombstones)
long	countClusterElements(int iClusterId, boolean countTombstones)
long	countClusterElements(String iClusterName) Counts all the entities in the specified cluster name.
<THISDB extends ODatabase> THISDB	create() Creates a new database.
<THISDB extends ODatabase> THISDB	create(Map<OGlobalConfiguration,Object> iInitialSettings) Creates a new database passing initial settings.
<THISDB extends ODatabase> THISDB	create(String incrementalBackupPath) Creates new database from database backup.
boolean	declareIntent(OIntent iIntent) Declares an intent to the database.
void	drop() Drops a database.
boolean	dropCluster(int iClusterId, boolean iTruncate) Drops a cluster by its id.
boolean	dropCluster(String iClusterName, boolean iTruncate) Drops a cluster by its name.
boolean	equals(Object iOther)
boolean	exists() Checks if the database exists.
boolean	existsCluster(String iClusterName) Returns true if the cluster exists, otherwise false.
void	freeze() Flush cached storage content to the disk.
void	freeze(boolean throwException) Flush cached storage content to the disk.
Object	get(ODatabase.ATTRIBUTES iAttribute) Returns a database attribute value
OIntent	getActiveIntent() Get the active intent in the current session.
int	getClusterIdByName(String iClusterName) Returns the cluster id by name.
String	getClusterNameById(int iClusterId) Returns the cluster name by id.
Collection<String>	getClusterNames() Returns all the names of the clusters.
long	getClusterRecordSizeById(int iClusterId) Returns the total size of records contained in the cluster defined by its id.
long	getClusterRecordSizeByName(String iClusterName) Returns the total size of records contained in the cluster defined by its name.
int	getClusters() Returns the number of clusters.
OContextConfiguration	getConfiguration() Returns the database configuration settings.
ODatabaseInternal<?>	getDatabaseOwner() Returns the database owner.
int	getDefaultClusterId() Returns the default cluster id.
OLocalRecordCache	getLocalCache() Returns the level1 cache.
OBasicTransaction	getMicroOrRegularTransaction() The active implicit micro-transaction or active/inactive regular transaction.
String	getName() Returns the database name.
Iterator<Map.Entry<String,Object>>	getProperties() Returns an iterator of the property entries
Object	getProperty(String iName) Gets the property value.
ORecordMetadata	getRecordMetadata(ORID rid)
long	getSize() Returns the total size of database as used space.
ODatabase.STATUS	getStatus() Returns the current status of database.
OStorage	getStorage() Returns the underlying storage implementation.
<DBTYPE extends ODatabase> DBTYPE	getUnderlying() Return the underlying database.
String	getURL() Returns the database URL.
boolean	isActiveOnCurrentThread() Returns true if the current database instance is active on current thread, otherwise false.
boolean	isClosed() Checks if the database is closed.
<THISDB extends ODatabase> THISDB	open(OToken iToken) Opens a database using an authentication token received as an argument.
<THISDB extends ODatabase> THISDB	open(String iUserName, String iUserPassword) Opens a database using the user and password received as arguments.
void	registerListener(ODatabaseListener iListener) Registers a listener to the database events.
void	release() Allows to execute write-related commands on DB.
void	reload() Reloads the database information like the cluster list.
void	replaceStorage(OStorage iNewStorage) Internal only: replace the storage with a new one.
void	restore(InputStream in, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener) Executes a restore of a database backup.
<THISDB extends ODatabase> THISDB	set(ODatabase.ATTRIBUTES attribute, Object iValue) Sets a database attribute value
ODatabaseInternal<?>	setDatabaseOwner(ODatabaseInternal<?> iOwner) Internal.
Object	setProperty(String iName, Object iValue) Sets a property value
<THISDB extends ODatabase> THISDB	setStatus(ODatabase.STATUS iStatus) Set the current status of database.
String	toString()
void	truncateCluster(String clusterName) Removes all data in the cluster with given name.
void	unregisterListener(ODatabaseListener iListener) Unregisters a listener to the database events.

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

addRidbagPrefetchStats, createInterruptTimerTask, getActiveClusterMap, getActiveDataCenterMap, getEnterpriseEndpoint, getLocalNodeName, getSharedContext, getStats, interruptExecution, isSharded, resetInitialization, resetRecordLoadStats, setInternal, setUser

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

addBlobCluster, begin, begin, begin, command, command, command, commit, commit, createClass, delete, delete, delete, execute, execute, executeWithRetry, getBlobClusterIds, getClass, getConflictStrategy, getDictionary, getHooks, getListeners, getMetadata, getTransaction, getType, getUser, incrementalBackup, isMVCC, live, live, load, load, load, load, load, load, load, load, load, load, newInstance, query, query, query, registerHook, registerHook, reload, reload, rollback, rollback, save, save, save, save, setConflictStrategy, setConflictStrategy, setMVCC, unregisterHook

Field Detail

underlying

protected DB extends ODatabaseInternal underlying

databaseOwner

protected ODatabaseInternal<?> databaseOwner

Constructor Detail

ODatabaseWrapperAbstract

public ODatabaseWrapperAbstract(DB iDatabase)

Method Detail

open

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

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 <THISDB extends ODatabase> THISDB 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<T>

Parameters:

iToken - Authentication token

Returns:

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

activateOnCurrentThread

public ODatabase activateOnCurrentThread()

Description copied from interface: ODatabase

Activate current database instance on current thread. Call this method before using the database if you switch between multiple databases instances on the same thread or if you pass them across threads.

Specified by:

activateOnCurrentThread in interface ODatabase<T>

isActiveOnCurrentThread

public boolean isActiveOnCurrentThread()

Description copied from interface: ODatabase

Returns true if the current database instance is active on current thread, otherwise false.

Specified by:

isActiveOnCurrentThread in interface ODatabase<T>

create

public <THISDB extends ODatabase> THISDB create()

Description copied from interface: ODatabase

Creates a new database.

Specified by:

create in interface ODatabase<T>

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<T>

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.

create

public <THISDB extends ODatabase> THISDB create(Map<OGlobalConfiguration,Object> iInitialSettings)

Description copied from interface: ODatabase

Creates a new database passing initial settings.

Specified by:

create in interface ODatabase<T>

Returns:

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

exists

public boolean exists()

Description copied from interface: ODatabase

Checks if the database exists.

Specified by:

exists in interface ODatabase<T>

Returns:

True if already exists, otherwise false.

reload

public void reload()

Description copied from interface: ODatabase

Reloads the database information like the cluster list.

Specified by:

reload in interface ODatabase<T>

getConfiguration

public OContextConfiguration getConfiguration()

Description copied from interface: ODatabase

Returns the database configuration settings. If defined, any database configuration overwrites the global one.

Specified by:

getConfiguration in interface ODatabase<T>

Returns:

OContextConfiguration

backup

public List<String> backup(OutputStream out,
                           Map<String,Object> options,
                           Callable<Object> callable,
                           OCommandOutputListener iListener,
                           int compressionLevel,
                           int bufferSize)
                    throws IOException

Executes a backup of the database. During the backup the database will be frozen in read-only mode.

Specified by:

backup in interface OBackupable

Parameters:

out - OutputStream used to write the backup content. Use a FileOutputStream to make the backup persistent on disk

options - Backup options as Map object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

compressionLevel - ZIP Compression level between 0 (no compression) and 9 (maximum). The bigger is the compression, the smaller will be the final backup content, but will consume more CPU and time to execute

bufferSize - Buffer size in bytes, the bigger is the buffer, the more efficient will be the compression

Throws:

IOException

See Also:

ODatabaseExport

restore

public void restore(InputStream in,
                    Map<String,Object> options,
                    Callable<Object> callable,
                    OCommandOutputListener iListener)
             throws IOException

Executes a restore of a database backup. During the restore the database will be frozen in read-only mode.

Specified by:

restore in interface OBackupable

Parameters:

in - InputStream used to read the backup content. Use a FileInputStream to read a backup on a disk

options - Backup options as Map object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

Throws:

IOException

See Also:

ODatabaseImport

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 ODatabase<T>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

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<T>

Parameters:

iNewStorage - The new storage to use. Usually it's a wrapped instance of the current cluster.

drop

public void drop()

Description copied from interface: ODatabase

Drops a database.

Specified by:

drop in interface ODatabase<T>

getStatus

public ODatabase.STATUS getStatus()

Description copied from interface: ODatabase

Returns the current status of database.

Specified by:

getStatus in interface ODatabase<T>

setStatus

public <THISDB extends ODatabase> THISDB setStatus(ODatabase.STATUS iStatus)

Description copied from interface: ODatabase

Set the current status of database. deprecated since 2.2

Specified by:

setStatus in interface ODatabase<T>

getName

public String getName()

Description copied from interface: ODatabase

Returns the database name.

Specified by:

getName in interface ODatabase<T>

Returns:

Name of the database

getURL

public String getURL()

Description copied from interface: ODatabase

Returns the database URL.

Specified by:

getURL in interface ODatabase<T>

Returns:

URL of the database

getStorage

public OStorage getStorage()

Description copied from interface: ODatabaseInternal

Returns the underlying storage implementation.

Specified by:

getStorage in interface ODatabaseInternal<T>

Returns:

The underlying storage implementation

See Also:

OStorage

getMicroOrRegularTransaction

public OBasicTransaction getMicroOrRegularTransaction()

Description copied from interface: ODatabaseInternal

The active implicit micro-transaction or active/inactive regular transaction. Use the transaction returned by this method if you are doing "system" things that affect both regular database transactions and implicit storage micro-transactions wrapping non-transactional operations on the database-storage level.

Specified by:

getMicroOrRegularTransaction in interface ODatabaseInternal<T>

getLocalCache

public OLocalRecordCache getLocalCache()

Description copied from interface: ODatabase

Returns the level1 cache. Cannot be null.

Specified by:

getLocalCache in interface ODatabase<T>

Returns:

Current cache.

isClosed

public boolean isClosed()

Description copied from interface: ODatabase

Checks if the database is closed.

Specified by:

isClosed in interface ODatabase<T>

Returns:

true if is closed, otherwise false.

countClusterElements

public long countClusterElements(int iClusterId)

Description copied from interface: ODatabase

Counts all the entities in the specified cluster id.

Specified by:

countClusterElements in interface ODatabase<T>

Parameters:

iClusterId - Cluster id

Returns:

Total number of entities contained in the specified cluster

truncateCluster

public void truncateCluster(String clusterName)

Removes all data in the cluster with given name. As result indexes for this class will be rebuilt.

Specified by:

truncateCluster in interface ODatabase<T>

Parameters:

clusterName - Name of cluster to be truncated.

countClusterElements

public long countClusterElements(int[] iClusterIds)

Description copied from interface: ODatabase

Counts all the entities in the specified cluster ids.

Specified by:

countClusterElements in interface ODatabase<T>

Parameters:

iClusterIds - Array of cluster ids Cluster id

Returns:

Total number of entities contained in the specified clusters

countClusterElements

public long countClusterElements(String iClusterName)

Description copied from interface: ODatabase

Counts all the entities in the specified cluster name.

Specified by:

countClusterElements in interface ODatabase<T>

Parameters:

iClusterName - Cluster name

Returns:

Total number of entities contained in the specified cluster

countClusterElements

public long countClusterElements(int iClusterId,
                                 boolean countTombstones)

Specified by:

countClusterElements in interface ODatabase<T>

countClusterElements

public long countClusterElements(int[] iClusterIds,
                                 boolean countTombstones)

Specified by:

countClusterElements in interface ODatabase<T>

getClusters

public int getClusters()

Description copied from interface: ODatabase

Returns the number of clusters.

Specified by:

getClusters in interface ODatabase<T>

Returns:

Number of the clusters

existsCluster

public boolean existsCluster(String iClusterName)

Description copied from interface: ODatabase

Returns true if the cluster exists, otherwise false.

Specified by:

existsCluster in interface ODatabase<T>

Parameters:

iClusterName - Cluster name

Returns:

true if the cluster exists, otherwise false

getClusterNames

public Collection<String> getClusterNames()

Description copied from interface: ODatabase

Returns all the names of the clusters.

Specified by:

getClusterNames in interface ODatabase<T>

Returns:

Collection of cluster names.

getClusterIdByName

public int getClusterIdByName(String iClusterName)

Description copied from interface: ODatabase

Returns the cluster id by name.

Specified by:

getClusterIdByName in interface ODatabase<T>

Parameters:

iClusterName - Cluster name

Returns:

The id of searched cluster.

getClusterNameById

public String getClusterNameById(int iClusterId)

Description copied from interface: ODatabase

Returns the cluster name by id.

Specified by:

getClusterNameById in interface ODatabase<T>

Parameters:

iClusterId - Cluster id

Returns:

The name of searched cluster.

getClusterRecordSizeById

public long getClusterRecordSizeById(int iClusterId)

Description copied from interface: ODatabase

Returns the total size of records contained in the cluster defined by its id.

Specified by:

getClusterRecordSizeById in interface ODatabase<T>

Parameters:

iClusterId - Cluster id

Returns:

The name of searched cluster.

getClusterRecordSizeByName

public long getClusterRecordSizeByName(String iClusterName)

Description copied from interface: ODatabase

Returns the total size of records contained in the cluster defined by its name.

Specified by:

getClusterRecordSizeByName in interface ODatabase<T>

Parameters:

iClusterName - Cluster name

Returns:

Total size of records contained.

addCluster

public int addCluster(String iClusterName,
                      int iRequestedId,
                      Object... iParameters)

Description copied from interface: ODatabase

Adds a new cluster.

Specified by:

addCluster in interface ODatabase<T>

Parameters:

iClusterName - Cluster name

iRequestedId - requested id of the cluster

iParameters - Additional parameters to pass to the factories

Returns:

Cluster id

addCluster

public int addCluster(String iClusterName,
                      Object... iParameters)

Description copied from interface: ODatabase

Adds a new cluster.

Specified by:

addCluster in interface ODatabase<T>

Parameters:

iClusterName - Cluster name

iParameters - Additional parameters to pass to the factories

Returns:

Cluster id

dropCluster

public boolean dropCluster(String iClusterName,
                           boolean iTruncate)

Description copied from interface: ODatabase

Drops a cluster by its name. Physical clusters will be completely deleted

Specified by:

dropCluster in interface ODatabase<T>

Parameters:

iClusterName - the name of the cluster

Returns:

true if has been removed, otherwise false

dropCluster

public boolean dropCluster(int iClusterId,
                           boolean iTruncate)

Description copied from interface: ODatabase

Drops a cluster by its id. Physical clusters will be completely deleted.

Specified by:

dropCluster in interface ODatabase<T>

Parameters:

iClusterId - id of cluster to delete

Returns:

true if has been removed, otherwise false

getDefaultClusterId

public int getDefaultClusterId()

Description copied from interface: ODatabase

Returns the default cluster id. If not specified all the new entities will be stored in the default cluster.

Specified by:

getDefaultClusterId in interface ODatabase<T>

Returns:

The default cluster id

declareIntent

public boolean declareIntent(OIntent iIntent)

Description copied from interface: ODatabase

Declares an intent to the database. Intents aim to optimize common use cases.

Specified by:

declareIntent in interface ODatabase<T>

Parameters:

iIntent - The intent

getActiveIntent

public OIntent getActiveIntent()

Description copied from interface: ODatabase

Get the active intent in the current session.

Specified by:

getActiveIntent in interface ODatabase<T>

Returns:

getUnderlying

public <DBTYPE extends ODatabase> DBTYPE getUnderlying()

Description copied from interface: ODatabaseInternal

Return the underlying database. Used in wrapper instances to know the down level ODatabase instance.

Specified by:

getUnderlying in interface ODatabaseInternal<T>

Returns:

The underlying ODatabase implementation.

getDatabaseOwner

public ODatabaseInternal<?> getDatabaseOwner()

Description copied from interface: ODatabaseInternal

Returns the database owner. Used in wrapped instances to know the up level ODatabase instance.

Specified by:

getDatabaseOwner in interface ODatabaseInternal<T>

Returns:

Returns the database owner.

setDatabaseOwner

public ODatabaseInternal<?> setDatabaseOwner(ODatabaseInternal<?> iOwner)

Description copied from interface: ODatabaseInternal

Internal. Sets the database owner.

Specified by:

setDatabaseOwner in interface ODatabaseInternal<T>

equals

public boolean equals(Object iOther)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

setProperty

public Object setProperty(String iName,
                          Object iValue)

Description copied from interface: ODatabase

Sets a property value

Specified by:

setProperty in interface ODatabase<T>

Parameters:

iName - Property name

iValue - new value to set

Returns:

The previous value if any, otherwise null

getProperty

public Object getProperty(String iName)

Description copied from interface: ODatabase

Gets the property value.

Specified by:

getProperty in interface ODatabase<T>

Parameters:

iName - Property name

Returns:

The previous value if any, otherwise null

getProperties

public Iterator<Map.Entry<String,Object>> getProperties()

Description copied from interface: ODatabase

Returns an iterator of the property entries

Specified by:

getProperties in interface ODatabase<T>

get

public Object get(ODatabase.ATTRIBUTES iAttribute)

Description copied from interface: ODatabase

Returns a database attribute value

Specified by:

get in interface ODatabase<T>

Parameters:

iAttribute - Attributes between #ATTRIBUTES enum

Returns:

The attribute value

set

public <THISDB extends ODatabase> THISDB set(ODatabase.ATTRIBUTES attribute,
                                             Object iValue)

Description copied from interface: ODatabase

Sets a database attribute value

Specified by:

set in interface ODatabase<T>

Parameters:

attribute - Attributes between #ATTRIBUTES enum

iValue - Value to set

Returns:

underlying

registerListener

public void registerListener(ODatabaseListener iListener)

Description copied from interface: ODatabase

Registers a listener to the database events.

Specified by:

registerListener in interface ODatabase<T>

Parameters:

iListener - the listener to register

unregisterListener

public void unregisterListener(ODatabaseListener iListener)

Description copied from interface: ODatabase

Unregisters a listener to the database events.

Specified by:

unregisterListener in interface ODatabase<T>

Parameters:

iListener - the listener to unregister

getRecordMetadata

public ORecordMetadata getRecordMetadata(ORID rid)

Specified by:

getRecordMetadata in interface ODatabase<T>

getSize

public long getSize()

Description copied from interface: ODatabase

Returns the total size of database as used space.

Specified by:

getSize in interface ODatabase<T>

freeze

public void freeze(boolean throwException)

Description copied from interface: ODatabase

Flush cached storage content to the disk.

After this call users can perform only select queries. All write-related commands will queued till ODatabase.release() command will be called or exception will be thrown on attempt to modify DB data. Concrete behaviour depends on throwException parameter.

IMPORTANT: This command is not reentrant.

Specified by:

freeze in interface ODatabase<T>

Parameters:

throwException - If true OModificationOperationProhibitedException exception will be thrown in case of write command will be performed.

freeze

public void freeze()

Description copied from interface: ODatabase

Flush cached storage content to the disk.

After this call users can perform only idempotent calls like read records and select/traverse queries. All write-related operations will queued till ODatabase.release() command will be called.

Given command waits till all on going modifications in indexes or DB will be finished.

IMPORTANT: This command is not reentrant.

Specified by:

freeze in interface ODatabase<T>

See Also:

ODatabase.release()

release

public void release()

Description copied from interface: ODatabase

Allows to execute write-related commands on DB. Called after ODatabase.freeze() command.

Specified by:

release in interface ODatabase<T>

See Also:

ODatabase.freeze()

checkOpenness

protected void checkOpenness()