如何使用房间Db返回Rx单笔交易？

Question

假设有一个具有以下两种方法的Dao类：

（1）

delete(items: List<Item>): Completable

（2）

 insert(items: List< Item >): Single<List<Long>>

如何将它们链接到Dao类中的一个事务方法中，从“delete method”开始，然后返回“insert method”结果？

我想要一个签名如下的方法：

@Transaction
fun deleteAndInsert(): Single<List<Long> > {
    ...
}

Answer 1

>

用@Transaction注释的方法不能返回延迟/异步返回类型io。反应性X。仅有一个的由于事务是线程受限的，Room不能保证方法实现中的所有查询都在同一线程上执行，因此只允许同步@事务实现的方法。如果启动了一个事务，并且更改了线程并等待，那么如果其他线程尝试执行查询，则可能会发生数据库死锁。这种限制可防止此类情况发生

当我将代码反编译为java时，我看到了。

public interface CustomerDao {
@Transaction
@NotNull
List deleteAndCreate(@NotNull List var1);

@Query("DELETE FROM customer")
@NotNull
Completable deleteAll();

@Insert
@NotNull
List insertAll(@NotNull List var1);

@Metadata(
   mv = {1, 1, 15},
   bv = {1, 0, 3},
   k = 3
)
public static final class DefaultImpls {
   @Transaction
   @NotNull
   public static List deleteAndCreate(CustomerDao $this, @NotNull List 
     users) 
   {
      Intrinsics.checkParameterIsNotNull(users, "users");
      $this.deleteAll();
      return $this.insertAll(users);
   }
}
}

Answer 2

我觉得不太可能。

我曾经尝试过它，但我得到了一个编译时错误：

“带有@Transaction注释的方法不能返回延迟/异步返回类型io.reactivex.Single。由于事务是线程限制的，并且Room不能保证方法实现中的所有查询都在同一线程上执行，因此只允许同步的@Transaction实现的方法。如果启动了事务并更改了线程，然后等待数据库如果其他线程尝试执行查询，则可能会发生死锁。此限制可防止发生此类情况。“”

Answer 3

我假设您的主要目标是将deleteAndInert（）的返回类型设置为单。

您可以实现这一点与小修改

• 首先通过使delete（）和插入（）函数同步。
• 由于@Transaction只能同步工作，我们需要创建另一个函数来调用delete（）和插入（）。此外，使用@Transaction
注释此函数
• 创建另一个新函数，该函数创建单并调用上述函数。

abstract class SampleDao{
    protected abstract fun delete()
    protected abstract fun insert(items: List<Item>) : List<Long>

    @Transaction
    protected open fun deleteAndInsertSync(items: List<Item>): List<Long>{
        delete()
        return insert(items)
    }

    fun deleteAndInsert(items:List<Item>): Single<List<Long>>{
        return Single.create {
            it.onSuccess(deleteAndInsertSync(items))
        }
    }
}