如何在Kotlin协程中使用Sqldelight

Question

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

我有一个普通的查询，如下所示：

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

我能把它变成一个挂起函数吗？

Answer 1

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

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

然后将您的查询转换为：

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

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

然后，您可以在协程作用域中对结果进行.collect{}。

Answer 2

对于单次查询，您不需要协程扩展库。取而代之的是：

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

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