Package io.jmix.eclipselink.impl

Class EclipselinkPersistenceSupport

java.lang.Object

io.jmix.eclipselink.impl.EclipselinkPersistenceSupport

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

@Component("eclipselink_EclipselinkPersistenceSupport")
public class EclipselinkPersistenceSupport
extends Object
implements org.springframework.context.ApplicationContextAware

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EclipselinkPersistenceSupport.ContainerResourceHolder
protected class	EclipselinkPersistenceSupport.ContainerResourceSynchronization
static interface	EclipselinkPersistenceSupport.EntityVisitor
protected class	EclipselinkPersistenceSupport.OnSaveEntityVisitor

Field Summary

Fields

Modifier and Type	Field	Description
protected List<AfterCompleteTransactionListener>	afterCompleteTxListeners
protected AttributeChangesProvider	attributeChangesProvider
protected List<BeforeCommitTransactionListener>	beforeCommitTxListeners
protected org.springframework.beans.factory.ObjectProvider<DeletePolicyProcessor>	deletePolicyProcessorProvider
protected EntityChangedEventManager	entityChangedEventManager
protected EntityListenerManager	entityListenerManager
protected EntityStates	entityStates
protected JpaCacheSupport	jpaCacheSupport
protected List<JpaLifecycleListener>	lifecycleListeners
protected Metadata	metadata
protected MetadataTools	metadataTools
protected QueryCacheManager	queryCacheManager
static final String	RESOURCE_HOLDER_KEY
protected StoreAwareLocator	storeAwareLocator

Constructor Summary

Constructors

Constructor	Description
EclipselinkPersistenceSupport()

Method Summary

Modifier and Type	Method	Description
protected void	beforeStore(EclipselinkPersistenceSupport.ContainerResourceHolder container, EclipselinkPersistenceSupport.EntityVisitor visitor, Collection<Object> instances, Set<Object> processed, boolean warnAboutImplicitFlush)
protected static Set<Object>	createEntitySet()
void	detach(jakarta.persistence.EntityManager entityManager, Object entity)
protected void	fireBeforeDetachEntityListener(Object entity, String storeName)
protected void	fireEntityChange(Object entity, EntityOp entityOp, AttributeChanges changes)
protected void	fireFlush(String storeName)
EclipselinkPersistenceSupport.ContainerResourceHolder	getInstanceContainerResourceHolder(String storeName)
Collection<Object>	getInstances(jakarta.persistence.EntityManager entityManager)
Collection<Object>	getSavedInstances(String storeName)
Collection<Object>	getSavedInstancesByTransactionManager(String tmKey)
String	getStorageName(org.eclipse.persistence.sessions.Session session)
protected boolean	isDeleted(Object entity, org.eclipse.persistence.internal.descriptors.changetracking.AttributeChangeListener changeListener)
protected void	makeDetached(Object instance)
EclipselinkPersistenceSupport.ContainerResourceHolder	prepareInstanceContainerResourceHolder(String transactionManagerKey)
void	processFlush(jakarta.persistence.EntityManager entityManager, boolean warnAboutImplicitFlush)
void	registerInstance(Object entity, jakarta.persistence.EntityManager entityManager)
void	registerInstance(Object entity, org.eclipse.persistence.internal.sessions.AbstractSession session)
void	registerSynchronizations(String transactionManagerKey)	INTERNAL.
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
protected void	traverseEntities(EclipselinkPersistenceSupport.ContainerResourceHolder container, EclipselinkPersistenceSupport.EntityVisitor visitor, boolean warnAboutImplicitFlush)

Methods inherited from class java.lang.Object

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

Field Details

RESOURCE_HOLDER_KEY

public static final String RESOURCE_HOLDER_KEY

storeAwareLocator

@Autowired
protected StoreAwareLocator storeAwareLocator

metadata

@Autowired
protected Metadata metadata

metadataTools

@Autowired
protected MetadataTools metadataTools

entityListenerManager

@Autowired
protected EntityListenerManager entityListenerManager

queryCacheManager

@Autowired
protected QueryCacheManager queryCacheManager

jpaCacheSupport

@Autowired
protected JpaCacheSupport jpaCacheSupport

entityChangedEventManager

@Autowired
protected EntityChangedEventManager entityChangedEventManager

entityStates

@Autowired
protected EntityStates entityStates

attributeChangesProvider

@Autowired
protected AttributeChangesProvider attributeChangesProvider

lifecycleListeners

@Autowired(required=false)
protected List<JpaLifecycleListener> lifecycleListeners

deletePolicyProcessorProvider

@Autowired
protected org.springframework.beans.factory.ObjectProvider<DeletePolicyProcessor> deletePolicyProcessorProvider

beforeCommitTxListeners

protected List<BeforeCommitTransactionListener> beforeCommitTxListeners

afterCompleteTxListeners

protected List<AfterCompleteTransactionListener> afterCompleteTxListeners

Constructor Details

EclipselinkPersistenceSupport

public EclipselinkPersistenceSupport()

Method Details

createEntitySet

protected static Set<Object> createEntitySet()

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

registerSynchronizations

public void registerSynchronizations(String transactionManagerKey)

INTERNAL. Register synchronizations with a just started transaction.

registerInstance

public void registerInstance(Object entity,
 jakarta.persistence.EntityManager entityManager)

registerInstance

public void registerInstance(Object entity,
 org.eclipse.persistence.internal.sessions.AbstractSession session)

getInstances

public Collection<Object> getInstances(jakarta.persistence.EntityManager entityManager)

getSavedInstances

public Collection<Object> getSavedInstances(String storeName)

getSavedInstancesByTransactionManager

public Collection<Object> getSavedInstancesByTransactionManager(String tmKey)

getStorageName

public String getStorageName(org.eclipse.persistence.sessions.Session session)

prepareInstanceContainerResourceHolder

public EclipselinkPersistenceSupport.ContainerResourceHolder prepareInstanceContainerResourceHolder(String transactionManagerKey)

getInstanceContainerResourceHolder

public EclipselinkPersistenceSupport.ContainerResourceHolder getInstanceContainerResourceHolder(String storeName)

processFlush

public void processFlush(jakarta.persistence.EntityManager entityManager,
 boolean warnAboutImplicitFlush)

fireBeforeDetachEntityListener

protected void fireBeforeDetachEntityListener(Object entity,
 String storeName)

isDeleted

protected boolean isDeleted(Object entity,
 org.eclipse.persistence.internal.descriptors.changetracking.AttributeChangeListener changeListener)

traverseEntities

protected void traverseEntities(EclipselinkPersistenceSupport.ContainerResourceHolder container,
 EclipselinkPersistenceSupport.EntityVisitor visitor,
 boolean warnAboutImplicitFlush)

beforeStore

protected void beforeStore(EclipselinkPersistenceSupport.ContainerResourceHolder container,
 EclipselinkPersistenceSupport.EntityVisitor visitor,
 Collection<Object> instances,
 Set<Object> processed,
 boolean warnAboutImplicitFlush)

detach

public void detach(jakarta.persistence.EntityManager entityManager,
 Object entity)

makeDetached

protected void makeDetached(Object instance)

fireFlush

protected void fireFlush(String storeName)

fireEntityChange

protected void fireEntityChange(Object entity,
 EntityOp entityOp,
 @Nullable
 AttributeChanges changes)