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

Field Summary

Fields

Modifier and Type	Field and Description
protected String	name

Constructor Summary

Constructors

Constructor and Description
ManagedConnectionFactoryImpl(String name)

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.
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.
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 SessionImpl	getConnection() Called by the ManagedConnectionImpl constructor to get a new physical connection.
PrintWriter	getLogWriter()
String	getName() Gets the repository name.
protected static RepositoryDescriptor	getRepositoryDescriptor(String name) Gets the repository descriptor provided by the repository extension point.
javax.resource.spi.ResourceAdapter	getResourceAdapter()
void	markReferencedBinaries() Marks the binaries in use by passing them to the binary manager(s)'s GC mark() method.
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	setResourceAdapter(javax.resource.spi.ResourceAdapter resourceAdapter) Called by the application server exactly once to associate this ManagedConnectionFactory with a ResourceAdapter.
void	shutdown()

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.resource.spi.ManagedConnectionFactory

equals, hashCode

Field Detail

name

protected final String name

Constructor Detail

ManagedConnectionFactoryImpl

public ManagedConnectionFactoryImpl(String name)

Method Detail

getName

public String getName()

Description copied from interface: RepositoryManagement

Gets the repository name.

Specified by:

getName in interface RepositoryManagement

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

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

shutdown

public void shutdown()

getRepositoryDescriptor

protected static RepositoryDescriptor getRepositoryDescriptor(String name)

Gets the repository descriptor provided by the repository extension point. It's where clustering, indexing, etc. are configured.

getConnection

protected SessionImpl getConnection()

Called by the ManagedConnectionImpl constructor to get a new physical connection.

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