Package sk.iway.iwcm.components.file_archiv

Interface FileArchiveRepository

All Superinterfaces:

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

@Repository
public interface FileArchiveRepository
extends DomainIdRepository<FileArchivatorBean,Long>

Provides domain-scoped persistence and bulk-update operations for file archive records.

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
int	claimWaitingFile(Long id, Integer domainId)	Atomically claims a waiting scheduled upload.
Integer	countReferencesToMain(String referenceToMain, Integer domainId)
List<FileArchivatorBean>	findAllByReferenceIdAndDomainId(Long referenceId, int domainId)
List<FileArchivatorBean>	findAllByReferenceIdAndUploadedAndDomainId(Long referenceId, int uploaded, int domainId)
org.springframework.data.domain.Page<FileArchivatorBean>	findAllByReferenceIdAndUploadedAndDomainId(Long referenceId, int uploaded, int domainId, org.springframework.data.domain.Pageable pageable)
List<FileArchivatorBean>	findAllByReferenceToMainAndDomainId(String referenceToMain, Integer domainId)
List<FileArchivatorBean>	findAllByReferenceToMainAndReferenceIdAndDomainId(String referenceToMain, Integer referenceId, Integer domainId)
List<FileArchivatorBean>	findAllByUploadedAndDomainId(Integer uploaded, Integer domainId)
List<FileArchivatorBean>	findAllMainFilesUploadedNotPattern(Integer domainId, org.springframework.data.domain.Pageable pageable)
List<FileArchivatorBean>	findAllMainFilesUploadedNotPatternIdsIn(List<Integer> globalIds, Integer domainId, org.springframework.data.domain.Pageable pageable)
List<FileArchivatorBean>	findAllMainFilesUploadedNotPatternsVirtualPathLike(String pattern, Integer domainId)
List<FileArchivatorBean>	findDistinctAllByCategoryLikeAndFilePathLikeAndDomainId(String category, String filePath, int domainId)
List<FileArchivatorBean>	findDistinctAllByProductLikeAndFilePathLikeAndDomainId(String product, String filePath, int domainId)
List<Integer>	findDistinctReferenceIds(Integer domainId)
FileArchivatorBean	findFirstByReferenceIdOrderByOrderIdAsc(int orderId)
Optional<Long>	findIdByFilePathAndFileName(String filePath, String fileName, Integer domainId)
List<String>	getDistinctCategory(Integer domainId)
List<String>	getDistinctProduct(Integer domainId)
String	getReferenceToMain(Long id, Integer domainId)
void	updateCategory(String oldCategory, String newCategory, Integer domainId)
void	updateProduct(String oldProduct, String newProduct, Integer domainId)
void	updateReferenceToMain(Long referenceId, String referenceToMain, Integer domainId)
void	updateReferenceToMain(String oldReferenceToMain, String newReferenceToMain, Integer domainId)

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, findAllByIdInAndDomainId, 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

findDistinctAllByProductLikeAndFilePathLikeAndDomainId

List<FileArchivatorBean> findDistinctAllByProductLikeAndFilePathLikeAndDomainId(String product,
 String filePath,
 int domainId)

findDistinctAllByCategoryLikeAndFilePathLikeAndDomainId

List<FileArchivatorBean> findDistinctAllByCategoryLikeAndFilePathLikeAndDomainId(String category,
 String filePath,
 int domainId)

findAllByReferenceIdAndUploadedAndDomainId

org.springframework.data.domain.Page<FileArchivatorBean> findAllByReferenceIdAndUploadedAndDomainId(Long referenceId,
 int uploaded,
 int domainId,
 org.springframework.data.domain.Pageable pageable)

findAllByReferenceIdAndUploadedAndDomainId

List<FileArchivatorBean> findAllByReferenceIdAndUploadedAndDomainId(Long referenceId,
 int uploaded,
 int domainId)

findAllByReferenceIdAndDomainId

List<FileArchivatorBean> findAllByReferenceIdAndDomainId(Long referenceId,
 int domainId)

findFirstByReferenceIdOrderByOrderIdAsc

FileArchivatorBean findFirstByReferenceIdOrderByOrderIdAsc(int orderId)

findDistinctReferenceIds

@Query("SELECT DISTINCT fab.referenceId FROM FileArchivatorBean fab WHERE fab.uploaded = 0 AND fab.referenceId > 0 AND fab.domainId = :domainId")
List<Integer> findDistinctReferenceIds(@Param("domainId")
 Integer domainId)

getDistinctCategory

@Query("SELECT DISTINCT fab.category FROM FileArchivatorBean fab WHERE fab.domainId = :domainId")
List<String> getDistinctCategory(@Param("domainId")
 Integer domainId)

getDistinctProduct

@Query("SELECT DISTINCT fab.product FROM FileArchivatorBean fab WHERE fab.domainId = :domainId")
List<String> getDistinctProduct(@Param("domainId")
 Integer domainId)

updateCategory

@Transactional
@Modifying
@Query("UPDATE FileArchivatorBean fab SET fab.category = :newCategory WHERE fab.category = :oldCategory AND fab.domainId = :domainId")
void updateCategory(@Param("oldCategory")
 String oldCategory,
 @Param("newCategory")
 String newCategory,
 @Param("domainId")
 Integer domainId)

