org.openspaces.persistency.hibernate
Class AbstractHibernateSpaceSynchronizationEndpoint

java.lang.Object
  com.gigaspaces.sync.SpaceSynchronizationEndpoint
      org.openspaces.persistency.patterns.ManagedEntriesSpaceSynchronizationEndpoint
          org.openspaces.persistency.hibernate.AbstractHibernateSpaceSynchronizationEndpoint

Direct Known Subclasses:

DefaultHibernateSpaceSynchronizationEndpoint, StatelessHibernateSpaceSynchronizationEndpoint

public abstract class AbstractHibernateSpaceSynchronizationEndpoint
extends ManagedEntriesSpaceSynchronizationEndpoint

A base class for Hibernate based SpaceSynchronizationEndpoint implementations.

Since:

9.5

Author:

eitany

Field Summary

protected static Log

logger

Constructor Summary

AbstractHibernateSpaceSynchronizationEndpoint(org.hibernate.SessionFactory sessionFactory, Set<String> managedEntries)

Method Summary

protected Map<String,Object>	filterItemValue(String entityName, Map<String,Object> itemValues) Filter from the input map the unmapped field of this entity
Iterable<String>	getManagedEntries()
protected String	getPartialUpdateHQL(DataSyncOperation dataSyncOperation, Map<String,Object> updatedValues)
org.hibernate.SessionFactory	getSessionFactory()
protected boolean	isManaged(DataSyncOperation dataSyncOperation)
protected void	rollbackTx(org.hibernate.Transaction tr)

Methods inherited from class com.gigaspaces.sync.SpaceSynchronizationEndpoint

afterOperationsBatchSynchronization, afterTransactionSynchronization, onAddIndex, onIntroduceType, onOperationsBatchSynchronization, onTransactionConsolidationFailure, onTransactionSynchronization

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected static final Log logger

Constructor Detail

AbstractHibernateSpaceSynchronizationEndpoint

public AbstractHibernateSpaceSynchronizationEndpoint(org.hibernate.SessionFactory sessionFactory,
                                                     Set<String> managedEntries)

Method Detail

isManaged

protected boolean isManaged(DataSyncOperation dataSyncOperation)

Parameters:

dataSyncOperation -

Returns:

filterItemValue

protected Map<String,Object> filterItemValue(String entityName,
                                             Map<String,Object> itemValues)

Filter from the input map the unmapped field of this entity

Parameters:

entityName -

itemValues - map of properties to filter

getPartialUpdateHQL

protected String getPartialUpdateHQL(DataSyncOperation dataSyncOperation,
                                     Map<String,Object> updatedValues)

rollbackTx

protected void rollbackTx(org.hibernate.Transaction tr)

getSessionFactory

public org.hibernate.SessionFactory getSessionFactory()

Returns:

the sessionFactory

getManagedEntries

public Iterable<String> getManagedEntries()

Specified by:

getManagedEntries in class ManagedEntriesSpaceSynchronizationEndpoint