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:
James Sutherland
  • Field Details

    • connectionPools

      protected List<String> connectionPools
  • Constructor Details

    • HashPartitioningPolicy

      public HashPartitioningPolicy()
    • HashPartitioningPolicy

      public HashPartitioningPolicy(String partitionField)
    • HashPartitioningPolicy

      public HashPartitioningPolicy(String partitionField, boolean unionUnpartitionableQueries)
  • Method Details

    • 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