如何利用RxJava从Android Room数据库选择查询中获取返回

Question

这是我的问题

@Query("SELECT EXISTS(SELECT 1 FROM media2 WHERE path = :path AND isFav = 1 LIMIT 1)")
    int checkIsFav(String path);

从存储库调用

public boolean checkIsFav(String path) {
    return mDatabase.favDAO().checkIsFav(path) == 1;
}

这有时会导致以下错误

 java.lang.IllegalStateException: Cannot access database on the main thread since it may potentially lock the UI for a long period of time.

Observable.fromCallable(() -> mDatabase.favDAO().checkIsFav(path) == 1);

或

Observable.just(mDatabase)
    .subscribeOn(Schedulers.io())
    .subscribe(db -> db.favDAO().insertMedia2(media));

我正在我的片段中使用这个方法

if (mediaViewModel.checkIsFav(media.getPath())){
    mediaViewModel.removeFav(media.getPath());
} else {
    media.setFav(true);
    mediaViewModel.addFav(media);
}

和回收器适配器。

 boolean isfav = ((App)context.getApplicationContext()).getRepository()
     .checkIsFav(currentItem.getPath());

更新的问题与单人：

这是我在Dao中的查询

@Query("SELECT EXISTS(SELECT 1 FROM media2 WHERE path = :path AND isFav = 1 LIMIT 1)")
Single<Integer> checkIsFav(String path);

我在存储库中的方法

public Single<Integer> checkIsFav(String path){
    return mDatabase.favDAO().checkIsFav(path);
}

java prettyprint-override">((App)context.getApplicationContext()).getRepository().checkIsFav(media.getPath())
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread()).subscribe(
        new SingleObserver<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onSuccess(Integer integer) {

            }

            @Override
            public void onError(Throwable e) {

            }
        }
    );

if (App.favDB.existFav(currentItem.getPath()))

 public boolean existFav(String path) {
        SQLiteDatabase db = getReadableDatabase();
        Cursor cur = db.rawQuery(
            String.format("SELECT EXISTS(SELECT 1 FROM %s WHERE %s=? LIMIT 1)", TABLE_NAME, MEDIA_PATH),
            new String[]{ path });
        boolean tracked = cur.moveToFirst() &&  cur.getInt(0) == 1;
        cur.close();
        return tracked;
    }

也许我没有好好考虑这件事。

我要做的只是确定此介质是否存在于我的表中。

Answer 1

我认为你应该在主线程中观察你的数据。如此使用

observeOn(AndroidSchedulers.mainThread()).

尝试将其更改为

Observable.just(mDatabase)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread()) 
        .subscribe(db -> db.favDAO().insertMedia2(media));

另请参阅以下关于observeon()的注释