public class UnionPartitioningPolicy extends ReplicationPartitioningPolicy
Modifier and Type | Field and Description |
---|---|
protected boolean |
replicateWrites |
connectionPools
name
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, setConnectionPools
acquireAccessor, convertClassNamesToClasses, getAccessor, getName, partitionPersist, setName
public 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