代码之家 › 专栏 › 技术社区 › Mosius sMiLo

Android:使用Room和RxJava检查数据库中是否存在对象

android-room rx-java kotlin android

Mosius sMiLo · 技术社区 · 6 年前

Room 作为ORM,下面是我的Dao接口:

@Dao
interface UserDao {
    @Query(value = "SELECT * FROM User LIMIT 1")
    fun get(): Single<User?>

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    fun add(profile: User)
}

另一方面,我在存储库中有一个方法可以检查用户是否登录,下面是实现代码:

override fun isUserLogin(): Single<Boolean> = userDao
            .get().async()
            .onErrorReturn { null }
            .map { it != null }

查询返回空结果集:SELECT*FROM User LIMIT 1

我想回来 null 在本例中,但当我执行代码时,它会引发一个异常,消息如下:

我不能用 Optional 因为道回来了 Single<User?> 所以 onErrorReturn 应该返回相同的类型。

如何在不改变Dao的情况下检查用户是否存在?

3 回复 | 直到 6 年前

lelloman 6 年前

COUNT

@Query("SELECT COUNT(*) from User")
fun usersCount() : Single<Int>

它将返回表中的行数,如果为0,则表示数据库中没有用户,因此。

override fun isUserLogin(): Single<Int> = userDao
            .usersCount()
            .async()
            .map { it > 0 }

如果你真的想用丑陋的方式去做:

@Query(value = "SELECT * FROM User LIMIT 1")
fun get(): Single<User>

不要使用可为null的类型,这是毫无意义的。然后映射到Boolean并处理异常:

override fun isUserLogin(): Single<Boolean> = userDao
        .get()
        .async()
        .map { true }
        .onErrorReturn { false }

Kiskae 6 年前

使用 Maybe ,它准确地模拟了预期0个结果、1个结果或异常的响应。

Chris 6 年前

如果将DAO更改为返回一个可流动的用户列表,则可以通过检查列表的大小将其映射为布尔值。

@Query(value = "SELECT * FROM User LIMIT 1")
fun get(): Flowable<List<User>>

fun isUserLogin(): Single<Boolean> = userDao
    .get()
    .flatMapSingle { Single.just(it.size == 1) }
    .onErrorReturn { false }
    .first(false)

推荐文章

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

7 年前

Myk Willis · 将具有指定泛型列表类型的Observable作为方法参数传递

7 年前

Mangat Rai Modi · 垂直。x反应式卡夫卡客户端:编写时链接不起作用?

7 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

7 年前

Jhon Fredy Trujillo Ortega · 如何在平面图中使用等待方法?

7 年前

casolorz · 可合成。清除导致OkHttp抛出java。lang.IllegalStateException:输入/退出不平衡

7 年前

O10 · 与observeOn组合时,RxJava启动时忽略运算符

7 年前

ddinchev · RxJava2并行执行一组completable并等待全部完成

7 年前

advice · RxJava-捕获使用者异常

7 年前

Daksh · 条件链单链和完全链

7 年前