public class ReplicationPartitioningPolicy extends PartitioningPolicy
Constructor and Description |
---|
ReplicationPartitioningPolicy() |
ReplicationPartitioningPolicy(List<String> pools) |
ReplicationPartitioningPolicy(String... pools) |
Modifier and Type | Method and Description |
---|---|
void |
addConnectionPool(String connectionPool)
PUBLIC:
Add the connection pool name to the list of pools to rotate queries through.
|
List<String> |
getConnectionPools()
PUBLIC:
Return the list of connection pool names to replicate queries to.
|
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 each pool.
|
void |
initialize(org.eclipse.persistence.internal.sessions.AbstractSession session)
INTERNAL:
Default the connection pools to all pools if unset.
|
void |
setConnectionPools(List<String> connectionPools)
PUBLIC:
Set the list of connection pool names to replicate queries to.
|
acquireAccessor, convertClassNamesToClasses, getAccessor, getName, partitionPersist, setName
public ReplicationPartitioningPolicy()
public ReplicationPartitioningPolicy(String... pools)
public void initialize(org.eclipse.persistence.internal.sessions.AbstractSession session)
initialize
in class PartitioningPolicy
public List<String> getConnectionPools()
public void setConnectionPools(List<String> connectionPools)
public void addConnectionPool(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