Package com.broadleafcommerce.datafeed.service

Interface IncrementalDataFeedEntityUpdateRecordService<P extends IncrementalDataFeedEntityUpdateRecord>

All Superinterfaces:

com.broadleafcommerce.data.tracking.core.service.CrudEntityService<P>, com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityService<P>

All Known Implementing Classes:

DefaultIncrementalDataFeedEntityUpdateRecordService

public interface IncrementalDataFeedEntityUpdateRecordService<P extends IncrementalDataFeedEntityUpdateRecord>
extends com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityService<P>

Service component providing API for CRUD operations on IncrementalDataFeedEntityUpdateRecord. Supported by IncrementalDataFeedEntityUpdateRecordRepository.

See Also:

• IncrementalDataFeedEntityUpdateManager

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.

Methods inherited from interface com.broadleafcommerce.data.tracking.core.service.CrudEntityService

create, createAll, createAllAllowingPartialSuccess, delete, readAll, readAll, readAll, readAllByContextId, readByContextId, replace, replaceAll, replaceAllAllowingPartialSuccess, update, updateAll, updateAllAllowingPartialSuccess, updateSort

Methods inherited from interface com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityService

readAll, readAll, readAll, readAll

Method Details

setExecutionIdForUnackedRecords

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

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