Package com.broadleafcommerce.dataimport.repository

Interface CustomizedImportBatchItemCompletionRepository<D>

All Superinterfaces:
com.broadleafcommerce.common.extension.DomainTypeAware
All Known Subinterfaces:
ImportBatchItemCompletionRepository<D>, JpaImportBatchItemCompletionRepository<D>
All Known Implementing Classes:
JpaCustomizedImportBatchItemCompletionRepository
public interface CustomizedImportBatchItemCompletionRepository<D> extends com.broadleafcommerce.common.extension.DomainTypeAware
Author:
Samarth Dhruva (samarthd)

  • Method Details

    • findByCorrelationIdInOrTopLevelParentIdInOrderedByLineNumber

      Stream<D> findByCorrelationIdInOrTopLevelParentIdInOrderedByLineNumber(String importId, @Nullable Collection<String> correlationIdIn, @Nullable Collection<String> topLevelParentCorrelationIdIn)
      For the given importId, returns all batch item completion records which either have a BatchItemCompletion.correlationId that matches one of the given correlationIdIn values or a BatchItemCompletion.topLevelParentCorrelationId that matches one of the given topLevelParentCorrelationIdIn values.

      Results must be sorted by BatchItemCompletion.lineNumber in ascending order.

      Parameters:
      importId - the ID of the import which results should be filtered by
      correlationIdIn - a list of correlation IDs that are valid to return in the result (optional)
      topLevelParentCorrelationIdIn - a list of top level parent correlation IDs that are valid to return in the result (optional)
      Returns:
      all records which either have a BatchItemCompletion.correlationId that matches one of the given correlationIdIn values or a BatchItemCompletion.topLevelParentCorrelationId that matches one of the given topLevelParentCorrelationIdIn values, sorted by BatchItemCompletion.lineNumber in ascending order

    • initializeForIndexing

      @Deprecated(since="1.8.2", forRemoval=true) @Nullable D initializeForIndexing(String batchItemCompletionId, com.broadleafcommerce.data.tracking.core.messaging.search.BatchIndexableType type, List<String> idsToIndex)
      Deprecated, for removal: This API element is subject to removal in a future version.
      replaced by initializeForIndexing(String, String, List)
      If the import is found, atomically initializes the NotificationState for BatchIndexRequestProducer.TYPE, and renews Import.getLastUpdated().
      Parameters:
      batchItemCompletionId - the ID of the BatchItemCompletion instance to modify
      type - The indexable type for the import
      idsToIndex - The repository entity ids to index
      Returns:
      the updated Import if found and updated, null otherwise

    • initializeForIndexing

      @Nullable D initializeForIndexing(String batchItemCompletionId, String batchIndexableType, List<String> idsToIndex)
      If the import is found, atomically initializes the NotificationState for BatchIndexRequestProducer.TYPE, and renews Import.getLastUpdated().
      Parameters:
      batchItemCompletionId - the ID of the BatchItemCompletion instance to modify
      batchIndexableType - The indexable type for the import
      idsToIndex - The repository entity ids to index
      Returns:
      the updated Import if found and updated, null otherwise

    • findAllBatchItemCompletionIdsByImportIds

      List<String> findAllBatchItemCompletionIdsByImportIds(List<String> importIds, int batchSize)
      Read a list of batch item completion ids for the provided import ids.
      Parameters:
      importIds - the import ids to match batch item completions against
      batchSize - the batch size for results returned
      Returns:
      a list of batch item completion ids for the provided import id

    • deleteAllByIdInBatch

      Integer deleteAllByIdInBatch(List<String> ids)
      Delete the batch item completions that match the corresponding ids using a single query.
      Parameters:
      ids - the list of ids to delete
      Returns:
      the number of batch item completions deleted