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

Fields

Modifier and Type	Field and Description
protected static org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
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 org.apache.commons.logging.Log logger

Constructor Detail

AbstractHibernateSpaceSynchronizationEndpoint

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

Method Detail

isManaged

protected boolean isManaged(DataSyncOperation dataSyncOperation)

Returns:

if dataSyncOperation managed return true , else return false

filterItemValue

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

Filter from the input map the unmapped field of this entity

Parameters:

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