Package sk.iway.iwcm.rag.jpa

Interface IndexQueueRepository

All Superinterfaces:

org.springframework.data.repository.CrudRepository<IndexQueueEntity,Long>, DomainIdRepository<IndexQueueEntity,Long>, org.springframework.data.jpa.repository.JpaRepository<IndexQueueEntity,Long>, org.springframework.data.jpa.repository.JpaSpecificationExecutor<IndexQueueEntity>, org.springframework.data.repository.ListCrudRepository<IndexQueueEntity,Long>, org.springframework.data.repository.ListPagingAndSortingRepository<IndexQueueEntity,Long>, org.springframework.data.repository.PagingAndSortingRepository<IndexQueueEntity,Long>, org.springframework.data.repository.query.QueryByExampleExecutor<IndexQueueEntity>, org.springframework.data.repository.Repository<IndexQueueEntity,Long>

@Repository
public interface IndexQueueRepository
extends DomainIdRepository<IndexQueueEntity,Long>

Spring Data repository for IndexQueueEntity. Provides methods to query, insert, and delete RAG indexing queue entries.

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.jpa.repository.JpaSpecificationExecutor

org.springframework.data.jpa.repository.JpaSpecificationExecutor.SpecificationFluentQuery<T extends Object>

Method Summary

Modifier and Type	Method	Description
void	deleteByEntityTypeAndEntityId(RagEntityType entityType, Integer entityId, Integer domainId)
void	deleteByEntityTypeAndEntityId(RagEntityType entityType, List<Integer> entityIds, Integer domainId)
List<Integer>	findExistingEntityIds(RagEntityType entityType, RagIndexAction action, Integer domainId)
List<IndexQueueEntity>	findTop500ByOrderByCreateDateAsc()

Methods inherited from interface org.springframework.data.repository.CrudRepository

count, delete, deleteAll, deleteAll, deleteAllById, deleteById, existsById, findById, save

Methods inherited from interface sk.iway.iwcm.system.datatable.spring.DomainIdRepository

findAllByDomainId, findAllByDomainId, findFirstByIdAndDomainId

Methods inherited from interface org.springframework.data.jpa.repository.JpaRepository

deleteAllByIdInBatch, deleteAllInBatch, deleteAllInBatch, deleteInBatch, findAll, findAll, flush, getById, getOne, getReferenceById, saveAllAndFlush, saveAndFlush

Methods inherited from interface org.springframework.data.jpa.repository.JpaSpecificationExecutor

count, count, delete, delete, exists, exists, findAll, findAll, findAll, findAll, findAll, findBy, findBy, findOne, findOne, update

Methods inherited from interface org.springframework.data.repository.ListCrudRepository

findAll, findAllById, saveAll

Methods inherited from interface org.springframework.data.repository.ListPagingAndSortingRepository

findAll

Methods inherited from interface org.springframework.data.repository.PagingAndSortingRepository

findAll

Methods inherited from interface org.springframework.data.repository.query.QueryByExampleExecutor

count, exists, findAll, findBy, findOne

Method Details

findTop500ByOrderByCreateDateAsc

List<IndexQueueEntity> findTop500ByOrderByCreateDateAsc()

deleteByEntityTypeAndEntityId

@Modifying
@Transactional
@Query("DELETE FROM IndexQueueEntity q WHERE q.entityType = :entityType AND q.entityId = :entityId AND q.domainId = :domainId")
void deleteByEntityTypeAndEntityId(@Param("entityType")
 RagEntityType entityType,
 @Param("entityId")
 Integer entityId,
 @Param("domainId")
 Integer domainId)

deleteByEntityTypeAndEntityId

@Modifying
@Transactional
@Query("DELETE FROM IndexQueueEntity q WHERE q.entityType = :entityType AND q.entityId IN :entityIds AND q.domainId = :domainId")
void deleteByEntityTypeAndEntityId(@Param("entityType")
 RagEntityType entityType,
 @Param("entityIds")
 List<Integer> entityIds,
 @Param("domainId")
 Integer domainId)

findExistingEntityIds

@Query("SELECT q.entityId FROM IndexQueueEntity q WHERE q.entityType = :entityType AND q.action = :action AND q.domainId = :domainId")
List<Integer> findExistingEntityIds(@Param("entityType")
 RagEntityType entityType,
 @Param("action")
 RagIndexAction action,
 @Param("domainId")
 Integer domainId)