public class UCPDataPartitioningCallback extends Object implements DataPartitioningCallback, oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallback
PartitioningPolicy| Modifier and Type | Field and Description |
|---|---|
protected ThreadLocal |
partitionId
The id is stored in a thread local.
|
| Constructor and Description |
|---|
UCPDataPartitioningCallback() |
| Modifier and Type | Method and 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.
|
protected ThreadLocal partitionId
public void register(DataSource datSource, Session session)
register in interface DataPartitioningCallbackpublic void setPartitionId(int id)
setPartitionId in interface DataPartitioningCallbackpublic int getPartitionId()
getPartitionId in interface oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallbackpublic boolean setDataKey(Object key)
setDataKey in interface oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallbackpublic boolean setConnectionAffinityContext(Object context)
setConnectionAffinityContext in interface oracle.ucp.ConnectionAffinityCallbackpublic void setAffinityPolicy(oracle.ucp.ConnectionAffinityCallback.AffinityPolicy policy)
setAffinityPolicy in interface oracle.ucp.ConnectionAffinityCallbackpublic Object getConnectionAffinityContext()
getConnectionAffinityContext in interface oracle.ucp.ConnectionAffinityCallbackpublic oracle.ucp.ConnectionAffinityCallback.AffinityPolicy getAffinityPolicy()
getAffinityPolicy in interface oracle.ucp.ConnectionAffinityCallbackCopyright © 2007–2021 Eclipse.org - EclipseLink Project. All rights reserved.