如何使用Android Room进行单行查询

Question

如何使用RxJava的Android Room进行单行查询？我可以查询项目列表，没有问题。这里，我想找出是否存在特定的行。根据文档，如果不存在行，我可以返回Single并检查EmptyResultSetException异常。

我可以吃一些类似的东西：

@Query("SELECT * FROM Users WHERE userId = :id LIMIT 1")
Single<User> findByUserId(String userId);

如何使用此呼叫？看起来有一些onError/onSuccess，但在单个上找不到这些方法

usersDao.findByUserId("xxx").???

任何可行的例子都会很好！

Answer 1

根据文档，如果不存在行，我可以返回Single并检查EmptyResultSetException异常。

或者，如果您通过其他方式处理后台线程，只需返回User。

@Query("SELECT * FROM Users WHERE userId = :id")
User findByUserId(String id);

如何使用此呼叫？

usersDao.findByUserId("xxx")
  .subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .subscribe(user -> { ... }, error -> { ... });

这里，我为用户和错误显示了两个lambda表达式。您可以使用两个消费者对象。我还假设您对androidscheduler具有依赖关系rxandroid。mainThread（），并且您希望用户在该线程上传递给您。

IOW，您使用它的方式与使用RxJava中的任何其他单的方式相同。详细信息将根据您的需求而有所不同。