diff --git a/app/src/main/kotlin/com/simplemobiletools/smsmessenger/extensions/Context.kt b/app/src/main/kotlin/com/simplemobiletools/smsmessenger/extensions/Context.kt
index 230bc686..d3beb6e2 100644
--- a/app/src/main/kotlin/com/simplemobiletools/smsmessenger/extensions/Context.kt
+++ b/app/src/main/kotlin/com/simplemobiletools/smsmessenger/extensions/Context.kt
@@ -524,6 +524,7 @@ fun Context.markMessageRead(id: Long, isMMS: Boolean) {
     val selection = "${Sms._ID} = ?"
     val selectionArgs = arrayOf(id.toString())
     contentResolver.update(uri, contentValues, selection, selectionArgs)
+    messagesDB.markRead(id)
 }
 
 fun Context.markThreadMessagesRead(threadId: Long) {
@@ -536,6 +537,7 @@ fun Context.markThreadMessagesRead(threadId: Long) {
         val selectionArgs = arrayOf(threadId.toString())
         contentResolver.update(uri, contentValues, selection, selectionArgs)
     }
+    messagesDB.markThreadRead(threadId)
 }
 
 fun Context.markThreadMessagesUnread(threadId: Long) {
diff --git a/app/src/main/kotlin/com/simplemobiletools/smsmessenger/interfaces/MessagesDao.kt b/app/src/main/kotlin/com/simplemobiletools/smsmessenger/interfaces/MessagesDao.kt
index c8422f3e..4e25bd99 100644
--- a/app/src/main/kotlin/com/simplemobiletools/smsmessenger/interfaces/MessagesDao.kt
+++ b/app/src/main/kotlin/com/simplemobiletools/smsmessenger/interfaces/MessagesDao.kt
@@ -19,4 +19,10 @@ interface MessagesDao {
 
     @Query("SELECT * FROM messages WHERE thread_id = :threadId")
     fun getThreadMessages(threadId: Long): List<Message>
+
+    @Query("UPDATE messages SET read = 1 WHERE id = :id")
+    fun markRead(id: Long)
+
+    @Query("UPDATE messages SET read = 1 WHERE thread_id = :threadId")
+    fun markThreadRead(threadId: Long)
 }