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.LoggerLogger.protected final AbstractService<?> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoFlush(PersistenceChanges changes, TransactionItems items) Transactional changes commit.voidflush()Flushes all pending changes to the OData service.Asynchronously flushes all pending changes to the OData service.protected voidprocessDelayedUpdates(List<EntityLinkDesc> delayedUpdates, int pos, TransactionItems items, PersistenceChanges changeset) protected intprocessEntityContext(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:PersistenceManagerAsynchronously flushes all pending changes to the OData service.- Specified by:
flushAsyncin interfacePersistenceManager- Returns:
- a future handle
-
flush
public void flush()Description copied from interface:PersistenceManagerFlushes all pending changes to the OData service.- Specified by:
flushin 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)
-