org.datanucleus.store.neodatis

Class NeoDatisStoreManager

java.lang.Object

org.datanucleus.properties.PropertyStore

org.datanucleus.store.AbstractStoreManager

org.datanucleus.store.neodatis.NeoDatisStoreManager

All Implemented Interfaces:

org.datanucleus.store.ObjectReferencingStoreManager, org.datanucleus.store.StoreManager

public class NeoDatisStoreManager
extends org.datanucleus.store.AbstractStoreManager
implements org.datanucleus.store.ObjectReferencingStoreManager

Store Manager for NeoDatis (http://www.neodatis.org/).

DataNucleus will select this StoreManager with URLs of the form "neodatis:...". Support for NeoDatis is for the following URLs

• neodatis:{filename} - uses a local NeoDatis database in the named file
• neodatis:server:{filename} - uses a local NeoDatis database in the named file as an embedded server
• neodatis:{hostname}:{port}/{identifier} - uses a remote NeoDatis database with the specified username/password

These URLs are specific to DataNucleus support since NeoDatis doesn't use URLs to define the datastore.

Object Activation and Field Loading

NeoDatis provides methods to hand out memory versions of the datastore objects. Each object has to be "activated" to have its values accessible. Similarly the object can be "deactivated" when it is no longer needed (freeing up resources, and the link to the disk object). When we retrieve an object from NeoDatis it activates the object. This makes all fields accessible. If however one of the fields is a PC object (or collection, or map, or array etc) that object itself is not activated. Consequently all fields are accessible from the start (unlike with RDBMS), but the ObjectProvider manages the list of fields that are considered "loaded", and this is initially just those in the DFG (even though others are available). When the user accesses one of these "not-loaded" fields NeoDatisManager.fetchObject is called and that field is marked as loaded (if it is a SCO mutable it is wrapped, and if it is a PC object it has a ObjectProvider connected and is activated).

Persistence

Each object is persisted on its own, and we dont use NeoDatis's internal cascade mechanism. Instead the NeoDatisManager.insertObject, or NeoDatisManager.updateObject methods are called for each object that is to be persisted/updated. Each call to insertObject/updateObject provides reachability by use of PersistFieldManager.

Deletion

Currently objects are deleted one by one since NeoDatis doesn't provide its own cascade delete process. We use DeleteFieldManager to navigate through the objec graph according to dependent field metadata.

Transactions and Connections

Refer to ConnectionFactoryImpl. In simple terms each ExecutionContext has a NeoDatis ODB associated with it, and this is retained until the end of life of the ExecutionContext. With NeoDatis in server mode this allows use of multiple PMs on the same underlying datastore. With NeoDatis in file mode you can only have one PM operating on the same underlying datastore at once. This is a NeoDatis limitation rather than ours.

Field Summary

Fields inherited from class org.datanucleus.store.AbstractStoreManager

connectionMgr, flushProcess, namingFactory, nucleusContext, persistenceHandler, primaryConnectionFactoryName, queryMgr, schemaHandler, secondaryConnectionFactoryName, storeDataMgr, storeManagerKey, valueGenerationMgr

Fields inherited from class org.datanucleus.properties.PropertyStore

frequentProperties, properties

Fields inherited from interface org.datanucleus.store.StoreManager

OPTION_APPLICATION_COMPOSITE_ID, OPTION_APPLICATION_ID, OPTION_DATASTORE_ID, OPTION_DATASTORE_TIME_STORES_MILLISECS, OPTION_DATASTORE_TIME_STORES_NANOSECS, OPTION_DATASTORE_TIMEOUT, OPTION_NONDURABLE_ID, OPTION_ORM, OPTION_ORM_EMBEDDED_ARRAY, OPTION_ORM_EMBEDDED_ARRAY_NESTED, OPTION_ORM_EMBEDDED_COLLECTION, OPTION_ORM_EMBEDDED_COLLECTION_NESTED, OPTION_ORM_EMBEDDED_MAP, OPTION_ORM_EMBEDDED_MAP_NESTED, OPTION_ORM_EMBEDDED_PC, OPTION_ORM_EMBEDDED_PC_NESTED, OPTION_ORM_FOREIGN_KEYS, OPTION_ORM_SECONDARY_TABLE, OPTION_ORM_SERIALISED_ARRAY_ELEMENT, OPTION_ORM_SERIALISED_COLLECTION_ELEMENT, OPTION_ORM_SERIALISED_MAP_KEY, OPTION_ORM_SERIALISED_MAP_VALUE, OPTION_ORM_SERIALISED_PC, OPTION_QUERY_CANCEL, OPTION_QUERY_JDOQL_BITWISE_OPS, OPTION_QUERY_JDOQL_BULK_DELETE, OPTION_QUERY_JDOQL_BULK_INSERT, OPTION_QUERY_JDOQL_BULK_UPDATE, OPTION_QUERY_JPQL_BULK_DELETE, OPTION_QUERY_JPQL_BULK_INSERT, OPTION_QUERY_JPQL_BULK_UPDATE, OPTION_TXN_ISOLATION_READ_COMMITTED, OPTION_TXN_ISOLATION_READ_UNCOMMITTED, OPTION_TXN_ISOLATION_REPEATABLE_READ, OPTION_TXN_ISOLATION_SERIALIZABLE

Constructor Summary

Constructors

Constructor and Description
NeoDatisStoreManager(org.datanucleus.ClassLoaderResolver clr, org.datanucleus.PersistenceNucleusContext ctx, Map<String,Object> props) Constructor for a new NeoDatis StoreManager.

Method Summary

Modifier and Type	Method and Description
void	close() Release of resources
void	deregisterODB(org.neodatis.odb.ODB odb) Method to deregister an ODB from this store.
org.datanucleus.store.Extent	getExtent(org.datanucleus.ExecutionContext ec, Class c, boolean subclasses) Accessor for an Extent for a class.
Object	getObjectIdForObject(org.datanucleus.ExecutionContext ec, Object pc) Convenience method to get the identity for a Persistable object.
String	getStrategyForNative(org.datanucleus.metadata.AbstractClassMetaData cmd, int absFieldNumber)
Collection	getSupportedOptions() Accessor for the supported options in string form
boolean	isStrategyDatastoreAttributed(org.datanucleus.metadata.AbstractClassMetaData cmd, int absFieldNumber) Check if the strategy is attributed by the database when the persistable object is inserted into the database.
void	notifyObjectIsOutdated(org.datanucleus.state.ObjectProvider sm) Hook for the ObjectProvider to notify us that an object is outdated (no longer valid).
void	registerODB(org.neodatis.odb.ODB odb) Method to register an ODB as active on this store.
protected void	registerStoreData(org.datanucleus.store.StoreData data) Method to register some data with the store.

Methods inherited from class org.datanucleus.store.AbstractStoreManager

deregisterAllStoreData, getApiAdapter, getBooleanObjectProperty, getBooleanProperty, getBooleanProperty, getClassNameForObjectID, getConnection, getConnection, getConnection, getConnectionDriverName, getConnectionFactory, getConnectionFactory2, getConnectionFactory2Name, getConnectionFactoryName, getConnectionManager, getConnectionPassword, getConnectionURL, getConnectionUserName, getDatastoreDate, getDefaultObjectProviderClassName, getFlushProcess, getIntProperty, getMetaDataManager, getNamingFactory, getNativeQueryLanguage, getNucleusConnection, getNucleusContext, getNucleusSequence, getPersistenceHandler, getPropertiesForGenerator, getProperty, getQueryCacheKey, getQueryManager, getSchemaHandler, getStoreDataForClass, getStoreManagerKey, getStrategyValue, getStrategyValueForGenerator, getStringProperty, getSubClassesForClass, getValueGenerationManager, hasProperty, isJdbcStore, logConfiguration, manageClasses, manageClassForIdentity, managesClass, newStoreData, printInformation, registerConnectionFactory, registerConnectionMgr, supportsQueryLanguage, supportsValueStrategy, transactionCommitted, transactionRolledBack, transactionStarted, unmanageAllClasses, unmanageClass, useBackedSCOWrapperForMember, usesBackedSCOWrappers

Methods inherited from class org.datanucleus.properties.PropertyStore

getFrequentProperties, hasPropertyNotNull, setPropertyInternal

Methods inherited from class java.lang.Object

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

Constructor Detail

NeoDatisStoreManager

public NeoDatisStoreManager(org.datanucleus.ClassLoaderResolver clr,
                            org.datanucleus.PersistenceNucleusContext ctx,
                            Map<String,Object> props)

Constructor for a new NeoDatis StoreManager. Stores the basic information required for the datastore management.

Parameters:

clr - the ClassLoaderResolver

ctx - The corresponding context.

props - Properties for the store manager

Method Detail

close

public void close()

Release of resources

Specified by:

close in interface org.datanucleus.store.StoreManager

Overrides:

close in class org.datanucleus.store.AbstractStoreManager

getStrategyForNative

public String getStrategyForNative(org.datanucleus.metadata.AbstractClassMetaData cmd,
                                   int absFieldNumber)

Overrides:

getStrategyForNative in class org.datanucleus.store.AbstractStoreManager

registerStoreData

protected void registerStoreData(org.datanucleus.store.StoreData data)

Method to register some data with the store. This will also register the data with the starter process.

Overrides:

registerStoreData in class org.datanucleus.store.AbstractStoreManager

Parameters:

data - The StoreData to add

registerODB

public void registerODB(org.neodatis.odb.ODB odb)

Method to register an ODB as active on this store. Will load up all known class mapping information into the datastore container.

Parameters:

odb - ODB

deregisterODB

public void deregisterODB(org.neodatis.odb.ODB odb)

Method to deregister an ODB from this store. ODB are deregistered when about to be closed and hence not interested in more class mapping information.

Parameters:

odb - ODB

notifyObjectIsOutdated

public void notifyObjectIsOutdated(org.datanucleus.state.ObjectProvider sm)

Hook for the ObjectProvider to notify us that an object is outdated (no longer valid). With NeoDatis we have no activate/deactivate mechanism so we do nothing.

Specified by:

notifyObjectIsOutdated in interface org.datanucleus.store.ObjectReferencingStoreManager

Parameters:

sm - ObjectProvider of object

isStrategyDatastoreAttributed

public boolean isStrategyDatastoreAttributed(org.datanucleus.metadata.AbstractClassMetaData cmd,
                                             int absFieldNumber)

Check if the strategy is attributed by the database when the persistable object is inserted into the database. "datastore-identity" cases will be datastore attributed (since we can't store the id anywhere).

Specified by:

isStrategyDatastoreAttributed in interface org.datanucleus.store.StoreManager

Overrides:

isStrategyDatastoreAttributed in class org.datanucleus.store.AbstractStoreManager

Parameters:

cmd - Metadata for the class

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

Returns:

if the object for the strategy is attributed by the database

getObjectIdForObject

public Object getObjectIdForObject(org.datanucleus.ExecutionContext ec,
                                   Object pc)

Convenience method to get the identity for a Persistable object.

Parameters:

ec - execution context

pc - The object

Returns:

The identity

getExtent

public org.datanucleus.store.Extent getExtent(org.datanucleus.ExecutionContext ec,
                                              Class c,
                                              boolean subclasses)

Accessor for an Extent for a class.

Specified by:

getExtent in interface org.datanucleus.store.StoreManager

Overrides:

getExtent in class org.datanucleus.store.AbstractStoreManager

Parameters:

ec - execution context

c - The class requiring the Extent

subclasses - Whether to include subclasses of 'c'

Returns:

The Extent.

getSupportedOptions

public Collection getSupportedOptions()

Accessor for the supported options in string form

Specified by:

getSupportedOptions in interface org.datanucleus.store.StoreManager

Overrides:

getSupportedOptions in class org.datanucleus.store.AbstractStoreManager