Room是google在Architecture Components
提出的一个持久化库，可以异步查询返回LiveData和Rxjava里的Maybe,Single,Flowable,其中LiveData和Flowable是可观测的查询。它们允许自动从数据库更新数据，从而刷新UI。

可以在UserDao里这么写，

@Query(“SELECT * FROM Users WHERE id = :userId”)
User getUserById(String userId);

但他有两个缺点：
1、这是同步的，所以会阻塞。
2、当user被修改的时候，我们总是需要手动调用这个方法。

在返回Maybe或Single的时候，确保subscribeOn调用了Scheduler的不同线程，而不是AndroidSchedulers.mainThread()

若想加上room对rxjava的支持，需要在build.gradle中添加以下内容

// RxJava support for Room
implementation “android.arch.persistence.room:rxjava2:1.0.0-alpha5”
// Testing support
androidTestImplementation “android.arch.core:core-testing:1.0.0-alpha5”

Maybe

@Query(“SELECT * FROM Users WHERE id = :userId”)
Maybe<User> getUserById(String userId);

来说说发生了啥：
1、当数据库里没有这条数据的时候，Maybe会直接onComplete()。
2、当有这条数据的时候，Maybe会触发onSuccess，然后会正常的onComplete()。
3、当数据在Maybe的onCompleted()后进行了更新，那就什么都不会发生了。

Single

@Query(“SELECT * FROM Users WHERE id = :userId”)
Single<User> getUserById(String userId);

1、当数据库里没有这条数据的时候，Single会直接onError(EmptyResultSetException.class)。
2、当有这条数据的时候，Single会触发onSuccess。
3、当数据在Single.onCompleted()后进行了更新，那就什么都不会发生了,自流被关闭后。

Flowable

@Query(“SELECT * FROM Users WHERE id = :userId”)
Flowable<User> getUserById(String userId);

1、当数据库里没有这条数据的时候，Flowable不会发射，当然也就不会有onNext和onError。
2、当有这条数据的时候，Flowable会触发onNext。
3、任何时候数据被更新了，Flowable会自动发射来让你用最新的数据来更新UI。

Room and RxJava ， google写了个简单的 例子

over~