Mercury-IM/Mercury-IM
Mercury-IM
/
Mercury-IM
mirror of https://codeberg.org/Mercury-IM/Mercury-IM
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add comments to MessageDao

This commit is contained in:
Paul Schaub 2019-08-30 15:12:42 +02:00
parent d8f9a30585
commit d4fb389ee4
Signed by: vanitasvitae
GPG Key ID: 62BEE9264BF17311
1 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
persistence-room/src/main/java/org/mercury_im/messenger/persistence/room/dao/MessageDao.java
View File

@ -16,24 +16,35 @@ import io.reactivex.Observable;
@TypeConverters(EntityBareJidConverter.class)
public interface MessageDao extends BaseDao<RoomMessageModel> {
@Query("SELECT * FROM messages WHERE fk_account_id = :accountId ORDER BY send_date ASC")
@Query("SELECT * FROM messages " +
"WHERE fk_account_id = :accountId " +
"ORDER BY send_date ASC")
Observable<List<RoomMessageModel>> getAllMessagesOf(long accountId);
@Query("SELECT * FROM messages WHERE fk_account_id = :accountId AND `from` = :sender ORDER BY send_date ASC")
@Query("SELECT * FROM messages " +
"WHERE fk_account_id = :accountId AND `from` = :sender " +
"ORDER BY send_date ASC")
Observable<List<RoomMessageModel>> getAllMessagesFrom(long accountId, EntityBareJid sender);
@Query("SELECT * FROM messages WHERE fk_account_id = :accountId AND (`from` = :peer OR `to` = :peer) ORDER BY send_date ASC")
@Query("SELECT * FROM messages " +
"WHERE fk_account_id = :accountId AND (`from` = :peer OR `to` = :peer) " +
"ORDER BY send_date ASC")
Observable<List<RoomMessageModel>> getAllMessagesInConversation(long accountId, EntityBareJid peer);
@Query("SELECT * FROM messages WHERE body LIKE :query COLLATE utf8_general_ci")
@Query("SELECT * FROM messages " +
"WHERE body LIKE :query " +
"COLLATE utf8_general_ci") // case insensitive
Observable<List<RoomMessageModel>> findMessageByQuery(String query);
@Query("SELECT * FROM messages WHERE fk_account_id = :accountId AND body LIKE :query COLLATE utf8_general_ci")
@Query("SELECT * FROM messages " +
"WHERE fk_account_id = :accountId AND body LIKE :query " +
"COLLATE utf8_general_ci") // case insensitive
Observable<List<RoomMessageModel>> findMessageByQuery(long accountId, String query);
@Query("SELECT * FROM messages " +
"WHERE fk_account_id = :accountId " +
"AND (`from` = :peer OR `to` = :peer) " +
"AND body LIKE :query COLLATE utf8_general_ci")
"AND body LIKE :query " +
"COLLATE utf8_general_ci") // case insensitive
Observable<List<RoomMessageModel>> findMessageByQuery(long accountId, EntityBareJid peer, String query);
}