org.datanucleus.store.federation

Class FederatedStoreManager

java.lang.Object

org.datanucleus.store.federation.FederatedStoreManager

All Implemented Interfaces:

StoreManager

public class FederatedStoreManager
extends Object
implements StoreManager

A federated StoreManager orchestrates the persistence/retrieval for multiple datastores. It is responsible for creating the individual StoreManager instances for the datastore(s) that are being federated. Has a "primary" StoreManager where data is stored by default when no metadata is specified for a class, and then has a map of "secondary" StoreManagers keyed by name that can be used for persistence as defined in metadata. When a request comes in to persist some data, this class is responsible for selecting the appropriate StoreManager for persistence. When a request comes in to query some data, this class is responsible for selecting the appropriate StoreManager to query.

Assumes that there are persistence properties of the form

 datanucleus.datastore.SecondStore=secondstore.properties
 datanucleus.datastore.ThirdStore=thirdstore.properties
 

where these properties files have the properties for the secondary stores with names "SecondStore", "ThirdStore".

Field Summary

Fields

Modifier and Type	Field and Description
protected static Localiser	LOCALISER Localisation of messages.
protected StorePersistenceHandler	persistenceHandler Persistence handler.
static String	PROPERTY_DATA_FEDERATION_DATASTORE_NAME

Constructor Summary

Constructors

Constructor and Description
FederatedStoreManager(ClassLoaderResolver clr, NucleusContext nucleusContext)

Method Summary

Methods

