Package org.eclipse.persistence.descriptors.partitioning

Class PinnedPartitioningPolicy

java.lang.Object

org.eclipse.persistence.descriptors.partitioning.PartitioningPolicy

org.eclipse.persistence.descriptors.partitioning.PinnedPartitioningPolicy

All Implemented Interfaces:

Serializable

public class PinnedPartitioningPolicy
extends PartitioningPolicy

PUBLIC: PinnedPartitionPolicy pins requests to a single connection pool.

See Also:

• Serialized Form

Author:

James Sutherland

Field Summary

Fields

Modifier and Type	Field	Description
protected String	connectionPool

Fields inherited from class org.eclipse.persistence.descriptors.partitioning.PartitioningPolicy

name

Constructor Summary

Constructors

Constructor	Description
PinnedPartitioningPolicy()
PinnedPartitioningPolicy(String pool)

Method Summary

Modifier and Type	Method	Description
String	getConnectionPool()	PUBLIC: Return the connection pool to pin queries to.
List<org.eclipse.persistence.internal.databaseaccess.Accessor>	getConnectionsForQuery(org.eclipse.persistence.internal.sessions.AbstractSession session, DatabaseQuery query, org.eclipse.persistence.internal.sessions.AbstractRecord arguments)	INTERNAL: Get a connection from each pool.
void	setConnectionPool(String connectionPool)	PUBLIC: Set the connection pool to pin queries to.

Methods inherited from class org.eclipse.persistence.descriptors.partitioning.PartitioningPolicy

acquireAccessor, convertClassNamesToClasses, getAccessor, getName, initialize, partitionPersist, setName

Methods inherited from class java.lang.Object

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

Field Details

connectionPool

protected String connectionPool

Constructor Details

PinnedPartitioningPolicy

public PinnedPartitioningPolicy()

PinnedPartitioningPolicy

public PinnedPartitioningPolicy(String pool)

Method Details

getConnectionPool

public String getConnectionPool()

PUBLIC: Return the connection pool to pin queries to.

setConnectionPool

public void setConnectionPool(String connectionPool)

PUBLIC: Set the connection pool to pin queries to.

getConnectionsForQuery

public List<org.eclipse.persistence.internal.databaseaccess.Accessor> getConnectionsForQuery(org.eclipse.persistence.internal.sessions.AbstractSession session,
 DatabaseQuery query,
 org.eclipse.persistence.internal.sessions.AbstractRecord arguments)

INTERNAL: Get a connection from each pool.

Specified by:

getConnectionsForQuery in class PartitioningPolicy