Package com.broadleafcommerce.datafeed.repository

Interface CustomizedIncrementalDataFeedEntityUpdateRecordRepository<D extends com.broadleafcommerce.data.tracking.core.Trackable>

All Known Subinterfaces:

IncrementalDataFeedEntityUpdateRecordRepository<D>, JpaIncrementalDataFeedEntityUpdateRecordRepository<D>

All Known Implementing Classes:

JpaCustomizedIncrementalDataFeedEntityUpdateRecordRepository

public interface CustomizedIncrementalDataFeedEntityUpdateRecordRepository<D extends com.broadleafcommerce.data.tracking.core.Trackable>

Advanced repository methods for IncrementalDataFeedEntityUpdateRecordRepository.

Method Summary

Modifier and Type	Method	Description
int	hardDeleteAllByProcessExecutionId(String dataFeedProcessExecutionId, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically finds and hard-deletes IncrementalDataFeedEntityUpdateRecord instances belonging to the given DataFeedProcessExecution.
int	setExecutionIdForUnackedRecords(String dataFeedProcessId, String dataFeedProcessExecutionId, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically finds and sets IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessExecutionId() on all IncrementalDataFeedEntityUpdateRecord entities where it is currently null.

Method Details

setExecutionIdForUnackedRecords

@Policy(operationTypes=UPDATE)
int setExecutionIdForUnackedRecords(String dataFeedProcessId,
 String dataFeedProcessExecutionId,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Atomically finds and sets IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessExecutionId() on all IncrementalDataFeedEntityUpdateRecord entities where it is currently null.

Parameters:

dataFeedProcessId - the value of IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessId() to filter results by

dataFeedProcessExecutionId - the new value to set for IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessExecutionId()

contextInfo - context information around multitenant state

Returns:

the number of records that were updated

hardDeleteAllByProcessExecutionId

@Policy(operationTypes=DELETE)
int hardDeleteAllByProcessExecutionId(String dataFeedProcessExecutionId,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Atomically finds and hard-deletes IncrementalDataFeedEntityUpdateRecord instances belonging to the given DataFeedProcessExecution.

Parameters:

dataFeedProcessExecutionId - the value of IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessExecutionId() to match

contextInfo - context information around multitenant state

Returns:

the number of records that were deleted