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 DataPartitioningCallback
public void setPartitionId(int id)
setPartitionId
in interface DataPartitioningCallback
public int getPartitionId()
getPartitionId
in interface oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallback
public boolean setDataKey(Object key)
setDataKey
in interface oracle.ucp.jdbc.oracle.DataBasedConnectionAffinityCallback
public boolean setConnectionAffinityContext(Object context)
setConnectionAffinityContext
in interface oracle.ucp.ConnectionAffinityCallback
public void setAffinityPolicy(oracle.ucp.ConnectionAffinityCallback.AffinityPolicy policy)
setAffinityPolicy
in interface oracle.ucp.ConnectionAffinityCallback
public Object getConnectionAffinityContext()
getConnectionAffinityContext
in interface oracle.ucp.ConnectionAffinityCallback
public oracle.ucp.ConnectionAffinityCallback.AffinityPolicy getAffinityPolicy()
getAffinityPolicy
in interface oracle.ucp.ConnectionAffinityCallback
Copyright © 2007–2021 Eclipse.org - EclipseLink Project. All rights reserved.