updateProduct

@Transactional
@Modifying
@Query("UPDATE FileArchivatorBean fab SET fab.product = :newProduct WHERE fab.product = :oldProduct AND fab.domainId = :domainId")
void updateProduct(@Param("oldProduct")
 String oldProduct,
 @Param("newProduct")
 String newProduct,
 @Param("domainId")
 Integer domainId)

findAllMainFilesUploadedNotPatternsVirtualPathLike

@Query("SELECT fab FROM FileArchivatorBean fab WHERE CONCAT(fab.filePath, fab.fileName) LIKE :pattern AND fab.domainId = :domainId AND fab.referenceId = -1 AND fab.uploaded = -1 GROUP BY CONCAT(fab.filePath, fab.fileName)")
List<FileArchivatorBean> findAllMainFilesUploadedNotPatternsVirtualPathLike(@Param("pattern")
 String pattern,
 @Param("domainId")
 Integer domainId)

findAllByReferenceToMainAndDomainId

List<FileArchivatorBean> findAllByReferenceToMainAndDomainId(String referenceToMain,
 Integer domainId)

findAllByReferenceToMainAndReferenceIdAndDomainId

List<FileArchivatorBean> findAllByReferenceToMainAndReferenceIdAndDomainId(String referenceToMain,
 Integer referenceId,
 Integer domainId)

findAllByUploadedAndDomainId

List<FileArchivatorBean> findAllByUploadedAndDomainId(Integer uploaded,
 Integer domainId)

claimWaitingFile

@Transactional
@Modifying(clearAutomatically=true,
           flushAutomatically=true)
@Query("UPDATE FileArchivatorBean fab SET fab.uploaded = -2 WHERE fab.id = :id AND fab.uploaded = 0 AND fab.domainId = :domainId")
int claimWaitingFile(@Param("id")
 Long id,
 @Param("domainId")
 Integer domainId)

Atomically claims a waiting scheduled upload. The failed state is used as a fail-closed processing marker so another cluster node cannot publish the same detached row.

Parameters:

id - identifier of the waiting archive record

domainId - domain that owns the record

Returns:

number of claimed records; 1 when the claim succeeds, otherwise 0

updateReferenceToMain

@Transactional
@Modifying
@Query("UPDATE FileArchivatorBean fab SET fab.referenceToMain = :newReferenceToMain WHERE fab.referenceToMain = :oldReferenceToMain AND fab.domainId = :domainId")
void updateReferenceToMain(@Param("oldReferenceToMain")
 String oldReferenceToMain,
 @Param("newReferenceToMain")
 String newReferenceToMain,
 @Param("domainId")
 Integer domainId)

updateReferenceToMain

@Transactional
@Modifying
@Query("UPDATE FileArchivatorBean fab SET fab.referenceToMain = :referenceToMain WHERE fab.referenceId = :referenceId AND fab.domainId = :domainId")
void updateReferenceToMain(@Param("referenceId")
 Long referenceId,
 @Param("referenceToMain")
 String referenceToMain,
 @Param("domainId")
 Integer domainId)

getReferenceToMain

@Query("SELECT fab.referenceToMain FROM FileArchivatorBean fab WHERE fab.id = :id AND fab.domainId = :domainId")
String getReferenceToMain(@Param("id")
 Long id,
 @Param("domainId")
 Integer domainId)

countReferencesToMain

@Query("SELECT COUNT(fab.id) FROM FileArchivatorBean fab WHERE fab.referenceToMain = :referenceToMain AND fab.domainId = :domainId")
Integer countReferencesToMain(@Param("referenceToMain")
 String referenceToMain,
 @Param("domainId")
 Integer domainId)

findAllMainFilesUploadedNotPatternIdsIn

@Query("SELECT fab FROM FileArchivatorBean fab WHERE fab.globalId IN :globalIds AND fab.referenceId = -1 AND fab.uploaded = -1 AND (fab.referenceToMain IS NULL OR fab.referenceToMain = \'\') AND fab.domainId = :domainId")
List<FileArchivatorBean> findAllMainFilesUploadedNotPatternIdsIn(@Param("globalIds")
 List<Integer> globalIds,
 @Param("domainId")
 Integer domainId,
 org.springframework.data.domain.Pageable pageable)

findAllMainFilesUploadedNotPattern

@Query("SELECT fab FROM FileArchivatorBean fab WHERE fab.referenceId = -1 AND fab.uploaded = -1 AND (fab.referenceToMain IS NULL OR fab.referenceToMain = \'\') AND fab.domainId = :domainId")
List<FileArchivatorBean> findAllMainFilesUploadedNotPattern(@Param("domainId")
 Integer domainId,
 org.springframework.data.domain.Pageable pageable)

findIdByFilePathAndFileName

@Query("SELECT fab.id FROM FileArchivatorBean fab WHERE fab.filePath = :filePath AND fab.fileName = :fileName AND fab.domainId = :domainId")
Optional<Long> findIdByFilePathAndFileName(@Param("filePath")
 String filePath,
 @Param("fileName")
 String fileName,
 @Param("domainId")
 Integer domainId)