Modifier and Type	Method and Description
void	addClass(String className, ClassLoaderResolver clr) Method to add a class to the managed list for this datastore manager.
void	addClasses(String[] classNames, ClassLoaderResolver clr) Add classes to the persistence model for the datastore.
void	close() Release of resources.
ApiAdapter	getApiAdapter() Accessor for the API adapter.
Boolean	getBooleanObjectProperty(String name)
boolean	getBooleanProperty(String name)
boolean	getBooleanProperty(String name, boolean resultIfNotSet)
String	getClassNameForObjectID(Object id, ClassLoaderResolver clr, ExecutionContext ec) Returns the class corresponding to the given object identity.
ManagedConnection	getConnection(ExecutionContext ec) Accessor for a connection for the specified ExecutionContext.
ManagedConnection	getConnection(ExecutionContext ec, Map options) Accessor for a connection for the specified ExecutionContext.
String	getConnectionDriverName() Convenience accessor for the driver name to use for the connection.
Object	getConnectionFactory() Convenience accessor for the factory for the connection (transactional).
Object	getConnectionFactory2() Convenience accessor for the factory for the connection (non-transactional).
String	getConnectionFactory2Name() Convenience accessor for the factory name for the connection (non-transactional).
String	getConnectionFactoryName() Convenience accessor for the factory name for the connection (transactional).
ConnectionManager	getConnectionManager() Accessor for the connection manager for this store manager.
String	getConnectionPassword() Convenience accessor for the password to use for the connection.
String	getConnectionURL() Convenience accessor for the URL for the connection.
String	getConnectionUserName() Convenience accessor for the user name to use for the connection.
Date	getDatastoreDate() Get the date/time of the datastore.
String	getDefaultObjectProviderClassName()
Extent	getExtent(ExecutionContext ec, Class c, boolean subclasses) Interface to getting an Extent for a class.
FlushProcess	getFlushProcess() Accessor for the flush process to use with this datastore.
int	getIntProperty(String name)
NamingFactory	getNamingFactory() Accessor for the schema naming factory.
NucleusConnection	getNucleusConnection(ExecutionContext ec) Method to return a connection to the user for the ExecutionContext.
NucleusContext	getNucleusContext() Accessor for the context in which this StoreManager is running
NucleusSequence	getNucleusSequence(ExecutionContext ec, SequenceMetaData seqmd) Method to return a datastore sequence for this datastore matching the passed sequence MetaData.
StorePersistenceHandler	getPersistenceHandler() Accessor for the store persistence handler.
Object	getProperty(String name)
String	getQueryCacheKey() Accessor for the key used for representing this store manager in the query cache.
QueryManager	getQueryManager() Accessor for the query manager for this datastore.
StoreSchemaHandler	getSchemaHandler() Accessor for the store schema handler (if this datastore supports the concept of a schema).
StoreManager	getStoreManagerForClass(AbstractClassMetaData cmd) Accessor for the StoreManager to use for persisting the specified class.
StoreManager	getStoreManagerForClass(String className, ClassLoaderResolver clr) Accessor for the StoreManager to use for the specified class.
String	getStoreManagerKey() Accessor for the key for this store manager.
Object	getStrategyValue(ExecutionContext ec, AbstractClassMetaData cmd, int absoluteFieldNumber) Method to retrieve the value for a strategy for a particular field.
String	getStringProperty(String name)
Collection<String>	getSubClassesForClass(String className, boolean includeDescendents, ClassLoaderResolver clr) Utility to return the names of the classes that are known subclasses of the provided class.
Collection	getSupportedOptions() Accessor for the supported options in string form
ValueGenerationManager	getValueGenerationManager() Accessor for the ValueGenerationManager for obtaining sequences.
boolean	hasProperty(String name)
boolean	isAutoCreateColumns()
boolean	isAutoCreateConstraints()
boolean	isAutoCreateTables()
boolean	isJdbcStore() Returns whether the datastore is a "JDBC datastore".
boolean	isStrategyDatastoreAttributed(AbstractClassMetaData cmd, int absFieldNumber) Convenience method to return whether the strategy used by the specified class/member is generated in the datastore during a persist.
String	manageClassForIdentity(Object id, ClassLoaderResolver clr) Convenience method to ensure that the class defined by the passed OID/SingleFIeldIdentity is managed by the store.
boolean	managesClass(String className) Accessor for whether the specified class is managed currently
void	printInformation(String category, PrintStream ps) Method to output particular information owned by this datastore.
void	removeAllClasses(ClassLoaderResolver clr) Remove all classes from the persistence model for the datastore.
boolean	supportsQueryLanguage(String language) Accessor for whether this query language is supported.
boolean	supportsValueStrategy(String language) Accessor for whether this value strategy is supported.
void	transactionCommitted(ExecutionContext ec) Method to inform the StoreManager that a transaction has committed for the specified execution context.
void	transactionRolledBack(ExecutionContext ec) Method to inform the StoreManager that a transaction has rolled back for the specified execution context.
void	transactionStarted(ExecutionContext ec) Method to inform the StoreManager that a transaction has started for the specified execution context.
boolean	useBackedSCOWrapperForMember(AbstractMemberMetaData mmd, ExecutionContext ec) Method to return whether the specified member should use a backed SCO wrapper.

Methods inherited from class java.lang.Object

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

Field Detail

LOCALISER

protected static final Localiser LOCALISER

Localisation of messages.

PROPERTY_DATA_FEDERATION_DATASTORE_NAME

public static final String PROPERTY_DATA_FEDERATION_DATASTORE_NAME

See Also:

Constant Field Values

persistenceHandler

protected StorePersistenceHandler persistenceHandler

Persistence handler.

Constructor Detail

FederatedStoreManager

public FederatedStoreManager(ClassLoaderResolver clr,
                     NucleusContext nucleusContext)

Method Detail

getNucleusContext

public NucleusContext getNucleusContext()

Description copied from interface: StoreManager

Accessor for the context in which this StoreManager is running

Specified by:

getNucleusContext in interface StoreManager

Returns:

Returns the context.

getFlushProcess

public FlushProcess getFlushProcess()

Description copied from interface: StoreManager

Accessor for the flush process to use with this datastore.

Specified by:

getFlushProcess in interface StoreManager

