Package org.eclipse.persistence.platform.database.oracle.ucp

Class UCPDataPartitioningCallback

java.lang.Object

org.eclipse.persistence.platform.database.oracle.ucp.UCPDataPartitioningCallback

All Implemented Interfaces:

oracle.ucp.ConnectionAffinityCallback, oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallback, DataPartitioningCallback

Direct Known Subclasses:

GridLinkDataPartitioningCallback

public class UCPDataPartitioningCallback
extends Object
implements DataPartitioningCallback, oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallback

PUBLIC: Integrates with Oracle Universal ConnectionPool's data affinity support.

See Also:

• PartitioningPolicy

Author:

James Sutherland

Nested Class Summary

Nested classes/interfaces inherited from interface oracle.ucp.ConnectionAffinityCallback

oracle.ucp.ConnectionAffinityCallback.AffinityPolicy

Field Summary

Fields

Modifier and Type	Field	Description
protected ThreadLocal	partitionId	The id is stored in a thread local.

Constructor Summary

Constructors

Constructor	Description
UCPDataPartitioningCallback()

Method Summary

Modifier and Type	Method	Description
oracle.ucp.ConnectionAffinityCallback.AffinityPolicy	getAffinityPolicy()
Object	getConnectionAffinityContext()
int	getPartitionId()
void	register(DataSource datSource, Session session)
void	setAffinityPolicy(oracle.ucp.ConnectionAffinityCallback.AffinityPolicy policy)
boolean	setConnectionAffinityContext(Object context)
boolean	setDataKey(Object key)
void	setPartitionId(int id)	Set the partition id for this thread.

Methods inherited from class java.lang.Object

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

Field Details

partitionId

protected ThreadLocal partitionId

The id is stored in a thread local.

Constructor Details

UCPDataPartitioningCallback

public UCPDataPartitioningCallback()

Method Details

register

public void register(DataSource datSource,
 Session session)

Specified by:

register in interface DataPartitioningCallback

setPartitionId

public void setPartitionId(int id)

Set the partition id for this thread.

Specified by:

setPartitionId in interface DataPartitioningCallback

getPartitionId

public int getPartitionId()

Specified by:

getPartitionId in interface oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallback

setDataKey

public boolean setDataKey(Object key)

Specified by:

setDataKey in interface oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallback

setConnectionAffinityContext

public boolean setConnectionAffinityContext(Object context)

Specified by:

setConnectionAffinityContext in interface oracle.ucp.ConnectionAffinityCallback

setAffinityPolicy

public void setAffinityPolicy(oracle.ucp.ConnectionAffinityCallback.AffinityPolicy policy)

Specified by:

setAffinityPolicy in interface oracle.ucp.ConnectionAffinityCallback

getConnectionAffinityContext

public Object getConnectionAffinityContext()

Specified by:

getConnectionAffinityContext in interface oracle.ucp.ConnectionAffinityCallback

getAffinityPolicy

public oracle.ucp.ConnectionAffinityCallback.AffinityPolicy getAffinityPolicy()

Specified by:

getAffinityPolicy in interface oracle.ucp.ConnectionAffinityCallback