Room中UPDATE查询方法返回Flow<Int>不符合要求,如何解决?
解决Room UPDATE方法返回Flow的报错问题
报错原因
Room对更新/插入/删除这类写操作的返回值有明确限制:UPDATE方法只能返回void或Int(代表更新的行数),不能返回Flow<Int>。这是因为Flow用于监听持续的数据变化,而写操作是一次性执行的动作,不会持续发射数据,不符合Flow的使用场景。
解决方案
根据你的需求分两种情况处理:
情况1:仅需获取更新行数,无需监听数据变化
直接修改方法返回值为Int,如果在协程中调用,可添加suspend修饰符:
// 非协程调用 @Query("UPDATE releve SET accuracy_indicator = :isEnabled WHERE id_local = :releveId") fun updateAccuracyIndicator(releveId: Long, isEnabled: Boolean): Int // 协程调用(推荐) @Query("UPDATE releve SET accuracy_indicator = :isEnabled WHERE id_local = :releveId") suspend fun updateAccuracyIndicator(releveId: Long, isEnabled: Boolean): Int
情况2:需要监听目标数据的变化
将更新操作与数据监听拆分:
- 先实现更新方法(返回行数或void):
@Query("UPDATE releve SET accuracy_indicator = :isEnabled WHERE id_local = :releveId") suspend fun updateAccuracyIndicator(releveId: Long, isEnabled: Boolean): Int
- 单独写一个查询方法返回Flow,用于监听对应数据的变化:
@Query("SELECT accuracy_indicator FROM releve WHERE id_local = :releveId") fun getAccuracyIndicator(releveId: Long): Flow<Boolean>
调用时先执行更新操作,再通过getAccuracyIndicator的Flow监听数据变更。
补充说明
你的Room版本2.4.2及后续多数稳定版本都不支持写操作返回Flow,这是Room的设计规范——写操作是一次性执行的命令,而Flow用于订阅持续的数据源(比如表数据的变化)。
内容的提问来源于stack exchange,提问作者Human
相关产品推荐
相关产品推荐

