android - 如何在 Kotlin 协程中使用 Sqldelight

Question

SqlDelight 显然有 Kotlin 协程扩展函数，但我不知道如何实现它们，因为我找不到文档。

我有一个看起来像这样的普通查询：

val allItems
  get() = itemQueries.selectAll().mapToList()

我可以把它变成一个挂起功能吗？

score 7 · Accepted Answer

目前 (v1.2.1) 不支持 SqlDelight 查询的挂起功能，但是您可以使用 Coroutines Flow 对象，这会更好。为此，您需要在应用程序 gradle 中添加协程扩展库：

dependencies {
  implementation "com.squareup.sqldelight:coroutines-extensions:1.2.1"
}

然后把你的查询变成这样：

val allItems: Flow<List<Item>> = 
  itemQueries.selectAll()
    .asFlow()
    .mapToList()

此流程发出查询结果，并在每次数据库更改该查询时发出一个新结果。

然后，您可以.collect{}在协程范围内获得结果。

score 2 · Accepted Answer

对于单次查询，您不需要协程扩展库。相反，只需执行以下操作：

suspend fun getAllItems() = withContext(Dispatchers.IO) {
    itemQueries.selectAll().mapToList()
}

另一个答案特定于您想要对数据库中的更改做出反应的时间。

2 回答 2