CODEWITHSUNDEEP
javakotlinandroid-room
Jurgiele
Jurgiele

Reputation: 95

How to find out if a record already exists in a room database

I moved from sql db to room. I can't figure out how to check if item exist in database. How to write this code using Room?

fun existsCheck(place: Places): Boolean {
    val db= this.readableDatabase
    val query = "SELECT * FROM $TABLE_PLACES WHERE $COLUMN_LAT = ${place.lat} AND $COLUMN_LNG = ${place.lng}"
    val cursor = db.rawQuery(query, null)
    if(cursor.count > 0){
        cursor.close()
        db.close()
        return true
    }
    cursor.close()
    db.close()
    return false
}

I have tried to achieve this with this code, but always getting FALSE back

@Query("SELECT name FROM place WHERE lat = :lat AND lng = :lng")
fun exist(lat: Double?, lng: Double?): Flowable<String>

override fun save() {
    Observable.just(dao)
            .subscribeOn(Schedulers.io())
            .subscribe {  dao.insert(place) }
}

override fun itemExists(lat: Double?, lng: Double?): Single<Boolean> =
        dao.exist(lat, lng)
                .flatMapSingle { Single.just(it.isNotEmpty()) }
                .onErrorReturn { false }
                .first(false)



override fun delete() {
    dao.deleteByLat(place.lat)
}

override fun saveClicked() {
    var boolean = false
     itemExists(place.lat, place.lng)
             .subscribeOn(Schedulers.io())
             .map { it -> boolean = it }
    if (boolean){
        delete()
        v.setImageNotSaved()
    } else {
        save()
        v.setImageSaved()
    }

}

Upvotes: 3

Views: 4353

Answers (1)

Jurgiele
Jurgiele

Reputation: 95

This works fine

 override fun itemExists() {
         Observable.just(dao)
                .subscribeOn(Schedulers.io())
                .subscribeOn(AndroidSchedulers.mainThread())
                 .map { it -> it.exist(place.lat, place.lng) }
                .subscribe( { it -> saveClicked(true) },
                        {error -> saveClicked(false)})
    }

Upvotes: 1

Related Questions