public interface MessageEventRepository extends WonRepository<MessageEvent>
| Modifier and Type | Method and Description |
|---|---|
long |
countByParentURIAndMessageType(java.net.URI parentURI,
WonMessageType messageType) |
void |
deleteByParentURI(java.net.URI parentUri) |
java.util.List<MessageEvent> |
findByParentURI(java.net.URI URI) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURI(java.net.URI parentURI,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAfter(java.net.URI parentURI,
java.util.Date referenceDate,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAfterFetchDatasetEagerly(java.net.URI parentURI,
java.util.Date referenceDate,
org.springframework.data.domain.Pageable pageable) |
java.util.List<MessageEvent> |
findByParentURIAndMessageType(java.net.URI parentURI,
WonMessageType messageType) |
java.util.List<MessageEvent> |
findByParentURIAndMessageTypeForUpdate(java.net.URI parentURI,
WonMessageType messageType) |
java.util.List<MessageEvent> |
findByParentURIAndNotReferencedByOtherMessage(java.net.URI parentURI) |
java.util.List<MessageEvent> |
findByParentURIAndNotReferencedByOtherMessageForUpdate(java.net.URI parentURI) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAndType(java.net.URI parentURI,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAndTypeAfter(java.net.URI parentURI,
java.util.Date referenceDate,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAndTypeAfterFetchDatasetEagerly(java.net.URI parentURI,
java.util.Date referenceDate,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAndTypeBefore(java.net.URI parentURI,
java.util.Date referenceDate,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAndTypeBeforeFetchDatasetEagerly(java.net.URI parentURI,
java.util.Date referenceDate,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAndTypeBeforeFetchDatasetEagerly(java.net.URI parentURI,
java.net.URI referenceMessageURI,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIAndTypeFetchDatasetEagerly(java.net.URI parentURI,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIBefore(java.net.URI parentURI,
java.util.Date referenceDate,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIBeforeFetchDatasetEagerly(java.net.URI parentURI,
java.util.Date referenceDate,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIBeforeFetchDatasetEagerly(java.net.URI parentURI,
java.net.URI referenceMessageUri,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<MessageEvent> |
findByParentURIFetchDatasetEagerly(java.net.URI parentURI,
org.springframework.data.domain.Pageable pageable) |
java.util.Optional<MessageEvent> |
findFirstByMessageURIAndParentURI(java.net.URI messageUri,
java.net.URI parentUri) |
java.util.Date |
findMaxActivityDateOfParentAtTime(java.net.URI parentURI,
java.util.Date referenceDate) |
java.util.Date |
findMaxActivityDateOfParentAtTime(java.net.URI parentURI,
WonMessageType messageType,
java.util.Date referenceDate) |
MessageEvent |
findNewestByParentURI(java.net.URI parentUri) |
MessageEvent |
findNewestByParentURIforUpdate(java.net.URI parentUri) |
MessageEvent |
findOldestByParentURIforUpdate(java.net.URI parentUri) |
java.util.Optional<MessageEvent> |
findOneByMessageURIAndParentURI(java.net.URI messageURI,
java.net.URI parentURI) |
MessageEvent |
findOneByMessageURIAndParentURIForUpdate(java.net.URI uri,
java.net.URI parentUri) |
java.util.Optional<MessageEvent> |
findOneByParentURIAndRespondingToURIAndResponseContainerURI(java.net.URI parentURI,
java.net.URI responseToURI,
java.net.URI responseParentURI) |
org.springframework.data.domain.Slice<java.net.URI> |
getMessageURIsByParentURI(java.net.URI parentURI,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<java.net.URI> |
getMessageURIsByParentURIAfter(java.net.URI parentURI,
java.util.Date referenceDate,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<java.net.URI> |
getMessageURIsByParentURIAfter(java.net.URI parentURI,
java.util.Date referenceDate,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<java.net.URI> |
getMessageURIsByParentURIBefore(java.net.URI parentURI,
java.util.Date referenceDate,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Slice<java.net.URI> |
getMessageURIsByParentURIBefore(java.net.URI parentURI,
java.util.Date referenceDate,
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable) |
java.util.List<UnreadMessageInfoForConnection> |
getUnreadInfoForAtom(java.net.URI atomURI,
java.util.Collection<java.net.URI> lastSeenMessageURIs) |
boolean |
isReadPermittedForWebID(java.net.URI messageUri,
java.net.URI webId) |
void |
lockAtomAndMessageContainerByContainedMessageForUpdate(java.net.URI messageUri) |
void |
lockConnectionAndMessageContainerByContainedMessageForUpdate(java.net.URI messageUri) |
findById, saveAndFlushjava.util.Optional<MessageEvent> findFirstByMessageURIAndParentURI(java.net.URI messageUri, java.net.URI parentUri)
java.util.Optional<MessageEvent> findOneByMessageURIAndParentURI(java.net.URI messageURI, java.net.URI parentURI)
java.util.Optional<MessageEvent> findOneByParentURIAndRespondingToURIAndResponseContainerURI(java.net.URI parentURI, java.net.URI responseToURI, java.net.URI responseParentURI)
@Query(value="select case when (count(msg) > 0) then true else false end from MessageEvent msg left outer join Connection con on ( msg.parentURI = con.connectionURI or msg.parentURI = con.atomURI ) where msg.messageURI = :messageUri and ( ( con is null and msg.parentURI = :webId ) or con.atomURI = :webId or con.targetAtomURI = :webId or msg.recipientNodeURI = :webId or msg.senderNodeURI = :webId )")
boolean isReadPermittedForWebID(@Param(value="messageUri")
java.net.URI messageUri,
@Param(value="webId")
java.net.URI webId)
@Query(value="select \n\tnew won.protocol.model.unread.UnreadMessageInfoForConnection(\n\t\tc.connectionURI, \n\t\tc.state, \n\t\tcount(*), \n\t\tmax(m.creationDate), \n\t\tmin(m.creationDate) \n ) \n from Connection c join MessageEvent m on \n \tc.connectionURI = m.parentURI\n left join MessageEvent last on \n m.parentURI = last.parentURI\n and last.messageURI in :lastSeenMessageUris \n where \n c.atomURI = :atomUri \n\t\tand m.messageType not in (\'SUCCESS_RESPONSE\', \'FAILURE_RESPONSE\') \n and (last is null or m.creationDate > last.creationDate) \n group by c.connectionURI, c.state \n") java.util.List<UnreadMessageInfoForConnection> getUnreadInfoForAtom(@Param(value="atomUri") java.net.URI atomURI, @Param(value="lastSeenMessageUris") java.util.Collection<java.net.URI> lastSeenMessageURIs)
@Lock(value=PESSIMISTIC_WRITE)
@Query(value="select n,c from AtomMessageContainer c join MessageEvent msg on msg.parentURI = c.parentUri join Atom n on c.parentUri = n.atomURI where msg.messageURI = :messageUri")
void lockAtomAndMessageContainerByContainedMessageForUpdate(@Param(value="messageUri")
java.net.URI messageUri)
@Lock(value=PESSIMISTIC_WRITE)
@Query(value="select con,c from AtomMessageContainer c join MessageEvent msg on msg.parentURI = c.parentUri join Connection con on c.parentUri = con.connectionURI where msg.messageURI = :messageUri")
void lockConnectionAndMessageContainerByContainedMessageForUpdate(@Param(value="messageUri")
java.net.URI messageUri)
@Lock(value=PESSIMISTIC_WRITE) @Query(value="select msg from MessageEvent msg where msg.messageURI = :msgUri and msg.parentURI = :parentUri") MessageEvent findOneByMessageURIAndParentURIForUpdate(@Param(value="msgUri") java.net.URI uri, @Param(value="parentUri") java.net.URI parentUri)
java.util.List<MessageEvent> findByParentURI(java.net.URI URI)
@Lock(value=PESSIMISTIC_WRITE) @Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and msg.messageType = :messageType") java.util.List<MessageEvent> findByParentURIAndMessageTypeForUpdate(@Param(value="parent") java.net.URI parentURI, @Param(value="messageType") WonMessageType messageType)
@Query(value="select count(*) from MessageEvent msg where msg.parentURI = :parent and msg.messageType = :messageType")
long countByParentURIAndMessageType(@Param(value="parent")
java.net.URI parentURI,
@Param(value="messageType")
WonMessageType messageType)
@Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and msg.messageType = :messageType") java.util.List<MessageEvent> findByParentURIAndMessageType(@Param(value="parent") java.net.URI parentURI, @Param(value="messageType") WonMessageType messageType)
@Lock(value=PESSIMISTIC_WRITE) @Query(value="select msg from MessageEvent msg left outer join MessageEvent msg2 on msg.parentURI = msg2.parentURI and msg.creationDate < msg2.creationDate where msg.parentURI = :parent and msg2.id is null") MessageEvent findNewestByParentURIforUpdate(@Param(value="parent") java.net.URI parentUri)
@Query(value="select msg from MessageEvent msg left outer join MessageEvent msg2 on msg.parentURI = msg2.parentURI and msg.creationDate < msg2.creationDate where msg.parentURI = :parent and msg2.id is null") MessageEvent findNewestByParentURI(@Param(value="parent") java.net.URI parentUri)
@Lock(value=PESSIMISTIC_WRITE) @Query(value="select msg from MessageEvent msg left outer join MessageEvent msg2 on msg.parentURI = msg2.parentURI and msg.creationDate > msg2.creationDate where msg.parentURI = :parent and msg2.id is null") MessageEvent findOldestByParentURIforUpdate(@Param(value="parent") java.net.URI parentUri)
@Lock(value=PESSIMISTIC_WRITE) @Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and referencedByOtherMessage = false") java.util.List<MessageEvent> findByParentURIAndNotReferencedByOtherMessageForUpdate(@Param(value="parent") java.net.URI parentURI)
@Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and referencedByOtherMessage = false") java.util.List<MessageEvent> findByParentURIAndNotReferencedByOtherMessage(@Param(value="parent") java.net.URI parentURI)
@Query(value="select msg from MessageEvent msg where msg.parentURI = :parent") org.springframework.data.domain.Slice<MessageEvent> findByParentURI(@Param(value="parent") java.net.URI parentURI, org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg left join fetch msg.datasetHolder where msg.parentURI = :parent") org.springframework.data.domain.Slice<MessageEvent> findByParentURIFetchDatasetEagerly(@Param(value="parent") java.net.URI parentURI, org.springframework.data.domain.Pageable pageable)
@Query(value="select messageURI from MessageEvent msg where msg.parentURI = :parent and msg.messageType = :messageType")
org.springframework.data.domain.Slice<java.net.URI> getMessageURIsByParentURI(@Param(value="parent")
java.net.URI parentURI,
@Param(value="messageType")
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and msg.messageType = :messageType") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAndType(@Param(value="parent") java.net.URI parentURI, @Param(value="messageType") WonMessageType messageType, org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg left join fetch msg.datasetHolder where msg.parentURI = :parent and msg.messageType = :messageType") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAndTypeFetchDatasetEagerly(@Param(value="parent") java.net.URI parentURI, @Param(value="messageType") WonMessageType messageType, org.springframework.data.domain.Pageable pageable)
@Query(value="select messageURI from MessageEvent msg where msg.parentURI = :parent and msg.creationDate < :referenceDate")
org.springframework.data.domain.Slice<java.net.URI> getMessageURIsByParentURIBefore(@Param(value="parent")
java.net.URI parentURI,
@Param(value="referenceDate")
java.util.Date referenceDate,
org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and msg.creationDate < :referenceDate") org.springframework.data.domain.Slice<MessageEvent> findByParentURIBefore(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceDate") java.util.Date referenceDate, org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg left join fetch msg.datasetHolder where msg.parentURI = :parent and msg.creationDate < :referenceDate") org.springframework.data.domain.Slice<MessageEvent> findByParentURIBeforeFetchDatasetEagerly(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceDate") java.util.Date referenceDate, org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg left join fetch msg.datasetHolder where msg.parentURI = :parent and msg.creationDate < (select msg2.creationDate from MessageEvent msg2 where msg2.messageURI = :referenceMessageUri )") org.springframework.data.domain.Slice<MessageEvent> findByParentURIBeforeFetchDatasetEagerly(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceMessageUri") java.net.URI referenceMessageUri, org.springframework.data.domain.Pageable pageable)
@Query(value="select messageURI from MessageEvent msg where msg.parentURI = :parent and msg.creationDate < :referenceDate and msg.messageType = :messageType")
org.springframework.data.domain.Slice<java.net.URI> getMessageURIsByParentURIBefore(@Param(value="parent")
java.net.URI parentURI,
@Param(value="referenceDate")
java.util.Date referenceDate,
@Param(value="messageType")
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and msg.creationDate < :referenceDate and msg.messageType = :messageType") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAndTypeBefore(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceDate") java.util.Date referenceDate, @Param(value="messageType") WonMessageType messageType, org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg left join fetch msg.datasetHolder where msg.parentURI = :parent and msg.creationDate < :referenceDate and msg.messageType = :messageType") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAndTypeBeforeFetchDatasetEagerly(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceDate") java.util.Date referenceDate, @Param(value="messageType") WonMessageType messageType, org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg left join fetch msg.datasetHolder where msg.parentURI = :parent and msg.messageType = :messageType and msg.creationDate < (select msg2.creationDate from MessageEvent msg2 where msg2.messageURI = :referenceMessageUri )") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAndTypeBeforeFetchDatasetEagerly(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceMessageUri") java.net.URI referenceMessageURI, @Param(value="messageType") WonMessageType messageType, org.springframework.data.domain.Pageable pageable)
@Query(value="select messageURI from MessageEvent msg where msg.parentURI = :parent and msg.creationDate > :referenceDate")
org.springframework.data.domain.Slice<java.net.URI> getMessageURIsByParentURIAfter(@Param(value="parent")
java.net.URI parentURI,
@Param(value="referenceDate")
java.util.Date referenceDate,
org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and msg.creationDate > :referenceDate") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAfter(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceDate") java.util.Date referenceDate, org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg left join fetch msg.datasetHolder where msg.parentURI = :parent and msg.creationDate > :referenceDate") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAfterFetchDatasetEagerly(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceDate") java.util.Date referenceDate, org.springframework.data.domain.Pageable pageable)
@Query(value="select messageURI from MessageEvent msg where msg.parentURI = :parent and msg.creationDate > :referenceDate and msg.messageType = :messageType")
org.springframework.data.domain.Slice<java.net.URI> getMessageURIsByParentURIAfter(@Param(value="parent")
java.net.URI parentURI,
@Param(value="referenceDate")
java.util.Date referenceDate,
@Param(value="messageType")
WonMessageType messageType,
org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg left join fetch msg.datasetHolder where msg.parentURI = :parent and msg.creationDate > :referenceDate and msg.messageType = :messageType") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAndTypeAfter(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceDate") java.util.Date referenceDate, @Param(value="messageType") WonMessageType messageType, org.springframework.data.domain.Pageable pageable)
@Query(value="select msg from MessageEvent msg where msg.parentURI = :parent and msg.creationDate > :referenceDate and msg.messageType = :messageType") org.springframework.data.domain.Slice<MessageEvent> findByParentURIAndTypeAfterFetchDatasetEagerly(@Param(value="parent") java.net.URI parentURI, @Param(value="referenceDate") java.util.Date referenceDate, @Param(value="messageType") WonMessageType messageType, org.springframework.data.domain.Pageable pageable)
@Query(value="select max(msg.creationDate) from MessageEvent msg where msg.creationDate <= :referenceDate and parentURI = :parent")
java.util.Date findMaxActivityDateOfParentAtTime(@Param(value="parent")
java.net.URI parentURI,
@Param(value="referenceDate")
java.util.Date referenceDate)
@Query(value="select max(msg.creationDate) from MessageEvent msg where msg.creationDate <= :referenceDate and parentURI = :parent and msg.messageType = :messageType")
java.util.Date findMaxActivityDateOfParentAtTime(@Param(value="parent")
java.net.URI parentURI,
@Param(value="messageType")
WonMessageType messageType,
@Param(value="referenceDate")
java.util.Date referenceDate)
void deleteByParentURI(java.net.URI parentUri)
Copyright © 2020. All Rights Reserved.