使用 Room @Transaction 功能时，Android 仪器测试不会运行到结束

Question

我正在使用 AS 3.4.1 和运行 Android 9 的模拟器进行测试。

当我在其中使用Room Dao Function annotated with @Transaction 时，以下测试不会运行。

class RecurrenceManagerTest : DatabaseTest() {

    @Rule
    @JvmField
    val instantTaskExecutorRule = InstantTaskExecutorRule()

    var recurringEntryId: Long = -1

    @Before
    override fun setup() {
        super.setup() // only initialized the db

        val recurringEntry = RecurringEntry(
            recurrence = Recurrence(DATE.toEpochMilli(), Recurrence.DAILY)
        )

        recurringEntryId = runBlocking { db.recurringEntryDao().insert(recurringEntry) }

        val recurringBookEntry = BookEntry.create(
            title = TITLE,
            date = DATE,
            value = VALUE,
            isPaid = IS_PAID,
            notes = NOTES,
            entryType = ENTRY_TYPE,
            categoryId = CATEGORY_ID,
            contacts = CONTACTS,
            recurringEntryId = recurringEntryId
        )

        runBlocking {
            db.bookEntryDao().insert(recurringBookEntry) // BreakPoint #1
        }
    }

    @Test
    fun testInsertRecurrencesAndSchedule() { 
        var recurringEntry = runBlocking { db.recurringEntryDao().get(recurringEntryId) } // BreakPoint #2

        assertThat(recurringEntry, notNullValue())

        runBlocking { RecurrenceManager.insertRecurrencesAndSchedule(ApplicationProvider.getApplicationContext(), db, recurringEntry!!) }

        val bookEntries = db.bookEntryDao().getBookEntries().liveDataValue()
    }
}

这是插入函数：

@Transaction
suspend fun insert(bookEntry: BookEntry): Long {
    val id = insert(bookEntry.entity)
    bookEntry.embeddedContacts?.apply {
        forEach {
            it.id = 0
            it.bookEntryId = id
        }
    }?.let {
        insert(it)
    }

    return id
}

因此，如果我按原样运行测试（请参阅 BreakPoint #1），BreakPoint #2 甚至不会被调用，因此测试在之前的某个地方结束，没有结果。

如果我将 BreakPoint #1 处的代码替换为与 insert 函数完全相同的代码，则测试运行正常。

有人知道这里有什么问题吗？

Answer 1

您可以使用 setTransactionExecutor 在另一个线程中运行事务

return Room
       .inMemoryDatabaseBuilder(context, MyRoomDatabase::class.java)
       .setTransactionExecutor(Executors.newSingleThreadExecutor())
       .build()

然后在测试时使用 runBlocking 而不是 runBlockingTest

@Test
fun moveItem() = runBlocking {
    transactionFunction()
}

Answer 2

我遇到了同样的问题，问题是因为InstantTaskExecutorRule，如果您删除下面的代码块，@Transaction 应该可以与suspend 关键字一起正常工作

@Rule
@JvmField
val instantTaskExecutorRule = InstantTaskExecutorRule()

这条规则似乎阻止了RoomDatabase 获取事务线程。在RoomDatabase.kt 中，执行在以下函数中被阻止：

private suspend fun Executor.acquireTransactionThread(controlJob: Job): ContinuationInterceptor

希望这会有所帮助！