从API获取Item存入Room数据库仅成功存储一条的问题求助

问题根源分析 #

1. 主键冲突导致覆盖：实体类ItemLocal将title设为主键，若API返回的多条数据存在重复标题，插入时因OnConflictStrategy.REPLACE策略，后续条目会直接覆盖之前的同标题条目，最终数据库仅保留一条。
2. 缺少批量插入支持：原Dao仅提供单条插入方法，逐个插入遇到主键冲突时同样会触发覆盖逻辑。

修复方案 #

1. 调整实体类主键策略

将title改为普通字段，改用自增主键（或API返回的唯一标识作为主键），确保每条数据都有唯一标识：

@Entity(tableName = "item_table")
data class ItemLocal(
    @PrimaryKey(autoGenerate = true)
    val id: Int = 0, // 自增主键，确保每条数据唯一
    val author: String,
    val title: String,
    // 若API返回专属唯一ID，优先使用：
    // @PrimaryKey val itemId: String,
)

2. 扩展Dao的批量插入方法

在ItemDao中添加批量插入接口，提升效率同时避免循环插入的冗余：

@Query("SELECT * FROM item_table")
fun getAllItems(): Flow<List<ItemLocal>>

@Insert(onConflict = OnConflictStrategy.REPLACE)
suspend fun insertItem(item: ItemLocal)

// 新增批量插入方法
@Insert(onConflict = OnConflictStrategy.REPLACE)
suspend fun insertItems(items: List<ItemLocal>)

3. 完善Repository的插入逻辑

实现批量插入的具体调用：

suspend fun getItems(): List<ItemLocal> {
    return apiService.getItems()?.items?.map {
        ItemLocal(
            author = it.author.orEmpty(),
            title = it.title.orEmpty(),
            // 若使用API返回的唯一ID，此处对应赋值：
            // itemId = it.itemId.orEmpty(),
        )
    } ?: emptyList()
}

// 实现批量插入逻辑
suspend fun insertItemsToDatabase(items: List<ItemLocal>) {
    itemDao.insertItems(items)
}

4. 优化ViewModel的数据流逻辑（可选）

避免Activity中重复触发插入操作，直接在ViewModel获取数据后完成插入：

private val _itemList = MutableStateFlow(emptyList<ItemLocal>())
val itemList = _itemList.asStateFlow()

init {
    viewModelScope.launch {
        val fetchedItems = itemRepository.getItems()
        _itemList.value = fetchedItems
        // 获取数据后直接插入数据库
        itemRepository.insertItemsToDatabase(fetchedItems)
    }
}

对应的MainActivity可简化为仅处理UI更新：

lifecycleScope.launch {
    viewModel.itemList.collect { listOfItems ->
        // 在这里更新UI，比如刷新RecyclerView
        // itemAdapter.submitList(listOfItems)
    }
}

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