Room数据库使用协程异步返回Null

如何解决Room数据库使用协程异步返回Null

我目前正在尝试不使用ViewModel从房间数据库中获取数据。这是因为我正在使用NotificationHandler，可以通过警报管理器随时触发该事件。

以下是我到目前为止的代码。下面的代码从另一个类对sortNotification的调用开始。 sortNotification然后调用launchAsyncTask，这又通过调用getQuotesFromDatabase进入数据库。然后，我等待结果（我相信），将数据库中的数据分配给listOfQuotes变量，然后调用displayNotification来使用它。我的问题是，listOfQuotes在尝试使用displayNotification时始终为空。

现在，我知道数据库具有内容，就像当我打开应用程序并转到具有ViewModel的Activity时一样，数据已成功检索。我认为我的问题很可能与异步任务未正确完成或coroutineScope有关。当代码进入listOfQuotes时，我只需要displayNotification有数据。任何帮助将不胜感激。预先感谢。

private var job = Job()
private val ioScope = CoroutineScope(Dispatchers.IO + job)
private lateinit var listOfQuotes: LiveData<List<DefaultQuote>>

fun sortNotification() {
    launchAsyncTask()
}

private fun launchAsyncTask() = CoroutineScope(Dispatchers.IO).launch {
    val asyncTask = ioScope.async {
        getQuotesFromDatabase()
    }
    listOfQuotes = asyncTask.await()
    displayNotification()
}

private suspend fun getQuotesFromDatabase(): LiveData<List<DefaultQuote>> {
    return withContext(Dispatchers.IO) {
        val defaultQuoteDao = QuoteDatabase.getDatabase(context,this).defaultQuoteDao()
        val defaultQuoteRepository = DefaultQuoteRepository(defaultQuoteDao)
        defaultQuoteRepository.allQuotes
    }
}

private fun displayNotification() {
    val quote = listOfQuotes.value?.let {
        val size = it.size
        val randomIndex = (0..size).random()
        it[randomIndex]
    } ?: throw NullPointerException("Quotes not found")

// ... then do notification stuff

我还从我的DAO中添加了代码：

@Dao
interface DefaultQuoteDao {
    @Query("SELECT * FROM $DEFAULT_TABLE_NAME")
    fun getAllQuotes(): LiveData<List<DefaultQuote>>
}

还有我的存储库中的代码：

class DefaultQuoteRepository(private val defaultQuoteDao: DefaultQuoteDao) {
    val allQuotes: LiveData<List<DefaultQuote>> = defaultQuoteDao.getAllQuotes()
}

还有QuoteDatabase.getDatabase(Context,CoroutineScope)的代码：

fun getDatabase(context: Context,scope: CoroutineScope): QuoteDatabase {
            val tempInstance = INSTANCE
            if (tempInstance != null) {
                return tempInstance
            }
            synchronized(this) {
                val instance = Room.databaseBuilder(
                    context.applicationContext,QuoteDatabase::class.java,DATABASE_NAME
                )
                    .fallbackToDestructiveMigration()
                    .addCallback(QuoteDatabaseCallback(scope))
                    .build()
                INSTANCE = instance
                return instance
            }
        }

解决方法

一个具体的问题是您永远不会观察listOfQuotes LiveData的值。这是启动从数据库中提取数据所必需的。

总体而言，您这样做的方式很奇怪。您应该同时使用 协程或LiveData。两者都允许您观察数据库中的数据，但是您不需要两者。这就好比将异步调用包装在内部，然后再调用异步包装。您应该：

1. 删除协程并同步返回LiveData并对其进行观察。
2. 使用Flow从dao函数Flow<List<DefaultQuote>>返回getAllQuotes

我建议2.如果您希望应用程序变得中等或复杂。 Flow允许您以更简洁和灵活的方式映射或合并数据。

然后，您的函数sortNotification将变为：

// Ideally this should be injected into the class,but for a Service that's a little difficult. 
// At a minimum you should initialize it once for the class
val defaultQuoteRepository: DefaultQuoteRepository by lazy { 
    DefaultQuoteRepository(QuoteDatabase.getDatabase(context,this).defaultQuoteDao())
}

fun sortNotification() {
    defaultQuoteRepository.allQuotes
        .map { listOfQuotes ->
            listOfQuotes.random()
        }
        .flowOn(Dispatchers.IO)
        .onEach { randomQuote ->
            displayNotification(randomQuote)
        }
        // This makes the above onEach lambda run on the main thread so you're safe to show notifications. 
        // Ideally you should have a specific scope defined but tbh if you're not testing it's not that important
        .launchIn(GlobalScope)

}