org.datanucleus.store.neodatis

Class ConnectionFactoryImpl

java.lang.Object

org.datanucleus.store.connection.AbstractConnectionFactory

org.datanucleus.store.neodatis.ConnectionFactoryImpl

All Implemented Interfaces:

org.datanucleus.store.connection.ConnectionFactory

public class ConnectionFactoryImpl
extends org.datanucleus.store.connection.AbstractConnectionFactory

Implementation of a ConnectionFactory for NeoDatis. Obtains access to the NeoDatis ODB supporting use of

• File-based NeoDatis using a URL like "neodatis:file:{filename}"
• Embedded server-based NeoDatis using a URL like "neodatis:server:{filename}"
• Server-based NeoDatis using a URL like "neodatis:host:port/identifier"

When an ODB is obtained for an ExecutionContext, it is cached so all subsequent uses for that ExecutionContext will have the same ODB. This means that the ODB is aligned with the transaction, and so we can use commit/rollback on the ODB. When the txn commits we still have the ODB in the cache so if a subsequent txn starts on the same ExecutionContext it will then have the same ODB. When the ExecutionContext is closed the ODB is finally closed.

Field Summary

Fields

Modifier and Type	Field and Description
protected HashMap	odbByExecutionContext Cache of the NeoDatis ODB keyed by ExecutionContext.

Fields inherited from class org.datanucleus.store.connection.AbstractConnectionFactory

RESOURCE_NAME_NONTX, RESOURCE_NAME_TX, resourceName, resourceType, storeMgr

Fields inherited from interface org.datanucleus.store.connection.ConnectionFactory

DATANUCLEUS_CONNECTION_RESOURCE_TYPE, DATANUCLEUS_CONNECTION2_RESOURCE_TYPE

Constructor Summary

Constructors

Constructor and Description
ConnectionFactoryImpl(org.datanucleus.store.StoreManager storeMgr, String resourceType) Constructor

Method Summary

Modifier and Type	Method and Description
void	closeODBForExecutionContext(Object poolKey) Convenience method to notify the factory that the specified ExecutionContext is closing, so to close any resources for it.
org.datanucleus.store.connection.ManagedConnection	createManagedConnection(org.datanucleus.ExecutionContext ec, Map txnOptionsIgnored) Method to create a new managed connection.
protected org.neodatis.odb.ODB	getNewODB() Convenience method to create a new ODB for this datastore.

Methods inherited from class org.datanucleus.store.connection.AbstractConnectionFactory

close, getConnection, getResourceName, getResourceType, toString

Methods inherited from class java.lang.Object

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

Field Detail

odbByExecutionContext

protected HashMap odbByExecutionContext

Cache of the NeoDatis ODB keyed by ExecutionContext.

Constructor Detail

ConnectionFactoryImpl

public ConnectionFactoryImpl(org.datanucleus.store.StoreManager storeMgr,
                             String resourceType)

Constructor

Parameters:

storeMgr - Store Manager

resourceType - Type of resource (tx, nontx)

Method Detail

closeODBForExecutionContext

public void closeODBForExecutionContext(Object poolKey)

Convenience method to notify the factory that the specified ExecutionContext is closing, so to close any resources for it.

Parameters:

poolKey - Key for the connection pool

getNewODB

protected org.neodatis.odb.ODB getNewODB()

Convenience method to create a new ODB for this datastore.

Returns:

The ODB

createManagedConnection

public org.datanucleus.store.connection.ManagedConnection createManagedConnection(org.datanucleus.ExecutionContext ec,
                                                                                  Map txnOptionsIgnored)

Method to create a new managed connection.

Parameters:

ec - Key for the pool

txnOptionsIgnored - Transaction options

Returns:

The connection