public class ValuePartitioningPolicy extends FieldPartitioningPolicy
Constructor and Description |
---|
ValuePartitioningPolicy() |
ValuePartitioningPolicy(String partitionField) |
ValuePartitioningPolicy(String partitionField,
boolean unionUnpartitionableQueries) |
Modifier and Type | Method and Description |
---|---|
void |
addPartition(Object value,
String connectionPool)
PUBLIC:
Add the value partition.
|
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 one of the pools in a round robin rotation fashion.
|
String |
getDefaultConnectionPool()
PUBLIC:
Return the default connection pool used for any unmapped values.
|
List<String> |
getOrderedPartitions() |
Map<Object,String> |
getPartitions()
PUBLIC:
Return the value partitions.
|
void |
partitionPersist(org.eclipse.persistence.internal.sessions.AbstractSession session,
Object object,
ClassDescriptor descriptor)
INTERNAL:
Allow for the persist call to assign the partition.
|
void |
setDefaultConnectionPool(String defaultConnectionPool)
PUBLIC:
Set the default connection pool used for any unmapped values.
|
void |
setOrderedPartitions(List<String> orderedPartitions) |
void |
setPartitions(Map<Object,String> partitions)
PUBLIC:
Set the value partitions.
|
getPartitionField, getPartitionFieldName, getUnionUnpartitionableQueries, setPartitionField, setPartitionField, setUnionUnpartitionableQueries
acquireAccessor, convertClassNamesToClasses, getAccessor, getName, initialize, setName
public ValuePartitioningPolicy()
public ValuePartitioningPolicy(String partitionField)
public ValuePartitioningPolicy(String partitionField, boolean unionUnpartitionableQueries)
public String getDefaultConnectionPool()
public void setDefaultConnectionPool(String defaultConnectionPool)
public Map<Object,String> getPartitions()
public void setPartitions(Map<Object,String> partitions)
public void addPartition(Object value, String connectionPool)
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)
getConnectionsForQuery
in class PartitioningPolicy
public void partitionPersist(org.eclipse.persistence.internal.sessions.AbstractSession session, Object object, ClassDescriptor descriptor)
partitionPersist
in class PartitioningPolicy
EclipseLink 2.3.2, "build v20111125-r10461" API Reference