Returns:

The flush process

close

public void close()

Description copied from interface: StoreManager

Release of resources.

Specified by:

close in interface StoreManager

getStoreManagerForClass

public StoreManager getStoreManagerForClass(AbstractClassMetaData cmd)

Accessor for the StoreManager to use for persisting the specified class. TODO Extend this so that we can persist some objects of one type into one datastore, and other objects of that type into a different datastore.

Parameters:

cmd - Metadata for the class

Returns:

The StoreManager to use

getStoreManagerForClass

public StoreManager getStoreManagerForClass(String className,
                                   ClassLoaderResolver clr)

Accessor for the StoreManager to use for the specified class.

Parameters:

className - Name of the class

clr - ClassLoader resolver

Returns:

The StoreManager to use

addClass

public void addClass(String className,
            ClassLoaderResolver clr)

Description copied from interface: StoreManager

Method to add a class to the managed list for this datastore manager.

Specified by:

addClass in interface StoreManager

Parameters:

className - Name of the class

clr - The ClassLoaderResolver

addClasses

public void addClasses(String[] classNames,
              ClassLoaderResolver clr)

Description copied from interface: StoreManager

Add classes to the persistence model for the datastore.

This method is primarily useful for applications that wish to perform all of their datastore initialization up front, rather than wait for the runtime to do it on-demand.

Specified by:

addClasses in interface StoreManager

Parameters:

classNames - The class(es) to be added.

clr - The ClassLoaderResolver

getNamingFactory

public NamingFactory getNamingFactory()

Description copied from interface: StoreManager

Accessor for the schema naming factory.

Specified by:

getNamingFactory in interface StoreManager

Returns:

Naming factory.

getApiAdapter

public ApiAdapter getApiAdapter()

Description copied from interface: StoreManager

Accessor for the API adapter.

Specified by:

getApiAdapter in interface StoreManager

Returns:

API adapter

getClassNameForObjectID

public String getClassNameForObjectID(Object id,
                             ClassLoaderResolver clr,
                             ExecutionContext ec)

Description copied from interface: StoreManager

Returns the class corresponding to the given object identity. If the object is an OID (datastore-identity), return the PC class specified in the identity. If the object is SingleFieldIdentity, return the PC class specified in the identity If the object is an AppID PK, return the PC class that uses it. If the object is a SCOID, return the SCO class. If the object is a persistable class, return the class.

Specified by:

getClassNameForObjectID in interface StoreManager

Parameters:

id - The identity of some object.

clr - ClassLoader resolver

ec - execution context

Returns:

For datastore identity, return the class of the corresponding object. For application identity, return the class of the corresponding object or null if object does not exist.

getDatastoreDate

public Date getDatastoreDate()

Description copied from interface: StoreManager

Get the date/time of the datastore.

Specified by:

getDatastoreDate in interface StoreManager

Returns:

Date/time of the datastore

getExtent

public Extent getExtent(ExecutionContext ec,
               Class c,
               boolean subclasses)

Description copied from interface: StoreManager

Interface to getting an Extent for a class.

Specified by:

getExtent in interface StoreManager

Parameters:

ec - execution context

c - The class requiring the Extent

subclasses - Whether to include subclasses of 'c'

Returns:

The Extent.

isJdbcStore

public boolean isJdbcStore()

Description copied from interface: StoreManager

Returns whether the datastore is a "JDBC datastore". If it is then the JDO spec needs to return a connection that implements java.sql.Connection. RDBMS is the only one that will return true from here (or certainly as we can foresee now).

Specified by:

isJdbcStore in interface StoreManager

Returns:

Whether this is a JDBC datastore

getNucleusConnection

public NucleusConnection getNucleusConnection(ExecutionContext ec)

Description copied from interface: StoreManager

Method to return a connection to the user for the ExecutionContext. Typically provides a wrapper to the currently in-use ManagedConnection.

