異なるスレッドからのレルムトランザクション

Question

私は頻繁に使うwriteToRealmメソッドを持っています。そして、私は別のスレッドからそれを使用し、定型コードをカットする必要があります。この仕事のためのより良い方法は何ですか？

private boolean writeToRealm(String user, String id) { 

     SubscriberObject subscriber = new SubscriberObject(); 

     if(mRealm.where(SubscriberObject.class) 
       .equalTo(SubscriberObject.ID,id).findAll().isEmpty() 
       &&mRealm.where(SubscriberObject.class) 
       .equalTo(SubscriberObject.USERNAME,user).findAll().isEmpty()) { 
      subscriber.setId(id); 
      subscriber.setUsername(user); 
      mRealm.beginTransaction(); 
      mRealm.insert(subscriber); 
      mRealm.commitTransaction(); 
      return true; 
     } 
     return false; 

}

私は以下の構造（またはこのようなもの）を使用する予定ですが、私は、正しい施工を作成することはできません：私は作成する必要が

public static Boolean writeToRealm(final String user,final String id){ 
     Realm mRealm; 
     return Flowable.using(
       mRealm = Realm.getDefaultInstance(), 
       new Function<Realm, Boolean>() { 
        @Override 
        public Boolean apply(@NonNull Realm realm) throws Exception { 
         SubscriberObject subscriber = new SubscriberObject(); 
         if(realm.where(SubscriberObject.class) 
           .equalTo(SubscriberObject.ID,id).findAll().isEmpty() 
           &&realm.where(SubscriberObject.class) 
           .equalTo(SubscriberObject.USERNAME,user).findAll().isEmpty()) { 
          subscriber.setId(id); 
          subscriber.setUsername(user); 
          realm.beginTransaction(); 
          realm.insert(subscriber); 
          realm.commitTransaction(); 
          return true; 
         } 
         return false; 
        } 
       }, 
       mRealm.close()).subscribeOn(Schedulers.io()); 
    } 

であってもよいしこのタスクのためにルーパーを持つスレッドクラス？

この方法と同様の方法をクリーンなアーキテクチャに統合する方法を教えてください。

Answer 1

私はあなただけで、またexecuteTransaction（）を使用して好むください

private boolean writeToRealm(String user, String id) { 
    try(Realm realm = Realm.getDefaultInstance()) {   
     if(realm.where(SubscriberObject.class).equalTo(SubscriberObject.ID,id).count() <= 0L 
       && realm.where(SubscriberObject.class).equalTo(SubscriberObject.USERNAME,user).count() <= 0L) { 
      final SubscriberObject subscriber = new SubscriberObject(); 
      subscriber.setId(id); 
      subscriber.setUsername(user); 
      realm.executeTransaction(r -> r.insert(subscriber)); 
      return true; 
     } 
    } 
    return false; 
} 

Answer 2

私はこれが道に簡単解決策になると思う：

public static Boolean writeToRealm(String user, String id) { 
    Realm realm = Realm.getDefaultInstance(); 
    SubscriberObject subscriber = new SubscriberObject(); 
    if (realm.where(SubscriberObject.class).equalTo("ID", id).or().equalTo("USERNAME", user).findAll().isEmpty()){ 
     subscriber.setId(id); 
     subscriber.setUsername(user); 
     realm.beginTransaction(); 
     realm.insert(subscriber); 
     realm.commitTransaction(); 
     realm.close(); 
     return true; 
    } 
    realm.close(); 
    return false; 
} 

あなたには、いくつかのexplainationsが必要な場合は、ちょうど私が言うと、私はそれを実装します:)

PSを：私はあなたの質問をmissunderstood場合、聞かせて私は知っている！

Answer 3

非同期トランザクションのサポートは現在executeTransactionとしてではなく、代わりに同じスレッドでレルムを開くのと同じように動作し、それがバックグラウンド・レルムが別のスレッドで開かれたあなたを与えるだろう。また、トランザクションの完了時または失敗時に通知を受けたい場合は、コールバックを登録することもできます。

realm.executeTransactionAsync(new Realm.Transaction() { 
    @Override 
    public void execute(Realm realm) { 
     Dog dog = realm.where(Dog.class).equalTo("age", 1).findFirst(); 
     dog.setName("Fido"); 
    } 
}, new Realm.Transaction.OnSuccess() { 
    @Override 
    public void onSuccess() { 
     Log.d("REALM", "All done updating."); 
     Log.d("BG", t.getName()); 
    } 
}, new Realm.Transaction.OnError() { 
    @Override 
    public void onError(Throwable error) { 
     // transaction is automatically rolled-back, do any cleanup here 
    } 
}); 

read more

Answer 4

あなたが非同期的にお取引を行いたい場合は、boolean戻り値の型を持つことはできませんまず第一に。 Interfaceの結果を呼び出し元に返すか、RxJavaのような他の手段を選択する必要があります。

あなたに例を挙げてください。

RxJavaの方法（これは最も簡単な方法だろうと）：

public static Flowable<Boolean> writeToRealm(final String user,final String id) { 
    return Flowable.fromCallable(
     new Callable<Boolean>() { 
      @Override 
      public Boolean call() throws Exception { 
       Realm realm = Realm.getDefaultInstance(); 
       if(realm.where(SubscriberObject.class) 
        .equalTo(SubscriberObject.ID,id).findAll().isEmpty() 
        &&realm.where(SubscriberObject.class) 
        .equalTo(SubscriberObject.USERNAME,user).findAll().isEmpty()) { 
        SubscriberObject subscriber = new SubscriberObject(); 
        subscriber.setId(id); 
        subscriber.setUsername(user); 
        realm.beginTransaction(); 
        realm.insert(subscriber); 
        realm.commitTransaction(); 
        mRealm.close(); 
        return true; 
       } 
       mRealm.close(); 
       return false; 
     } 
    }); 
} 

あなたは、その特定のスレッド上でトランザクションを実行するために必要なスレッド/ schedularに返さFlowableをサブスクライブします。