Class ReplicationPartitioningPolicy

  • All Implemented Interfaces:
    Direct Known Subclasses:
    RoundRobinPartitioningPolicy, UnionPartitioningPolicy

    public class ReplicationPartitioningPolicy
    extends PartitioningPolicy
    PUBLIC: ReplicationPartitioningPolicy sends requests to a set of connection pools. It is for replicating data across a cluster of database machines. Only modification queries are replicated.
    See Also:
    Serialized Form
    James Sutherland
    EclipseLink 2.2
    • Field Detail

      • connectionPools

        protected java.util.List<java.lang.String> connectionPools
    • Constructor Detail

      • ReplicationPartitioningPolicy

        public ReplicationPartitioningPolicy()
      • ReplicationPartitioningPolicy

        public ReplicationPartitioningPolicy​(java.lang.String... pools)
      • ReplicationPartitioningPolicy

        public ReplicationPartitioningPolicy​(java.util.List<java.lang.String> pools)
    • Method Detail

      • initialize

        public void initialize​(org.eclipse.persistence.internal.sessions.AbstractSession session)
        INTERNAL: Default the connection pools to all pools if unset.
        initialize in class PartitioningPolicy
      • getConnectionPools

        public java.util.List<java.lang.String> getConnectionPools()
        PUBLIC: Return the list of connection pool names to replicate queries to.
      • setConnectionPools

        public void setConnectionPools​(java.util.List<java.lang.String> connectionPools)
        PUBLIC: Set the list of connection pool names to replicate queries to. A connection pool with the same name must be defined on the ServerSession.
      • addConnectionPool

        public void addConnectionPool​(java.lang.String connectionPool)
        PUBLIC: Add the connection pool name to the list of pools to rotate queries through.
      • getConnectionsForQuery

        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)
        INTERNAL: Get a connection from each pool.
        Specified by:
        getConnectionsForQuery in class PartitioningPolicy