NewPostDao.kt

@Dao
interface NewPostDao {
    @Query("SELECT * FROM `new_post`")
    fun getAll(): Observable<List<NewPost>>

    @Query("SELECT * FROM `new_post` WHERE `id` = :id")
    fun getPostById(id: String): Observable<NewPost>

    @Insert(onConflict = OnConflictStrategy.IGNORE)
    fun insertNewPost(newPost: NewPost): Long

    @Update(onConflict = OnConflictStrategy.REPLACE)
    fun updateNewPost(newPost: NewPost)

    @Delete
    fun deleteNewPost(newPost: NewPost)

    @Transaction
    fun upsert(newPost: NewPost) {
        if (-1L == insertNewPost(newPost)) {
            updateNewPost(newPost)
        }
    }
}