RxJava 2 与 Room 查询实操

186 阅读 0 评论 123 点赞

我是靠谱客的博主谨慎台灯，这篇文章主要介绍RxJava 2 与 Room 查询实操，现在分享给大家，希望可以做个参考。

从上一篇Room & RxJava 的使用引申而来的代码实际操作。

1. 定义一个数据库接口

@Dao
public interface UserDao {
    @Query("select * from user")
    Flowable<List<UserEntity>> getUsers();

    @Query("select * from user limit 1")
    Flowable<UserEntity> getUser();
}

2. 查询数据库

// ViewModel/DataRepository类：

public Flowable<List<UserEntity>> getUsers(){
        return database.userDao().getUsers();
    }

database为AppDatabase类，继承RoomDatabase。详见BasicSample中的AppDatabase类。

3. 在UI中引用

// Activity 或 Fragment类：

 userViewModel.getUsers()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<List<UserEntity>>() {
                    @Override
                    public void accept(List<UserEntity> entities) throws Exception {
                        adapter.setList(entities);
                    }
                })
        ;