Package com.bytedesk.core.socket.connection

Interface ConnectionRepository

All Superinterfaces:

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

public interface ConnectionRepository
extends org.springframework.data.jpa.repository.JpaRepository<ConnectionEntity,Long>, org.springframework.data.jpa.repository.JpaSpecificationExecutor<ConnectionEntity>

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
long	countByUserUidAndStatusAndDeletedFalse(String userUid, String status)
boolean	existsByClientId(String clientId)
Boolean	existsByUid(String uid)
Optional<ConnectionEntity>	findByClientId(String clientId)
Optional<ConnectionEntity>	findByClientIdForUpdate(String clientId)
Optional<ConnectionEntity>	findByUid(String uid)
List<ConnectionEntity>	findByUserUidAndDeletedFalse(String userUid)
int	updateHeartbeatIfOlder(String clientId, long now, long threshold)

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

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

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, delete, exists, findAll, findAll, findAll, findAll, findBy, findOne

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

findByUid

Optional<ConnectionEntity> findByUid(String uid)

existsByUid

Boolean existsByUid(String uid)

findByClientId

Optional<ConnectionEntity> findByClientId(String clientId)

existsByClientId

boolean existsByClientId(String clientId)

updateHeartbeatIfOlder

@Modifying(clearAutomatically=true,
           flushAutomatically=true)
@Query("update ConnectionEntity c set c.lastHeartbeatAt = :now where c.clientId = :clientId and (c.lastHeartbeatAt is null or c.lastHeartbeatAt <= :threshold)")
int updateHeartbeatIfOlder(@Param("clientId")
 String clientId,
 @Param("now")
 long now,
 @Param("threshold")
 long threshold)

findByClientIdForUpdate

@Lock(PESSIMISTIC_WRITE)
@Query("select c from ConnectionEntity c where c.clientId = :clientId")
Optional<ConnectionEntity> findByClientIdForUpdate(@Param("clientId")
 String clientId)

findByUserUidAndDeletedFalse

List<ConnectionEntity> findByUserUidAndDeletedFalse(String userUid)

countByUserUidAndStatusAndDeletedFalse

long countByUserUidAndStatusAndDeletedFalse(String userUid,
 String status)