org.nuxeo.ecm.core.storage.sql.ra

Class ConnectionFactoryImpl

java.lang.Object

org.nuxeo.ecm.core.storage.sql.ra.ConnectionFactoryImpl

All Implemented Interfaces:

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

public class ConnectionFactoryImpl
extends Object
implements Repository, Repository

The connection factory delegates connection requests to the application server ConnectionManager.

An instance of this class is returned to the application when a JNDI lookup is done.

Author:

Florent Guillaume

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConnectionFactoryImpl(ManagedConnectionFactoryImpl managedConnectionFactory, javax.resource.spi.ConnectionManager connectionManager)

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.
int	getActiveSessionsCount() Gets the number of active sessions.
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
Session	getConnection() Gets a new connection.
Session	getConnection(javax.resource.cci.ConnectionSpec connectionSpec) Gets a new connection.
javax.resource.cci.ResourceAdapterMetaData	getMetaData()
String	getName() Gets the repository name.
javax.resource.cci.RecordFactory	getRecordFactory()
Reference	getReference()
Session	getSession()
void	markReferencedBinaries() Marks the binaries in use by passing them to the binary manager(s)'s GC mark() method.
void	processClusterInvalidationsNext() Makes sure that the next transaction will process cluster invalidations.
void	setReference(Reference reference)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionFactoryImpl

public ConnectionFactoryImpl(ManagedConnectionFactoryImpl managedConnectionFactory,
                             javax.resource.spi.ConnectionManager connectionManager)

Method Detail

getConnection

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

Gets a new connection.

Specified by:

getConnection in interface javax.resource.cci.ConnectionFactory

Parameters:

connectionSpec - the connection spec (unused)

Returns:

the connection

getConnection

public Session getConnection()

Gets a new connection.

Specified by:

getConnection in interface javax.resource.cci.ConnectionFactory

Returns:

the connection

getMetaData

public javax.resource.cci.ResourceAdapterMetaData getMetaData()
                                                       throws javax.resource.ResourceException

Specified by:

getMetaData in interface javax.resource.cci.ConnectionFactory

Throws:

javax.resource.ResourceException

getRecordFactory

public javax.resource.cci.RecordFactory getRecordFactory()
                                                  throws javax.resource.ResourceException

Specified by:

getRecordFactory in interface javax.resource.cci.ConnectionFactory

Throws:

javax.resource.ResourceException

getReference

public Reference getReference()

Specified by:

getReference in interface Referenceable

setReference

public void setReference(Reference reference)

close

public void close()

Description copied from interface: Repository

Closes the repository and release all resources.

getName

public String getName()

Description copied from interface: RepositoryManagement

Gets the repository name.

Specified by:

getName in interface Repository

Specified by:

getName in interface RepositoryManagement

getSession

public Session getSession()

Specified by:

getSession in interface Repository

shutdown

public void shutdown()

Specified by:

shutdown in interface Repository

getActiveSessionsCount

public int getActiveSessionsCount()

Description copied from interface: RepositoryManagement

Gets the number of active sessions.

Specified by:

getActiveSessionsCount in interface Repository

Specified by:

getActiveSessionsCount in interface RepositoryManagement

getCacheSize

public long getCacheSize()

Description copied from interface: RepositoryManagement

Evaluate number of elements in all caches

Specified by:

getCacheSize in interface RepositoryManagement

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

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

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 Repository

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