RoomDatabase插入数据无效且无报错，求排查原因及异常捕获方法

问题背景 #

使用Room Database时，插入API返回的数据后无法读取到数据，且无SQL相关报错导致无法定位问题。尝试用@Throws(SQLException::class)抛出异常但无效，需排查数据读取失败的原因并掌握正确的SQL异常抛出方法。

相关代码 #

Entity

@Entity(tableName = "boards_table")
class BoardModel {
    @PrimaryKey
    var Id = ""
    var Title =""
}

注：Id非自增，数据来自API。

DAO

@Dao
interface BoardDAO {

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    suspend fun addBoard(board:BoardModel)

    @Query("SELECT * FROM boards_table")
    fun readAllData(): LiveData<List<BoardModel>>

    @Query("DELETE FROM boards_table")
        suspend fun deleteAllBoard()
    @Delete
    suspend fun deleteBoard(board:BoardModel)
}

Activity写入代码

private lateinit var boardDao:BoardDAO
appDb = NimaDatabase.getDatabase(this)

// tempBoardlist来自API且数据正常
for (board in tempBoardlist){
  GlobalScope.launch {
    boardDao.addBoard(board.toBoardModel())
   }
 }

Activity读取代码

var boardlist = boardDao.readAllData().value

API数据转换类

// 该类工作正常，用于便捷获取API数据
class board() {
    val _id: String = ""
    val title: String = ""
}

// 转换为BoardModel
fun board.toBoardModel() : BoardModel
{
    val b =  BoardModel()
    b.Id = _id
    b.Title = title
    return b
}

一、数据读取失败的核心原因及解决 #

1. LiveData.value 直接获取的时机错误 #

readAllData()返回的是LiveData<List<BoardModel>>，LiveData的value属性仅在数据已被主动观察或主线程中数据已加载完成时才会有值。直接调用.value大概率拿到null，因为Room查询是异步执行的，需通过观察者监听数据变化：

// 替换直接获取value的方式，改为观察LiveData
boardDao.readAllData().observe(this) { boards ->
    boardlist = boards
    // 后续UI更新或数据操作放在此处
}

2. 插入操作的异步线程未同步 #

使用GlobalScope.launch启动多个协程插入数据，但未等待所有插入完成就执行读取，导致读取时数据还未写入数据库。解决方式有两种：

• 批量插入减少协程开销：
  在DAO中新增批量插入方法：

  @Insert(onConflict = OnConflictStrategy.REPLACE)
  suspend fun addBoards(boards: List<BoardModel>)
  

  写入代码改为：

  GlobalScope.launch {
      val boardModels = tempBoardlist.map { it.toBoardModel() }
      boardDao.addBoards(boardModels)
  }
  

• 等待所有插入协程完成：

  GlobalScope.launch {
      val jobs = mutableListOf<Job>()
      for (board in tempBoardlist) {
          jobs.add(launch {
              boardDao.addBoard(board.toBoardModel())
          })
      }
      jobs.joinAll() // 等待所有插入操作完成
      // 切回主线程观察数据
      withContext(Dispatchers.Main) {
          boardDao.readAllData().observe(this@YourActivity) { boards ->
              boardlist = boards
          }
      }
  }
  

3. 实体类字段映射歧义 #

Room默认按字段名映射数据库列名，大小写差异可能导致数据存储/读取异常。建议显式指定列名避免歧义：

@Entity(tableName = "boards_table")
class BoardModel {
    @PrimaryKey
    @ColumnInfo(name = "id")
    var Id = ""
    @ColumnInfo(name = "title")
    var Title =""
}

同时可在转换方法中打印日志验证数据有效性：

fun board.toBoardModel() : BoardModel {
    val b = BoardModel()
    b.Id = _id
    b.Title = title
    Log.d("BoardConvert", "转换后数据：id=${_id}，title=${title}")
    return b
}

二、SQL异常抛出的正确方式 #

Room的suspend方法本身会抛出SQLException，但需注意以下几点：

1. 冲突策略影响异常抛出：
   当前@Insert使用OnConflictStrategy.REPLACE，冲突时会直接替换数据而非抛出异常。若需冲突时抛出异常，修改策略为ABORT：

   @Insert(onConflict = OnConflictStrategy.ABORT)
   suspend fun addBoard(board: BoardModel)
   

2. 用try-catch捕获异常：
   Kotlin中无需显式声明@Throws(SQLException::class)，直接在协程中捕获即可：

   GlobalScope.launch {
       try {
           val boardModels = tempBoardlist.map { it.toBoardModel() }
           boardDao.addBoards(boardModels)
       } catch (e: SQLException) {
           Log.e("RoomError", "插入失败：${e.message}")
           // 异常处理逻辑
       }
   }
   

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