Specified by:

getNucleusConnection in interface StoreManager

Parameters:

ec - execution context

Returns:

The datastore Connection

getNucleusSequence

public NucleusSequence getNucleusSequence(ExecutionContext ec,
                                 SequenceMetaData seqmd)

Description copied from interface: StoreManager

Method to return a datastore sequence for this datastore matching the passed sequence MetaData.

Specified by:

getNucleusSequence in interface StoreManager

Parameters:

ec - execution context

seqmd - SequenceMetaData

Returns:

The Sequence

getSchemaHandler

public StoreSchemaHandler getSchemaHandler()

Description copied from interface: StoreManager

Accessor for the store schema handler (if this datastore supports the concept of a schema).

Specified by:

getSchemaHandler in interface StoreManager

Returns:

Store schema handler.

getPersistenceHandler

public StorePersistenceHandler getPersistenceHandler()

Description copied from interface: StoreManager

Accessor for the store persistence handler.

Specified by:

getPersistenceHandler in interface StoreManager

Returns:

Store persistence handler.

getQueryManager

public QueryManager getQueryManager()

Description copied from interface: StoreManager

Accessor for the query manager for this datastore.

Specified by:

getQueryManager in interface StoreManager

Returns:

Query Manager for this store

getValueGenerationManager

public ValueGenerationManager getValueGenerationManager()

Description copied from interface: StoreManager

Accessor for the ValueGenerationManager for obtaining sequences.

Specified by:

getValueGenerationManager in interface StoreManager

Returns:

The ValueGenerationManagerr for this datastore

getStoreManagerKey

public String getStoreManagerKey()

Description copied from interface: StoreManager

Accessor for the key for this store manager.

Specified by:

getStoreManagerKey in interface StoreManager

Returns:

StoreManager key

getQueryCacheKey

public String getQueryCacheKey()

Description copied from interface: StoreManager

Accessor for the key used for representing this store manager in the query cache.

Specified by:

getQueryCacheKey in interface StoreManager

Returns:

Key for the query cache

getStrategyValue

public Object getStrategyValue(ExecutionContext ec,
                      AbstractClassMetaData cmd,
                      int absoluteFieldNumber)

Description copied from interface: StoreManager

Method to retrieve the value for a strategy for a particular field.

Specified by:

getStrategyValue in interface StoreManager

Parameters:

ec - execution context

cmd - AbstractClassMetaData for the class

absoluteFieldNumber - The field number

Returns:

The value

getSubClassesForClass

public Collection<String> getSubClassesForClass(String className,
                                       boolean includeDescendents,
                                       ClassLoaderResolver clr)

Description copied from interface: StoreManager

Utility to return the names of the classes that are known subclasses of the provided class. Actually uses the MetaDataManager for determining what is a subclass since the MetaData is often registered before being needed by the Store.

Specified by:

getSubClassesForClass in interface StoreManager

Parameters:

className - Class for which we search for subclasses.

includeDescendents - Whether to include subclasses of subclasses etc

clr - The ClassLoaderResolver

Returns:

Set of classes that are subclasses of the input class. TODO Use method in MetaDataManager and remove this

isStrategyDatastoreAttributed

public boolean isStrategyDatastoreAttributed(AbstractClassMetaData cmd,
                                    int absFieldNumber)

Description copied from interface: StoreManager

Convenience method to return whether the strategy used by the specified class/member is generated in the datastore during a persist.

Specified by:

isStrategyDatastoreAttributed in interface StoreManager

Parameters:

cmd - Metadata for the class

absFieldNumber - number of the field (or -1 if for datastore-id)

Returns:

if the object for the strategy is attributed by the database

manageClassForIdentity

public String manageClassForIdentity(Object id,
                            ClassLoaderResolver clr)

Description copied from interface: StoreManager

Convenience method to ensure that the class defined by the passed OID/SingleFIeldIdentity is managed by the store.

