Class TransactionalPersistenceManagerImpl
java.lang.Object
org.apache.olingo.ext.proxy.commons.TransactionalPersistenceManagerImpl
- All Implemented Interfaces:
Serializable
,PersistenceManager
PersistenceManager
implementation using OData batch requests to implement
high-level user transactions: all read-write operations will be packed in a batch request to the OData service when
calling flush().- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected static final org.slf4j.Logger
Logger.protected final AbstractService<?>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
doFlush
(PersistenceChanges changes, TransactionItems items) Transactional changes commit.void
flush()
Flushes all pending changes to the OData service.Asynchronously flushes all pending changes to the OData service.protected void
processDelayedUpdates
(List<EntityLinkDesc> delayedUpdates, int pos, TransactionItems items, PersistenceChanges changeset) protected int
processEntityContext
(EntityInvocationHandler handler, int pos, TransactionItems items, List<EntityLinkDesc> delayedUpdates, PersistenceChanges changeset)
-
Field Details
-
LOG
protected static final org.slf4j.Logger LOGLogger. -
service
-
-
Constructor Details
-
TransactionalPersistenceManagerImpl
-
-
Method Details
-
doFlush
Transactional changes commit. -
flushAsync
Description copied from interface:PersistenceManager
Asynchronously flushes all pending changes to the OData service.- Specified by:
flushAsync
in interfacePersistenceManager
- Returns:
- a future handle
-
flush
public void flush()Description copied from interface:PersistenceManager
Flushes all pending changes to the OData service.- Specified by:
flush
in interfacePersistenceManager
-
processEntityContext
protected int processEntityContext(EntityInvocationHandler handler, int pos, TransactionItems items, List<EntityLinkDesc> delayedUpdates, PersistenceChanges changeset) -
processDelayedUpdates
protected void processDelayedUpdates(List<EntityLinkDesc> delayedUpdates, int pos, TransactionItems items, PersistenceChanges changeset)
-