Room 数据库变化不更新 Job 对象？解决方法和常见问题解答

2024-03-18 06:47:49

Room 数据库更新时，为什么 Job 对象不会观察到变化？

问题

使用 Room 数据库时，如果你希望在数据库发生变化时收到通知，可以使用 observe() 方法。它会创建一个 LiveData 对象，该对象会在数据库发生变化时发出通知。

但是，如果你在你的 ViewModel 中创建了一个 Job 对象来执行数据库操作，则在数据库发生变化时，该 Job 对象不会自动更新 LiveData 对象。这是因为 Job 对象并不负责观察数据库的变化。

解决方法

为了解决这个问题，你需要在你的 ViewModel 中手动观察数据库的变化，并使用 LiveData.observe() 方法更新 Job 对象。这样，当数据库发生变化时，Job 对象将能够更新 LiveData 对象，并触发 observe() 方法。

修改后的代码

class PhotosViewModel @Inject constructor(
    private val photoUseCases: PhotoUseCases
): ViewModel() {

    private val _state = MutableLiveData(PhotosState())
    val state: LiveData<PhotosState> = _state

    private var getPhotosJob: Job? = null
    private val photos = mutableListOf<Photo>()
    

  init {
       getPhotos()
     }

    private fun getPhotos()
    {
        getPhotosJob?.cancel()

        getPhotosJob = photoUseCases.getPhotos()
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe { 
                photos.addAll(it)
                _state.value = state.value!!.copy(
                    photos = photos
                )
            }

    }

    fun savePhoto(photo: Photo) {
                 PhotoUseCases.addPhoto(photo)
    }

}

在上面修改后的代码中，我们使用 observeOn(AndroidSchedulers.mainThread()) 方法将 Flow 转换为 Observable，然后使用 subscribe 方法观察数据库的变化。当数据库发生变化时，subscribe 方法将触发，并且 photos 列表将更新。然后，我们使用更新后的 photos 列表更新 LiveData 对象。

注意：

确保你的 PhotoRepository 实现 Flowable<List<Photo>> 或 Observable<List<Photo>> 接口。
在你的 ViewModel 中，使用 AndroidSchedulers.mainThread() 将 Flow 转换为 Observable，以确保在主线程上更新 LiveData 对象。】