|
|
@ -11,27 +11,18 @@ import org.springframework.stereotype.Repository; |
|
|
|
|
|
|
|
@Repository |
|
|
|
public interface ChatMessageRepository extends JpaRepository<ChatMessage, Long> { |
|
|
|
// @Query("select r from RoleRepository where name = ?1") |
|
|
|
// @Query("select ur from UserRole ur where ur.user.userID = ?1") |
|
|
|
// @Query("select m from ChatMessage m where m.toUser.userID = ?1 or m.toUser.userID = ?2 and " |
|
|
|
// + "m.fromUser.userID = ?1 or m.fromUser.userID = ?2 order by m.messageTime asc") |
|
|
|
@Query("select m from ChatMessage m join fetch m.messageCipher mc join fetch m.toUser tu join fetch m.fromUser fu " |
|
|
|
+ "where (tu.userName = ?1 or tu.userName = ?2) and " |
|
|
|
+ "(fu.userName = ?1 or fu.userName = ?2) order by m.messageTime asc") |
|
|
|
public List<ChatMessage> getAllMessages(String fromUser, String toUser); |
|
|
|
|
|
|
|
@Query("select m from ChatMessage m join fetch m.messageCipher where (m.toUser.userName = ?1 or m.toUser.userName = ?2) and " |
|
|
|
+ "(m.fromUser.userName = ?1 or m.fromUser.userName = ?2) and" |
|
|
|
+ "(m.messageTime > ?3) order by m.messageTime asc") |
|
|
|
|
|
|
|
@Query("select m from ChatMessage m join fetch m.messageCipher mc join fetch m.toUser tu join fetch m.fromUser fu " |
|
|
|
+ "where (tu.userName = ?1 or tu.userName = ?2) and " |
|
|
|
+ "(fu.userName = ?1 or fu.userName = ?2) and (m.messageTime > ?3) order by m.messageTime asc") |
|
|
|
public List<ChatMessage> getNewMessages(String fromUser, String toUser, Date lastMessageTime); |
|
|
|
|
|
|
|
@Query("select m from ChatMessage m join fetch m.messageCipher where (m.toUser.userName = ?1 or m.toUser.userName = ?2) and " |
|
|
|
+ "(m.fromUser.userName = ?1 or m.fromUser.userName = ?2) order by m.messageTime desc") |
|
|
|
|
|
|
|
@Query("select m from ChatMessage m join fetch m.messageCipher mc join fetch m.toUser tu join fetch m.fromUser fu " |
|
|
|
+ "where (tu.userName = ?1 or tu.userName = ?2) and " |
|
|
|
+ "(fu.userName = ?1 or fu.userName = ?2) order by m.messageTime desc") |
|
|
|
public List<ChatMessage> getAllMessages(String fromUser, String toUser, PageRequest pageRequest); |
|
|
|
|
|
|
|
|
|
|
|
// DELETE FROM Country c WHERE c.population < :p |
|
|
|
// @Query("delete from ChatMessage m where where (m.toUser.userName = ?1 or m.toUser.userName = ?2) and" |
|
|
|
// + " (m.fromUser.userName = ?1 or m.fromUser.userName = ?2)") |
|
|
|
// public void deleteConversation(String fromUser, String toUser); |
|
|
|
} |
|
|
|
} |