won.protocol.repository

Interface ConnectionMessageContainerRepository

All Superinterfaces:

org.springframework.data.repository.CrudRepository<ConnectionMessageContainer,java.lang.Long>, org.springframework.data.repository.PagingAndSortingRepository<ConnectionMessageContainer,java.lang.Long>, org.springframework.data.repository.Repository<ConnectionMessageContainer,java.lang.Long>, WonRepository<ConnectionMessageContainer>

public interface ConnectionMessageContainerRepository
extends WonRepository<ConnectionMessageContainer>

Created by fkleedorfer on 05.12.2016.

Method Summary

Modifier and Type	Method and Description
ConnectionMessageContainer	findOneByContainedMessageUriForUpdate(java.net.URI messageUri)
ConnectionMessageContainer	findOneByParentUri(java.net.URI parentUri)
ConnectionMessageContainer	findOneByParentUriForUpdate(java.net.URI parentUri)
boolean	isReadPermittedForWebID(java.net.URI connectionUri, java.net.URI webId)
void	lockParentAndContainerByParentUriForUpdate(java.net.URI parentUri)

Methods inherited from interface won.protocol.repository.WonRepository

findById, saveAndFlush

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

findAll, findAll

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

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

Method Detail

findOneByParentUri

ConnectionMessageContainer findOneByParentUri(java.net.URI parentUri)

findOneByParentUriForUpdate

@Lock(value=PESSIMISTIC_WRITE)
 @Query(value="select c from ConnectionMessageContainer c where c.parentUri = :parentUri")
ConnectionMessageContainer findOneByParentUriForUpdate(@Param(value="parentUri")
                                                                                                                                                                                   java.net.URI parentUri)

lockParentAndContainerByParentUriForUpdate

@Lock(value=PESSIMISTIC_WRITE)
 @Query(value="select connection, c from Connection connection join ConnectionMessageContainer c on connection.connectionURI = c.parentUri where c.parentUri = :parentUri")
void lockParentAndContainerByParentUriForUpdate(@Param(value="parentUri")
                                                                                                                                                                                                                                                             java.net.URI parentUri)

findOneByContainedMessageUriForUpdate

@Lock(value=PESSIMISTIC_WRITE)
 @Query(value="select c from ConnectionMessageContainer c join  MessageEvent msg on msg.parentURI = c.parentUri where msg.messageURI = :messageUri")
ConnectionMessageContainer findOneByContainedMessageUriForUpdate(@Param(value="messageUri")
                                                                                                                                                                                                                                                       java.net.URI messageUri)

isReadPermittedForWebID

@Query(value="select case when (count(con) > 0) then true else false end from Connection con  where con.connectionURI = :connectionUri and (    con.atomURI = :webId    or con.targetAtomURI = :webId )")
boolean isReadPermittedForWebID(@Param(value="connectionUri")
                                                                                                                                                                                                                                           java.net.URI connectionUri,
                                                                                                                                                                                                                                           @Param(value="webId")
                                                                                                                                                                                                                                           java.net.URI webId)