org.nuxeo.ecm.core.storage.sql

Class RepositoryImpl

java.lang.Object

org.nuxeo.ecm.core.storage.sql.RepositoryImpl

All Implemented Interfaces:

Serializable, Referenceable, javax.resource.cci.ConnectionFactory, Repository, RepositoryManagement

public class RepositoryImpl
extends Object
implements Repository

Repository implementation, to be extended by backend-specific initialization code.

See Also:

RepositoryBackend, Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RepositoryImpl.SessionPathResolver

Field Summary

Fields

Modifier and Type	Field and Description
String	repositoryId Transient id for this repository assigned by the server on first connection.

Constructor Summary

Constructors

Constructor and Description
RepositoryImpl(RepositoryDescriptor repositoryDescriptor)

Method Summary

Methods

Modifier and Type	Method and Description
int	cleanupDeletedDocuments(int max, Calendar beforeTime) Cleans up (hard-deletes) any documents that have been soft-deleted in the database.
int	clearCaches() Clears all the caches.
void	close() Closes the repository and release all resources.
int	getActiveSessionsCount() Gets the number of active sessions.
RepositoryBackend	getBackend()
BinaryGarbageCollector	getBinaryGarbageCollector() Gets the binary GC for this repository.
long	getCacheMapperSize()
long	getCachePristineSize() Evaluate number of elements in hier cache
long	getCacheSelectionSize() Evaluate number of elements in selection cache
long	getCacheSize() Evaluate number of elements in all caches
SessionImpl	getConnection() Gets a new connection.
SessionImpl	getConnection(javax.resource.cci.ConnectionSpec connectionSpec) Gets a new connection.
Class<? extends FulltextParser>	getFulltextParserClass()
LockManager	getLockManager()
javax.resource.cci.ResourceAdapterMetaData	getMetaData()
Model	getModel()
String	getName() Gets the repository name.
javax.resource.cci.RecordFactory	getRecordFactory()
Reference	getReference()
RepositoryDescriptor	getRepositoryDescriptor()
void	markReferencedBinaries(BinaryGarbageCollector gc) Marks the binaries actually in use with the GC so that they won't be deleted.
void	processClusterInvalidationsNext() Makes sure that the next transaction will process cluster invalidations.
void	setReference(Reference reference)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

repositoryId

public String repositoryId

Transient id for this repository assigned by the server on first connection. This is not persisted.

Constructor Detail

RepositoryImpl

public RepositoryImpl(RepositoryDescriptor repositoryDescriptor)
               throws StorageException

Throws:

StorageException

Method Detail

getRepositoryDescriptor

public RepositoryDescriptor getRepositoryDescriptor()

getLockManager

public LockManager getLockManager()

getModel

public Model getModel()

getBackend

public RepositoryBackend getBackend()

getFulltextParserClass

public Class<? extends FulltextParser> getFulltextParserClass()

getConnection

public SessionImpl getConnection(javax.resource.cci.ConnectionSpec connectionSpec)
                          throws StorageException

Gets a new connection.

Specified by:

getConnection in interface javax.resource.cci.ConnectionFactory

Specified by:

getConnection in interface Repository

Parameters:

connectionSpec - the parameters to use to connect (unused)

Returns:

the session

Throws:

StorageException

getConnection

public SessionImpl getConnection()
                          throws StorageException

Gets a new connection.

Specified by:

getConnection in interface javax.resource.cci.ConnectionFactory

Specified by:

getConnection in interface Repository

Returns:

the session

Throws:

StorageException

getMetaData

public javax.resource.cci.ResourceAdapterMetaData getMetaData()

Specified by:

getMetaData in interface javax.resource.cci.ConnectionFactory

getRecordFactory

public javax.resource.cci.RecordFactory getRecordFactory()

Specified by:

getRecordFactory in interface javax.resource.cci.ConnectionFactory

setReference

public void setReference(Reference reference)

getReference

public Reference getReference()

Specified by:

getReference in interface Referenceable

close

public void close()
           throws StorageException

Description copied from interface: Repository

Closes the repository and release all resources.

Specified by:

close in interface Repository

Throws:

StorageException

getName

public String getName()

Description copied from interface: RepositoryManagement

Gets the repository name.

Specified by:

getName in interface RepositoryManagement

getActiveSessionsCount

public int getActiveSessionsCount()

Description copied from interface: RepositoryManagement

Gets the number of active sessions.

Specified by:

getActiveSessionsCount in interface RepositoryManagement

clearCaches

public int clearCaches()

Description copied from interface: RepositoryManagement

Clears all the caches.

Specified by:

clearCaches in interface RepositoryManagement

Returns:

an indicative count of objects removed

getCacheSize

public long getCacheSize()

Description copied from interface: RepositoryManagement

Evaluate number of elements in all caches

Specified by:

getCacheSize in interface RepositoryManagement

getCacheMapperSize

public long getCacheMapperSize()

getCachePristineSize

public long getCachePristineSize()

Description copied from interface: RepositoryManagement

Evaluate number of elements in hier cache

Specified by:

getCachePristineSize in interface RepositoryManagement

getCacheSelectionSize

public long getCacheSelectionSize()

Description copied from interface: RepositoryManagement

Evaluate number of elements in selection cache

Specified by:

getCacheSelectionSize in interface RepositoryManagement

processClusterInvalidationsNext

public void processClusterInvalidationsNext()

Description copied from interface: RepositoryManagement

Makes sure that the next transaction will process cluster invalidations.

Specified by:

processClusterInvalidationsNext in interface RepositoryManagement

getBinaryGarbageCollector

public BinaryGarbageCollector getBinaryGarbageCollector()

Description copied from interface: RepositoryManagement

Gets the binary GC for this repository.

Specified by:

getBinaryGarbageCollector in interface RepositoryManagement

Returns:

the binary garbage collector

markReferencedBinaries

public void markReferencedBinaries(BinaryGarbageCollector gc)

Description copied from interface: RepositoryManagement

Marks the binaries actually in use with the GC so that they won't be deleted.

The passed GC may or may not be the one returned by RepositoryManagement.getBinaryGarbageCollector() in case it's been determined that another repository's GC is pointing to the same binary data.

Specified by:

markReferencedBinaries in interface RepositoryManagement

Parameters:

gc - the binary garbage collector to use for this repository's binaries

cleanupDeletedDocuments

public int cleanupDeletedDocuments(int max,
                          Calendar beforeTime)

Description copied from interface: RepositoryManagement

Cleans up (hard-deletes) any documents that have been soft-deleted in the database.

Specified by:

cleanupDeletedDocuments in interface RepositoryManagement

Parameters:

max - the maximum number of documents to delete at a time

beforeTime - the maximum deletion time of the documents to delete

Returns:

the number of documents deleted