public class UnionPartitioningPolicy extends ReplicationPartitioningPolicy
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
replicateWrites |
connectionPoolsname| Constructor and Description |
|---|
UnionPartitioningPolicy() |
UnionPartitioningPolicy(boolean replicateWrites) |
UnionPartitioningPolicy(java.util.List<java.lang.String> pools) |
UnionPartitioningPolicy(java.lang.String... pools) |
| Modifier and Type | Method and Description |
|---|---|
java.util.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.
|
boolean |
getReplicateWrites()
PUBLIC:
Return if write queries should be replicated.
|
void |
setReplicateWrites(boolean replicateWrites)
PUBLIC:
Set if write queries should be replicated.
|
addConnectionPool, getConnectionPools, initialize, setConnectionPoolsacquireAccessor, convertClassNamesToClasses, getAccessor, getName, partitionPersist, setNamepublic UnionPartitioningPolicy()
public UnionPartitioningPolicy(boolean replicateWrites)
public UnionPartitioningPolicy(java.lang.String... pools)
public UnionPartitioningPolicy(java.util.List<java.lang.String> pools)
public boolean getReplicateWrites()
public void setReplicateWrites(boolean replicateWrites)
public java.util.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 ReplicationPartitioningPolicy