会议室数据库插入或更新但保留数据库字段？

Question

我试图实现以下场景 - >记录从API获取并存储到DB中.有些记录可能会被点击favorite,即使从API获取新数据,它们仍应保持这样.但是,我似乎找不到如何在不替换favorite整行的情况下替换那些已经被选中的记录的方法.我已经尝试逐个插入记录,并以某种方式在插入检查是否已经存在记录,但我似乎无法用RxJava来解决它.

Dao

    @Dao
    interface KafanaDao {

    @Insert
    fun insertSingleKafana(kafana: Kafana)

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    fun insertAll(kafani: List<Kafana>)

    @Query("SELECT * FROM ${Constants.KAFANI_TABLE_NAME}")
    fun getKafani(): Single<List<Kafana>>

    @Query("SELECT * FROM ${Constants.KAFANI_TABLE_NAME} WHERE name = :name")
    fun getSingleKafana(name: String): Single<Kafana>

    @Query("UPDATE ${Constants.KAFANI_TABLE_NAME} SET isFavorite = :isFavorite WHERE name = :name")
    fun setFavourite(name: String, isFavorite: Int)
}

然后我一个接一个地插入记录,但是如何检查它们是否已经存储在数据库中？

fun insertSingleKafanaInDb(kafana: Kafana) {
    Observable.fromCallable { kafanaDao.insertSingleKafana(kafana) }
            .subscribeOn(Schedulers.io())
            .subscribe {
                Timber.d("Inserted ${kafana.name} kafani from API in DB...")
            }
}

fun getKafaniFromApi(): Observable<List<Kafana>> {
    return apiService.getKafani().toObservable().doOnNext {
        for (kafana in it) {
            //I need to somehow do the check here
            insertSingleKafanaInDb(kafana)
        }
    }
}

Entity

    @Entity(tableName = Constants.KAFANI_TABLE_NAME)
    data class Kafana(
        @PrimaryKey
        @ColumnInfo(name = "name")
        @SerializedName("name")
        val name: String,
        @ColumnInfo(name = "phone")
        @SerializedName("phone")
        val phone: String,
        @ColumnInfo(name = "address")
        @SerializedName("address")
        val address: String,
        @ColumnInfo(name = "city")
        @SerializedName("city")
        val city: String,
        @ColumnInfo(name = "sponsored")
        @SerializedName("sponsored")
        val isSponsored: Boolean,
        @ColumnInfo(name = "isFavorite")
        var isFavorite: Boolean

)

Answer 1

可以通过两种方法完成

第一个：- 在插入 Kafane 之前，您查询 getSingleKafana(name: String): Single 并从数据库中获取它（如果它可用）并获取最喜欢的状态并将此最喜欢的字段设置为来自 API 的新 KAFANA 对象。

第二个：做一个查询，它会返回 KAFANA 对象列表，最喜欢的对象为真，结果将列表，在从 API 插入新的 KAFANA 之前检查 kafana 是否出现在列表中。

Room 不支持任何条件插入查询。它将插入整个对象。