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
protected Class<? extends FulltextParser>	fulltextParserClass
protected InvalidationsPropagator	invalidationsPropagator Propagator of invalidations to all mappers' caches.
protected com.codahale.metrics.MetricRegistry	registry
protected RepositoryDescriptor	repositoryDescriptor
String	repositoryId Transient id for this repository assigned by the server on first connection.
protected com.codahale.metrics.Counter	repositoryUp
protected boolean	selfRegisteredLockManager
protected com.codahale.metrics.Counter	sessionCount

Constructor Summary

Constructors

Constructor and Description
RepositoryImpl(RepositoryDescriptor repositoryDescriptor)

Method Summary

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.
protected void	closeAllSessions()
protected void	closeSession(SessionImpl session)
protected RepositoryBackend	createBackend()
protected Mapper	createCachingMapper(Model model, Mapper mapper)
protected ClusterInvalidator	createClusterInvalidator()
protected void	createMetricsGauges()
int	getActiveSessionsCount() Gets the number of active sessions.
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
protected Class<? extends CachingMapper>	getCachingMapperClass()
SessionImpl	getConnection() Gets a new connection.
SessionImpl	getConnection(javax.resource.cci.ConnectionSpec connectionSpec) Gets a new connection.
Class<? extends FulltextParser>	getFulltextParserClass()
InvalidationsPropagator	getInvalidationsPropagator()
LockManager	getLockManager()
protected String	getLockManagerName()
javax.resource.cci.ResourceAdapterMetaData	getMetaData()
Model	getModel()
String	getName() Gets the repository name.
javax.resource.cci.RecordFactory	getRecordFactory()
Reference	getReference()
RepositoryDescriptor	getRepositoryDescriptor()
protected void	initClusterInvalidator()
protected void	initLockManager()
protected void	initRepository()
void	markReferencedBinaries() Marks the binaries in use by passing them to the binary manager(s)'s GC mark() method.
Mapper	newMapper(Session.PathResolver pathResolver, boolean useInvalidations) Creates a new mapper.
protected SessionImpl	newSession(Model model, Mapper mapper)
void	processClusterInvalidationsNext() Makes sure that the next transaction will process cluster invalidations.
void	setReference(Reference reference)

Methods inherited from class java.lang.Object

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

Field Detail

repositoryDescriptor

protected final RepositoryDescriptor repositoryDescriptor

fulltextParserClass

protected final Class<? extends FulltextParser> fulltextParserClass

registry

protected final com.codahale.metrics.MetricRegistry registry

repositoryUp

protected final com.codahale.metrics.Counter repositoryUp

sessionCount

protected final com.codahale.metrics.Counter sessionCount

selfRegisteredLockManager

protected boolean selfRegisteredLockManager

Since:

7.4 : used to know if the LockManager was provided by this repository or externally

invalidationsPropagator

protected final InvalidationsPropagator invalidationsPropagator

Propagator of invalidations to all mappers' caches.

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)

Method Detail

createMetricsGauges

protected void createMetricsGauges()

createBackend

protected RepositoryBackend createBackend()

createCachingMapper

protected Mapper createCachingMapper(Model model,
                                     Mapper mapper)

getCachingMapperClass

protected Class<? extends CachingMapper> getCachingMapperClass()

getRepositoryDescriptor

public RepositoryDescriptor getRepositoryDescriptor()

getLockManager

public LockManager getLockManager()

getModel

public Model getModel()

getInvalidationsPropagator

public InvalidationsPropagator getInvalidationsPropagator()

getFulltextParserClass

public Class<? extends FulltextParser> getFulltextParserClass()

getConnection

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

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

getConnection

public SessionImpl getConnection()

Gets a new connection.

Specified by:

getConnection in interface javax.resource.cci.ConnectionFactory

Specified by:

getConnection in interface Repository

Returns:

the session

newMapper

public Mapper newMapper(Session.PathResolver pathResolver,
                        boolean useInvalidations)

Creates a new mapper.

Parameters:

pathResolver - the path resolver (for regular mappers)

useInvalidations - whether this mapper participates in invalidation propagation (false for lock manager / cluster invalidator)

Returns:

the new mapper.

Since:

7.4

initRepository

protected void initRepository()

getLockManagerName

protected String getLockManagerName()

initLockManager

protected void initLockManager()

initClusterInvalidator

protected void initClusterInvalidator()

createClusterInvalidator

protected ClusterInvalidator createClusterInvalidator()

newSession

protected SessionImpl newSession(Model model,
                                 Mapper mapper)

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()

Description copied from interface: Repository

Closes the repository and release all resources.

Specified by:

close in interface Repository

closeAllSessions

protected void closeAllSessions()

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

markReferencedBinaries

public void markReferencedBinaries()

Description copied from interface: RepositoryManagement

Marks the binaries in use by passing them to the binary manager(s)'s GC mark() method.

Specified by:

markReferencedBinaries in interface RepositoryManagement

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

closeSession

protected void closeSession(SessionImpl session)