Specified by:

manageClassForIdentity in interface StoreManager

Parameters:

id - OID

clr - ClassLoader resolver

Returns:

The class name of the class associated to this identity

managesClass

public boolean managesClass(String className)

Description copied from interface: StoreManager

Accessor for whether the specified class is managed currently

Specified by:

managesClass in interface StoreManager

Parameters:

className - The name of the class

Returns:

Whether it is managed

printInformation

public void printInformation(String category,
                    PrintStream ps)
                      throws Exception

Description copied from interface: StoreManager

Method to output particular information owned by this datastore. Each StoreManager can support whichever categories it likes.

Specified by:

printInformation in interface StoreManager

Parameters:

category - Category of information

ps - PrintStream

Throws:

Exception - Thrown if an error occurs in the output process

removeAllClasses

public void removeAllClasses(ClassLoaderResolver clr)

Description copied from interface: StoreManager

Remove all classes from the persistence model for the datastore. This empties the datastore of all datastore objects managed by us. All objects of types not managed are left untouched. In the case of RDBMS this means drop all tables for types managed by us.

Specified by:

removeAllClasses in interface StoreManager

Parameters:

clr - The ClassLoaderResolver

supportsQueryLanguage

public boolean supportsQueryLanguage(String language)

Description copied from interface: StoreManager

Accessor for whether this query language is supported.

Specified by:

supportsQueryLanguage in interface StoreManager

Parameters:

language - The language

Returns:

Whether it is supported.

supportsValueStrategy

public boolean supportsValueStrategy(String language)

Description copied from interface: StoreManager

Accessor for whether this value strategy is supported.

Specified by:

supportsValueStrategy in interface StoreManager

Parameters:

language - The strategy

Returns:

Whether it is supported.

getSupportedOptions

public Collection getSupportedOptions()

Description copied from interface: StoreManager

Accessor for the supported options in string form

Specified by:

getSupportedOptions in interface StoreManager

getConnectionManager

public ConnectionManager getConnectionManager()

Description copied from interface: StoreManager

Accessor for the connection manager for this store manager.

Specified by:

getConnectionManager in interface StoreManager

Returns:

connection manager

getConnection

public ManagedConnection getConnection(ExecutionContext ec)

Description copied from interface: StoreManager

Accessor for a connection for the specified ExecutionContext.

If there is an active transaction, a connection from the transactional connection factory will be returned. If there is no active transaction, a connection from the nontransactional connection factory will be returned.

Specified by:

getConnection in interface StoreManager

Parameters:

ec - execution context

Returns:

The Connection

getConnection

public ManagedConnection getConnection(ExecutionContext ec,
                              Map options)

Description copied from interface: StoreManager

Accessor for a connection for the specified ExecutionContext.

If there is an active transaction, a connection from the transactional connection factory will be returned. If there is no active transaction, a connection from the nontransactional connection factory will be returned.

Specified by:

getConnection in interface StoreManager

Parameters:

ec - execution context

options - connetion options

Returns:

The Connection

getConnectionDriverName

public String getConnectionDriverName()

Description copied from interface: StoreManager

Convenience accessor for the driver name to use for the connection.

Specified by:

getConnectionDriverName in interface StoreManager

Returns:

driver name

getConnectionURL

public String getConnectionURL()

Description copied from interface: StoreManager

Convenience accessor for the URL for the connection.

Specified by:

getConnectionURL in interface StoreManager

Returns:

connection URL

getConnectionUserName

public String getConnectionUserName()

Description copied from interface: StoreManager

Convenience accessor for the user name to use for the connection.

Specified by:

getConnectionUserName in interface StoreManager

Returns:

user name

getConnectionPassword

public String getConnectionPassword()

Description copied from interface: StoreManager

Convenience accessor for the password to use for the connection.

Specified by:

getConnectionPassword in interface StoreManager

Returns:

Password

getConnectionFactory

