使用Rxjava2操作Realm

最近项目需要使用Realm作为本地数据库，Realm作为移动端流行数据库框架之一，自身提供的API已经非常完善且使用简单，但作为使用了RxJava全家桶的项目，直接调用Realm的API总感觉有点不爽，
难道不能使用Rxjava来方便调用Realm吗？

google一下发现自己不是第一个有这种想法的人，已经有人实现了这个想法

使用Realm和RxJava打出组合拳的正确姿势

Realm Post

国内的文章也是参考国外某位大神的代码做出了一些修改，但由于文章较早，使用的Rxjava1，与项目使用的Rxjava2稍微有些区别，就花点时间将原代码改造
成了Rxjava2版本，方便以后使用。

源码已上传github：RxJavaToRealm

简单调用：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
/**
 * 增加
 */
private void add() {
    Random random = new Random();
    int i = random.nextInt(10000);
    final Student student = new Student();
    student.setId(i);
    student.setNanme("name " + i);
    student.setAge(i);
    RealmObservable
            .createObservable(new Function<Realm, Student>() {
                @Override
                public Student apply(Realm realm) throws Exception {
                    return realm.copyToRealm(student);
                }
            })
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Consumer<Student>() {
                @Override
                public void accept(Student s) throws Exception {
                    Log.d(TAG, "添加成功");
                    Toast.makeText(MainActivity.this, "添加成功！", Toast.LENGTH_SHORT).show();
                }
            }, new Consumer<Throwable>() {
                @Override
                public void accept(Throwable throwable) throws Exception {
                    Log.e(TAG, throwable.getMessage());
                }
            }, new Action() {
                @Override
                public void run() throws Exception {

                }
            });
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
/**
 * 查找
 */
private void find() {
    RealmObservable
            .createObservable(new Function<Realm, List<Student>>() {
                @Override
                public List<Student> apply(Realm realm) throws Exception {

                    RealmResults<Student> all = realm.where(Student.class).findAll();
                    return realm.copyFromRealm(all);
                }
            })
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Consumer<List<Student>>() {
                @Override
                public void accept(List<Student> students) throws Exception {
                    tv.setText(students.toString());
                }
            }, new Consumer<Throwable>() {
                @Override
                public void accept(Throwable throwable) throws Exception {

                }
            });
}