使用RxJava在主线程室中执行delete

Question

我使用的房间用于存储有关购物车详细信息。

我想删除主线程中的记录。我出错了

无法访问主线程上的数据库，因为它可能会长时间锁定

我检查了下面的链接，但没有帮助我

使用room（rxjava）执行删除

如何在android room和rxjava 2中插入数据并获取id作为out参数？

道阿ccess.java

    @Dao
    public interface DaoAccess {

        @Insert
        void insertMultipleRecord(DBProducts... universities);

        @Insert
        void insertMultipleListRecord(List<DBProducts> universities);

        @Insert
        void insertOnlySingleRecord(DBProducts university);


        @Query("SELECT * FROM DBProducts")
        LiveData<List<DBProducts>> fetchAllData();


        @Update
        void updateRecord(DBProducts university);

        @Delete
        void deleteRecord(DBProducts university);
    }

应用班

    public class PRApp extends Application {
        private static PRApp m_instance;
        DBHelper dbHelper;

        @Override
        public void onCreate() {
            super.onCreate();
            mInstance = this;
            prefs = new PRPrefs(this);
            m_instance = this;

            sDefSystemLanguage = Locale.getDefault().getLanguage();
            switch (sDefSystemLanguage) {
                case "en":
                    sDefSystemLanguageCode = "1";
                    break;
                case "ar":
                    sDefSystemLanguageCode = "2";
                    break;
                default:
                    sDefSystemLanguageCode = "3";
                    break;
            }
        }


        public DBHelper getRoomDB() {
            dbHelper = Room.databaseBuilder(getApplicationContext(),
                    DBHelper.class, "prasukh-db").build();
            return dbHelper;

        }



    }

我的异步任务正在工作

    new AsyncTask<Void, Void, Integer>() {
                    @Override
                    protected Integer doInBackground(Void... params) {
                        PRApp.getInstance().getRoomDB().daoAccess().deleteRecord(products.get(position));
                        return 0;
                    }

                    @Override
                    protected void onPostExecute(Integer agentsCount) {
                        Utilities.decrementBadegeCount();
                        productsArrayList.remove(position);
                        cardAdapter.notifyDataSetChanged();
                        notifyDataSetChanged();
                        hideProgressDialog();
                        setCartLayout();
                    }
                }.execute();

如何在RxJava中实现这一点。因为我的DAO删除返回无效？

Answer 1

使用可调用的运算符。

Observable.fromCallable(() -> {
    PRApp.getInstance().getRoomDB().daoAccess().deleteRecord(products.get(position));
    return true;
}).firstOrError()
     .subscribeOn(Schedulers.io())
     .observeOn(AndroidSchedulers.mainThread())
     .subscribe(new SingleObserver<List<String>>() {

          @Override
          public void onSubscribe(Disposable d) {

          }

          @Override
          public void onSuccess(List<String> strings) {

          }

          @Override
          public void onError(Throwable e) {

          }

      });
      // or only
      .subscribe()
      // But if an error occurred  in delete operation the app will crash

这将执行删除操作并生成可观察的

或者，您可以使用

Room.databaseBuilder(getApplicationContext(),DBHelper.class, "prasukh-db")
        .allowMainThreadQueries()
        .build();

但这是因为表演而不被鼓励的。