public Object getConnectionFactory()

Description copied from interface: StoreManager

Convenience accessor for the factory for the connection (transactional).

Specified by:

getConnectionFactory in interface StoreManager

Returns:

Connection Factory (transactional)

getConnectionFactory2

public Object getConnectionFactory2()

Description copied from interface: StoreManager

Convenience accessor for the factory for the connection (non-transactional).

Specified by:

getConnectionFactory2 in interface StoreManager

Returns:

Connection Factory (non-transactional)

getConnectionFactory2Name

public String getConnectionFactory2Name()

Description copied from interface: StoreManager

Convenience accessor for the factory name for the connection (non-transactional).

Specified by:

getConnectionFactory2Name in interface StoreManager

Returns:

Connection Factory name (non-transactional)

getConnectionFactoryName

public String getConnectionFactoryName()

Description copied from interface: StoreManager

Convenience accessor for the factory name for the connection (transactional).

Specified by:

getConnectionFactoryName in interface StoreManager

Returns:

Connection Factory name (transactional)

getProperty

public Object getProperty(String name)

Specified by:

getProperty in interface StoreManager

hasProperty

public boolean hasProperty(String name)

Specified by:

hasProperty in interface StoreManager

getIntProperty

public int getIntProperty(String name)

Specified by:

getIntProperty in interface StoreManager

getBooleanProperty

public boolean getBooleanProperty(String name)

Specified by:

getBooleanProperty in interface StoreManager

getBooleanProperty

public boolean getBooleanProperty(String name,
                         boolean resultIfNotSet)

Specified by:

getBooleanProperty in interface StoreManager

getBooleanObjectProperty

public Boolean getBooleanObjectProperty(String name)

Specified by:

getBooleanObjectProperty in interface StoreManager

getStringProperty

public String getStringProperty(String name)

Specified by:

getStringProperty in interface StoreManager

transactionStarted

public void transactionStarted(ExecutionContext ec)

Description copied from interface: StoreManager

Method to inform the StoreManager that a transaction has started for the specified execution context. This allows the StoreManager to initialise any objects as required.

Specified by:

transactionStarted in interface StoreManager

Parameters:

ec - ExecutionContext

transactionCommitted

public void transactionCommitted(ExecutionContext ec)

Description copied from interface: StoreManager

Method to inform the StoreManager that a transaction has committed for the specified execution context. This allows the StoreManager to close any objects as required.

Specified by:

transactionCommitted in interface StoreManager

Parameters:

ec - ExecutionContext

transactionRolledBack

public void transactionRolledBack(ExecutionContext ec)

Description copied from interface: StoreManager

Method to inform the StoreManager that a transaction has rolled back for the specified execution context. This allows the StoreManager to close any objects as required.

Specified by:

transactionRolledBack in interface StoreManager

Parameters:

ec - ExecutionContext

isAutoCreateTables

public boolean isAutoCreateTables()

Specified by:

isAutoCreateTables in interface StoreManager

isAutoCreateConstraints

public boolean isAutoCreateConstraints()

Specified by:

isAutoCreateConstraints in interface StoreManager

isAutoCreateColumns

public boolean isAutoCreateColumns()

Specified by:

isAutoCreateColumns in interface StoreManager

useBackedSCOWrapperForMember

public boolean useBackedSCOWrapperForMember(AbstractMemberMetaData mmd,
                                   ExecutionContext ec)

Description copied from interface: StoreManager

Method to return whether the specified member should use a backed SCO wrapper.

Specified by:

useBackedSCOWrapperForMember in interface StoreManager

Parameters:

mmd - Metadata for the member

ec - ExecutionContext

Returns:

Whether to use a back SCO wrapper (false means use a simple SCO wrapper).

getDefaultObjectProviderClassName

public String getDefaultObjectProviderClassName()

Specified by:

getDefaultObjectProviderClassName in interface StoreManager