使用不同线程的领域事务

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

我认为你只是在寻找

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; 
} 

如果你需要一些解释相关，只是告诉我，我会实现它:)

PS：如果我missunderstood你的问题，让我知道！

Answer 3

异步事务支持的工作方式与当前executeTransaction相同，但不是在同一个线程上打开Realm，它会为您提供在不同线程上打开的背景Realm。如果您希望在事务完成或失败时收到通知，您还可以注册回调。

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; 
     } 
    }); 
} 

您订阅返回所需的线程/程序器Flowable到特定线程上执行事务。