AndroidX Room中如何从多个DAO同步获取多数据集？

不需要重复编写LiveData观察代码，可以通过合并多个LiveData或使用Flow组合数据源的方式，实现三个数据集同步就绪后再进行关联处理，以下是具体方案：

方案1：用MediatorLiveData合并多个LiveData #

MediatorLiveData可以监听多个LiveData数据源，当任意一个数据源更新时，统一判断所有数据是否就绪，就绪后再发射组合后的完整数据。

步骤1：Dao层定义返回LiveData的方法 #

@Dao
interface DataDao {
    @Query("SELECT * FROM dcr_table")
    fun getDCRData(): LiveData<List<DCRData>>

    @Query("SELECT * FROM expenses_table")
    fun getExpensesData(): LiveData<List<ExpensesData>>

    @Query("SELECT * FROM mileage_table")
    fun getMileageData(): LiveData<List<MileageData>>
}

步骤2：ViewModel中合并数据源 #

class DataViewModel(private val dao: DataDao) : ViewModel() {
    // 单个数据源的LiveData
    private val dcrLiveData = dao.getDCRData()
    private val expensesLiveData = dao.getExpensesData()
    private val mileageLiveData = dao.getMileageData()

    // 合并后的组合数据源
    val combinedData: LiveData<Triple<List<DCRData>, List<ExpensesData>, List<MileageData>>> = MediatorLiveData().apply {
        // 临时存储每个数据源的最新数据
        var currentDcr: List<DCRData>? = null
        var currentExpenses: List<ExpensesData>? = null
        var currentMileage: List<MileageData>? = null

        // 统一更新逻辑：三个数据都非空时才发射组合结果
        fun updateCombinedData() {
            val dcr = currentDcr
            val expenses = currentExpenses
            val mileage = currentMileage
            if (dcr != null && expenses != null && mileage != null) {
                value = Triple(dcr, expenses, mileage)
            }
        }

        // 添加三个数据源的监听
        addSource(dcrLiveData) {
            currentDcr = it
            updateCombinedData()
        }
        addSource(expensesLiveData) {
            currentExpenses = it
            updateCombinedData()
        }
        addSource(mileageLiveData) {
            currentMileage = it
            updateCombinedData()
        }
    }
}

步骤3：UI层观察合并后的LiveData #

// 在Activity/Fragment中
viewModel.combinedData.observe(this) { (dcrList, expensesList, mileageList) ->
    // 这里直接复用你之前同步获取数据后的关联处理逻辑即可
    processCombinedData(dcrList, expensesList, mileageList)
}

方案2：用Kotlin Flow组合数据源（推荐） #

如果项目使用Kotlin，Room支持直接返回Flow，通过combine操作符可以更简洁地合并多个数据流，实现同样的效果。

步骤1：Dao层定义返回Flow的方法 #

@Dao
interface DataDao {
    @Query("SELECT * FROM dcr_table")
    fun getDCRData(): Flow<List<DCRData>>

    @Query("SELECT * FROM expenses_table")
    fun getExpensesData(): Flow<List<ExpensesData>>

    @Query("SELECT * FROM mileage_table")
    fun getMileageData(): Flow<List<MileageData>>
}

步骤2：ViewModel中组合Flow #

class DataViewModel(private val dao: DataDao) : ViewModel() {
    val combinedData = combine(
        dao.getDCRData(),
        dao.getExpensesData(),
        dao.getMileageData()
    ) { dcr, expenses, mileage ->
        Triple(dcr, expenses, mileage)
    }.asLiveData() // 转为LiveData适配UI生命周期
}

步骤3：UI层观察数据 #

和方案1的UI层代码完全一致，直接观察combinedData即可。

核心逻辑说明 #

两种方案都是通过等待三个数据集全部就绪再触发处理逻辑，既保留了Room LiveData/Flow的异步响应式特性，又能实现类似同步获取后的关联处理，无需重复编写多份观察代码。

内容的提问来源于stack exchange，提问作者Supun Ayeshmantha