为何MediatorLiveData无法监听两个Room数据源？

你遇到的核心问题是MediatorLiveData没有被正确触发，同时代码里还有几个关键的逻辑错误，导致数据库数据无法被监听、日志无法输出。下面一步步拆解问题并给出修复方案：

为什么日志没出现？ #

你的代码存在三个致命问题：

1. MediatorLiveData泛型不匹配：你定义的liveDataMerger是MediatorLiveData<List<Int>>，但实际要处理的是List<AccountGroupDto>和List<AccountDto>，泛型错误导致后续逻辑无法正常绑定数据源。
2. MediatorLiveData未被观察：Room的LiveData查询和MediatorLiveData的回调，只有在自身被主动观察时才会触发。你创建了liveDataMerger但没有给它添加观察者，所以数据源的变化完全不会被感知。
3. 返回的LiveData从未更新：你创建了shareItems但从未给它赋值，最终返回的是空的LiveData，Activity自然观察不到任何数据。

正确的实现代码 #

下面是修复后的Repository代码，同时实现数据转换和合并逻辑：

override fun getShareItems(): LiveData<List<ShareItem>> {
    // 最终对外提供的合并后数据LiveData
    val mergedShareItems = MutableLiveData<List<ShareItem>>()
    
    // 用MediatorLiveData监听两个不同类型的数据源
    val mediator = MediatorLiveData<Any>()
    
    // 保存两个数据源的最新数据快照
    var latestGroups: List<AccountGroupDto>? = null
    var latestAccounts: List<AccountDto>? = null
    
    // 监听账户分组数据
    mediator.addSource(accountGroupsDao.getAll()) { groups ->
        latestGroups = groups
        // 每次数据变化时合并最新的两组数据
        mergeDataAndUpdate(latestGroups, latestAccounts, mergedShareItems)
        println("Group log: 加载到${groups.size}个分组")
    }
    
    // 监听账户数据
    mediator.addSource(accountsDao.getAll()) { accounts ->
        latestAccounts = accounts
        mergeDataAndUpdate(latestGroups, latestAccounts, mergedShareItems)
        println("Account log: 加载到${accounts.size}个账户")
    }
    
    // 关键：给MediatorLiveData添加观察者，触发数据源监听
    val observer = Observer<Any> { /* 无需额外逻辑，仅触发监听 */ }
    mediator.observeForever(observer)
    
    // 注意：如果Repository是单例/长生命周期对象，需在合适时机移除observer避免内存泄漏
    // 比如在ViewModel的onCleared()中调用repository.removeObserver(observer)
    
    return mergedShareItems
}

// 单独封装数据转换与合并逻辑
private fun mergeDataAndUpdate(
    groups: List<AccountGroupDto>?,
    accounts: List<AccountDto>?,
    targetLiveData: MutableLiveData<List<ShareItem>>
) {
    val shareItemList = mutableListOf<ShareItem>()
    
    // 转换分组数据为ShareItem（isGroup=true）
    groups?.forEach { group ->
        shareItemList.add(ShareItem(
            accountId = 0, // 分组无账户ID，按业务需求设置默认值
            accountGroupId = group.id, // 假设AccountGroupDto有id字段
            isGroup = true
        ))
    }
    
    // 转换账户数据为ShareItem（isGroup=false）
    accounts?.forEach { account ->
        shareItemList.add(ShareItem(
            accountId = account.id, // 假设AccountDto有id字段
            accountGroupId = account.groupId ?: 0, // 如果账户属于某个分组，替换为对应ID
            isGroup = false
        ))
    }
    
    // 更新对外提供的LiveData
    targetLiveData.value = shareItemList
}

后续使用说明 #

在ViewModel中关联该LiveData，并在Activity中观察：

// ViewModel代码
class ShareViewModel(private val repository: ShareRepository) : ViewModel() {
    val shareItems = repository.getShareItems()
    
    override fun onCleared() {
        super.onCleared()
        // 若Repository保存了observer引用，在此处移除避免内存泄漏
        // repository.removeMediatorObserver()
    }
}

// Activity代码
viewModel.shareItems.observe(this) { items ->
    // 更新UI，比如给RecyclerView适配器提交数据
    shareAdapter.submitList(items)
}

关键修复点总结 #

• 修正MediatorLiveData的泛型，适配不同类型的数据源；
• 通过observeForever触发MediatorLiveData的监听逻辑，让Room的查询开始执行；
• 每次任意数据源变化时，合并最新数据并转换为ShareItem列表，更新对外提供的LiveData；
• 注意在合适时机移除observeForever添加的观察者，避免内存泄漏。

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