领域.io [Java] notifications -如何侦听特定表的更改

Question

我在realm java文档中看到了这个示例代码。

public class MyActivity extends Activity {
    private Realm realm;
    // A reference to RealmChangeListener needs to be held to avoid being
    // removed by the garbage collector.
    private RealmChangeListener realmListener;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
      super.onCreate(savedInstanceState);
      realm = Realm.getDefaultInstance();
      reamlListener = new RealmChangeListener() {
        @Override
        public void onChange() {
            // ... do something with the updates (UI, etc.) ...
        }};
      realm.addChangeListener(realmListener);
    }
    @Override
    protected void onDestroy() {
        super.onDestroy();
        // Remove the listener.
        realm.removeChangeListener(realmListener);
        // Close the realm instance.
        realm.close();
    }
}

我有一些数据库模式包含几个表。这些表中的数据总是在变化，但我只有一个表，我需要监听和刷新与这个表相关的UI。我不想检查在任何其他领域对象的任何小更新后，Realm中的这些变化是否完全在通缉表中。您能建议哪些最佳实践?

Answer 1

在Realm具有细粒度通知之前，我会通过使用contenttobserver、RxJava或您自己的Observer接口来实现我自己的通知系统。

Answer 2

正如Christian所说，RxJava可以提供帮助。当然，这是一个可能需要对代码进行重大更改的概念，而不是对问题的具体和快速解决方案。在任何情况下，用于访问数据库的存储库模式都是很好的实践。您可以使用自己的层访问Realm。在这种情况下，您可以控制对Realm的查询，并在数据更改时通知观察者。

    public interface RealmRepository {
            <T> Observable<T> get(Class clazz, Func1<RealmQuery, RealmQuery> predicate);
            void storeObject(Class clazz, JSONObject jsonObject);
            void storeObjects(Class clazz, JSONArray jsonArray);
            <T> Observable<T> update(Class clazz, Action0 action);
         }

使用Realm接口存储库允许您确保控制所有请求。

现在你将得到Observable<T>对象，可以通知如果数据改变。

    public class RealmRepositoryImpl implements RealmRepository {
    Realm realm;
    RealmQueryableCollection realmQueryCollection;
    public RealmRepositoryImpl(Realm realm) {
        this.realm = realm;
        this.realmQueryCollection = new RealmQueryableCollection();
    }
    @Override
    public <T> Observable<T> get(Class clazz, Func1<RealmQuery, RealmQuery> predicate) {
        BehaviorSubject<T> behaviorSubject = BehaviorSubject.create((T) getInner(clazz, predicate));
        realmQueryCollection.add(clazz, predicate, behaviorSubject);
        return behaviorSubject;
    }
    public <T extends RealmObject> RealmResults<T> getInner(Class clazz, Func1<RealmQuery, RealmQuery> predicate) {
        RealmQuery query = realm.where(clazz);
        if (predicate != null)
            query = predicate.call(query);
        return query.findAll();
    }
    @Override
    public void storeObject(Class clazz, JSONObject jsonObject) {
        realm.beginTransaction();
        realm.createOrUpdateObjectFromJson(clazz, jsonObject);
        realm.commitTransaction();
        notifyObservers(clazz);
    }
    @Override
    public void storeObjects(Class clazz, JSONArray jsonArray) {
        realm.beginTransaction();
        realm.createOrUpdateAllFromJson(clazz, jsonArray);
        realm.commitTransaction();
        notifyObservers(clazz);
    }

    @Override
    public <T> Observable<T> update(Class clazz, Action0 action) {
        return (Observable<T>) Observable.create(subscriber -> {
            realm.beginTransaction();
            action.call();
        }).doOnNext(o -> {
            realm.commitTransaction();
            notifyObservers(clazz);
        });
    }
    private void notifyObservers(Class clazz) {
        Observable.from(realmQueryCollection.getQuerables(clazz))
                .subscribe(realmQuerable ->
                        realmQuerable.getSubject().onNext(getInner(clazz, realmQuerable.getPredicate())));
    }
}

制作get query时，您只需保存实体(表)，谓词(nice rx.functions.Func1)和主题。当您要更改Realm中的数据时，您可以使用保存的谓词获取更改的数据，并通知所有观察者。

示例get query

public Observable<List<Event>> getEvents() {
        return realmRepository.get(Event.class, predicate -> predicate
                        .equalTo("category", "Art")
                        .or()
                        .equalTo("category", "Music"));
    }

我认为被动的方法是解决这个问题的自然方法。

完整的示例代码在GitHub上，你可以试着玩的例子。目前，这还不是一个完整的解决方案(没有通知退订等)，而只是一个想法。