ca.uhn.fhir.jpa.dao.data

Interface ISubscriptionTableDao

All Superinterfaces:

org.springframework.data.repository.CrudRepository<SubscriptionTable,Long>, org.springframework.data.jpa.repository.JpaRepository<SubscriptionTable,Long>, org.springframework.data.repository.PagingAndSortingRepository<SubscriptionTable,Long>, org.springframework.data.repository.query.QueryByExampleExecutor<SubscriptionTable>, org.springframework.data.repository.Repository<SubscriptionTable,Long>

public interface ISubscriptionTableDao
extends org.springframework.data.jpa.repository.JpaRepository<SubscriptionTable,Long>

Method Summary

Modifier and Type	Method and Description
void	deleteAllForSubscription(Long theSubscriptionId)
Collection<SubscriptionTable>	findInactiveBeforeCutoff(Date theCutoff)
SubscriptionTable	findOneByResourcePid(Long theId)
Collection<Long>	findSubscriptionsWhichNeedToBeChecked(String theStatus, Date theNextCheck)
int	updateLastClientPoll(Date theLastClientPoll)

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

deleteAllInBatch, deleteInBatch, findAll, findAll, findAll, findAll, findAll, flush, getOne, save, saveAndFlush

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

findAll

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

count, delete, delete, delete, deleteAll, exists, findOne, save

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

count, exists, findAll, findOne

Method Detail

findOneByResourcePid

@Query(value="SELECT t FROM SubscriptionTable t WHERE t.myResId = :pid")
SubscriptionTable findOneByResourcePid(@Param(value="pid")
                                                                                                                Long theId)

deleteAllForSubscription

@Modifying
 @Query(value="DELETE FROM SubscriptionTable t WHERE t.myId = :id ")
void deleteAllForSubscription(@Param(value="id")
                                                                                                              Long theSubscriptionId)

updateLastClientPoll

@Modifying
 @Query(value="UPDATE SubscriptionTable t SET t.myLastClientPoll = :last_client_poll")
int updateLastClientPoll(@Param(value="last_client_poll")
                                                                                                                           Date theLastClientPoll)

findInactiveBeforeCutoff

@Query(value="SELECT t FROM SubscriptionTable t WHERE t.myLastClientPoll < :cutoff OR (t.myLastClientPoll IS NULL AND t.myCreated < :cutoff)")
Collection<SubscriptionTable> findInactiveBeforeCutoff(@Param(value="cutoff")
                                                                                                                                                                                                      Date theCutoff)

findSubscriptionsWhichNeedToBeChecked

@Query(value="SELECT t.myId FROM SubscriptionTable t WHERE t.myStatus = :status AND t.myNextCheck <= :next_check")
Collection<Long> findSubscriptionsWhichNeedToBeChecked(@Param(value="status")
                                                                                                                                                                          String theStatus,
                                                                                                                                                                          @Param(value="next_check")
                                                                                                                                                                          Date theNextCheck)