Class HashPartitioningPolicy

  • All Implemented Interfaces:

    public class HashPartitioningPolicy
    extends FieldPartitioningPolicy
    PUBLIC: HashPartitioningPolicy partitions access to a database cluster by the hash of a field value from the object, such as the object's location, or tenant. The hash indexes into the list of connection pools. All write or read request for objects with that hash value are sent to the server. If a query does not include the field as a parameter, then it can either be sent to all servers and unioned, or left to the session's default behavior.
    See Also:
    Serialized Form
    James Sutherland
    EclipseLink 2.2
    • Field Detail

      • connectionPools

        protected List<String> connectionPools
    • Constructor Detail

      • HashPartitioningPolicy

        public HashPartitioningPolicy()
      • HashPartitioningPolicy

        public HashPartitioningPolicy​(String partitionField)
      • HashPartitioningPolicy

        public HashPartitioningPolicy​(String partitionField,
                                      boolean unionUnpartitionableQueries)
    • 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 List<String> getConnectionPools()
        PUBLIC: Return the list of connection pool names to replicate queries to.
      • setConnectionPools

        public void setConnectionPools​(List<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​(String connectionPool)
        PUBLIC: Add the connection pool name to the list of pools to rotate queries through.
      • getConnectionsForQuery

        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)
        INTERNAL: Get a connection from one of the pools in a round robin rotation fashion.
        Specified by:
        getConnectionsForQuery in class PartitioningPolicy
      • partitionPersist

        public void partitionPersist​(org.eclipse.persistence.internal.sessions.AbstractSession session,
                                     Object object,
                                     ClassDescriptor descriptor)
        INTERNAL: Allow for the persist call to assign the partition.
        partitionPersist in class PartitioningPolicy