RxJava & Room

译文:原文地址

更少的公式化代码,更少的SQL语句的编译时间,更少的基于SQL的异步观测查询语句的编译时间---

听上去怎么样?这些在Room数据库(来自架构组件的持续库)中都可以实现。异步查询返回的LiveData、RxJava中的Maybe、Single或者Flowable对象。返回LiveData和Flowable对象的都是可观测对象。他们可以做到无论什么时候你的数据发生改变了,UI都会及时响应实时的数据中的数据的变化。如果你已经在自己的app中使用了RxJava2,那么使用Rooom和Maybe、Single、Flowable就很轻而易举了。


让我们来思考这样一个UI情况:用户在界面上可以看到并且编辑自己的用户名。

这个用户名和用户的其他信息一样都会被保存到数据库中。

为了可以获得User这个对象我们需要在UserDao中使用这样的查询语句:

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

这样的方式有两个缺点:

1.这是一个阻塞的同步的调用

2.在用户数据发生改变的时候需要我们手动调用这个方法来进行更新

Room提供了使用RxJava中的Single、Flowable、Maybe对象的异步查询的方法,来实现观察者模式。(一个目标物件管理所有相依于它的观察者物件,并且在它本身的状态改变时主动发出通知)

如果你还在担心线程的问题,放一百八十个心吧。Room并不是在主线程中调用观察查询的。通过在Scheduler和observeOn方法中设置,你完全可以操控发射给下流的的数据在哪个线程中运行。

对于返回Maybe和Single的查询语句,请确保你的subscribeOn使用的Scheduler不是AndroidSchedulers.mainThread()

如果要和 Room一起使用RxJava2,那么就在自己项目的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就会被complete(RxJava中概念)

2.若数据库中有一个用户,那么Maybe就会触发onSuccess方法并且被complete

3.若数据库中用户信息在Maybe被complete之后被更新了,啥都不会发生


Single

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

就会发生这些事情:

1.若数据库中没有用户,那么Single就会触发onError(EmptyResultSetException.class)

2.若数据库中有一个用户,那么Single就会触发onSuccess

3.若数据库中用户信息在Single.onComplete调用之后被更新了,啥都不会发生,因为数据流已经完成了


Flowable

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

Flowable会这样运行:

1.若数据库中没有用户,那么Flowable就不会发射事件,既不运行onNext,也不运行onError

2.若数据库中有一个用户,那么Flowable就会触发onNext

3.若数据库中用户信息被更新了,Flowable就会自动发射事件,允许你根据更新的数据来更新UI界面


测试

测试一个返回Maybe/Single/Flowable的查询和测试同步查询并没有什么两样。在UserDaoTest中,要确定我们使用的是内存数据库,因为在进程被销毁的时候保存在这里的数据就会被自动清理。

@RunWith(AndroidJUnit4.class)
public class UserDaoTest {
…
private UsersDatabase mDatabase;
@Before
public void initDb() throws Exception {
    mDatabase = Room.inMemoryDatabaseBuilder(
                     InstrumentationRegistry.getContext(),
                     UsersDatabase.class)
            // allowing main thread queries, just for testing
            .allowMainThreadQueries()
            .build();
}

@After
public void closeDb() throws Exception {
    mDatabase.close();
}

在你的test中增加InstantTaskExecutorRule规则,确保Room被迅速执行。

@Rule
public InstantTaskExecutorRule instantTaskExecutorRule = 
                                      new InstantTaskExecutorRule();

在这个测试中,我们来订阅getUserById的发射事件,并且确保用户信息被新增了,被Flowable对象发射的。

@Test
public void insertAndGetUserById() {
    // Given that we have a user in the data source
    mDatabase.userDao().insertUser(USER);
    // When subscribing to the emissions of user
    mDatabase.userDao()
             .getUserById(USER.getId())
             .test()
             // assertValue asserts that there was only one emission
             .assertValue(new Predicate<User>() {
                @Override
                public boolean test(User user) throws Exception {
                    // The emitted user is the expected one
                    return user.getId().equals(USER.getId()) &&
                      user.getUserName().equals(USER.getUserName());
                }
            });
}

就是这样子啦!如果你在你的app中也使用了RxJava2,不妨试试响应式数据库,并且确保你的UI一直显示最新的数据,点击此处查看Room和RxJava的例子

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 213,047评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,807评论 3 386
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,501评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,839评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,951评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,117评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,188评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,929评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,372评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,679评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,837评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,536评论 4 335
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,168评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,886评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,129评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,665评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,739评论 2 351

推荐阅读更多精彩内容