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

Class ManagedConnectionFactoryImpl

java.lang.Object

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

All Implemented Interfaces:

Serializable, javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ResourceAdapterAssociation, RepositoryManagement

public class ManagedConnectionFactoryImpl
extends Object
implements javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ResourceAdapterAssociation, RepositoryManagement

The managed connection factory receives requests from the application server to create new ManagedConnection (the physical connection).

It also is a factory for ConnectionFactorys.

Author:

Florent Guillaume

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ManagedConnectionFactoryImpl()
ManagedConnectionFactoryImpl(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.
Object	createConnectionFactory()
Object	createConnectionFactory(javax.resource.spi.ConnectionManager connectionManager)
javax.resource.spi.ManagedConnection	createManagedConnection(Subject subject, javax.resource.spi.ConnectionRequestInfo connectionRequestInfo)
int	getActiveSessionsCount() Gets the number of active sessions.
BinaryGarbageCollector	getBinaryGarbageCollector() Gets the binary GC for this repository.
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
PrintWriter	getLogWriter()
String	getName() Gets the repository name.
String	getProperty()
javax.resource.spi.ResourceAdapter	getResourceAdapter()
String	getXaDataSource()
void	markReferencedBinaries(BinaryGarbageCollector gc) Marks the binaries actually in use with the GC so that they won't be deleted.
javax.resource.spi.ManagedConnection	matchManagedConnections(Set set, Subject subject, javax.resource.spi.ConnectionRequestInfo cri) Returns a matched connection from the candidate set of connections.
static Map<String,String>	parseProperties(String expr) Parses a string of the form: key1=val1;key2=val2;... and collects the key/value pairs.
void	processClusterInvalidationsNext() Makes sure that the next transaction will process cluster invalidations.
void	setLogWriter(PrintWriter out)
void	setName(String name)
void	setProperty(String property) Properties are specified in the format key=val1[;key2=val2;...]
void	setResourceAdapter(javax.resource.spi.ResourceAdapter resourceAdapter) Called by the application server exactly once to associate this ManagedConnectionFactory with a ResourceAdapter.
void	setXaDataSource(String xaDataSourceName)
void	shutdown()

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.resource.spi.ManagedConnectionFactory

equals, hashCode

Constructor Detail

ManagedConnectionFactoryImpl

public ManagedConnectionFactoryImpl()

ManagedConnectionFactoryImpl

public ManagedConnectionFactoryImpl(RepositoryDescriptor repositoryDescriptor)

Method Detail

setName

public void setName(String name)

getName

public String getName()

Description copied from interface: RepositoryManagement

Gets the repository name.

Specified by:

getName in interface RepositoryManagement

setXaDataSource

public void setXaDataSource(String xaDataSourceName)

getXaDataSource

public String getXaDataSource()

setProperty

public void setProperty(String property)

Properties are specified in the format key=val1[;key2=val2;...]

If a value has to contain a semicolon, it can be escaped by doubling it.

Parameters:

property -

See Also:

parseProperties(String)

getProperty

public String getProperty()

setResourceAdapter

public void setResourceAdapter(javax.resource.spi.ResourceAdapter resourceAdapter)
                        throws javax.resource.ResourceException

Called by the application server exactly once to associate this ManagedConnectionFactory with a ResourceAdapter. The ResourceAdapter may then be used to look up configuration.

Specified by:

setResourceAdapter in interface javax.resource.spi.ResourceAdapterAssociation

Throws:

javax.resource.ResourceException

getResourceAdapter

public javax.resource.spi.ResourceAdapter getResourceAdapter()

Specified by:

getResourceAdapter in interface javax.resource.spi.ResourceAdapterAssociation

setLogWriter

public void setLogWriter(PrintWriter out)

Specified by:

setLogWriter in interface javax.resource.spi.ManagedConnectionFactory

getLogWriter

public PrintWriter getLogWriter()

Specified by:

getLogWriter in interface javax.resource.spi.ManagedConnectionFactory

createConnectionFactory

public Object createConnectionFactory()
                               throws javax.resource.ResourceException

Specified by:

createConnectionFactory in interface javax.resource.spi.ManagedConnectionFactory

Throws:

javax.resource.ResourceException

createConnectionFactory

public Object createConnectionFactory(javax.resource.spi.ConnectionManager connectionManager)
                               throws javax.resource.ResourceException

Specified by:

createConnectionFactory in interface javax.resource.spi.ManagedConnectionFactory

Throws:

javax.resource.ResourceException

createManagedConnection

public javax.resource.spi.ManagedConnection createManagedConnection(Subject subject,
                                                           javax.resource.spi.ConnectionRequestInfo connectionRequestInfo)
                                                             throws javax.resource.ResourceException

Specified by:

createManagedConnection in interface javax.resource.spi.ManagedConnectionFactory

Throws:

javax.resource.ResourceException

matchManagedConnections

public javax.resource.spi.ManagedConnection matchManagedConnections(Set set,
                                                           Subject subject,
                                                           javax.resource.spi.ConnectionRequestInfo cri)
                                                             throws javax.resource.ResourceException

Returns a matched connection from the candidate set of connections.

Called by the application server when it's looking for an appropriate connection to server from a pool.

Specified by:

matchManagedConnections in interface javax.resource.spi.ManagedConnectionFactory

Throws:

javax.resource.ResourceException

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

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

shutdown

public void shutdown()
              throws StorageException

Throws:

StorageException

parseProperties

public static Map<String,String> parseProperties(String expr)

Parses a string of the form: key1=val1;key2=val2;... and collects the key/value pairs.

A ';' character may end the expression. If a value has to contain a ';', it can be escaped by doubling it.

Examples of valid expressions: key1=val1, key1=val1;, key1=val1;key2=val2, key1=a=b;;c=d;key2=val2.

Syntax errors are reported using the logger and will stop the parsing but already collected properties will be available. The ';' or '=' characters cannot be escaped in keys.

Parameters:

expr - the expression to parse

Returns:

a key/value map