Android：如何停止 Firestore 交易？

Question

首先，我使用queryWaitingRoom() 查询 Firestore 中的一些文档，如果结果满足条件，则调用 runTransactionInWaitingRoom()。

这是第一个函数：

private fun queryWaitingRoom() {
    waitingRoomRef
        .orderBy("isAvailable", Query.Direction.DESCENDING)
        .limit(1)
        .get()
        .addOnSuccessListener { documents ->

            if (!documents.isEmpty){
                for (document in documents) {
                    val waitingRoomId = document.get("id").toString()

                    runTransactionInWaitingRoom(waitingRoomId)
                }
            }
        }
}

我的问题是，在runTransactionInWaitingRoom() 中，如果currentState 的值不等于true，我如何才能在else 块中停止transaction？并再次拨打queryWaitingRoom()？ 这是第二个功能：

 private fun runTransactionInWaitingRoom(waitingRoomId: String){
    val docRef = waitingRoomRef.document(waitingRoomId)

    db.runTransaction { transaction ->

        val snapshot = transaction.get(docRef)
        val currentState = snapshot.getBoolean("isAvailable")

        if (currentState == true){
            transaction.update(docRef, "isAvailable", false)
        } else {
            ///// STOP THE TRANSACTION RIGHT HERE /////
            ///// And call the the queryWaitingRoom() again /////

            Log.d("OIWENCLKSJF", "Transaction.currentState != true")   // getting called 5 or 6 times.

            throw FirebaseFirestoreException("Population too high",    // only get called at the last attemp.
                FirebaseFirestoreException.Code.ABORTED)
        }

    }.addOnSuccessListener {

    }.addOnFailureListener { e ->
        Log.w("OIWENCLKSJF", "Transaction failure.", e)
    }
}

到目前为止，我得到的是 transaction 一直在调用自己，即使我将 exception 扔到 else 块中。 我在这里遇到了类似的问题，但没有帮助。如果有人能指导我一点，我将不胜感激。

Firestore how stop Transaction?

Answer 1

是的，isAvailable 属性来自同一个文档。

如果两个属性都属于同一个文档，则仅当isAvailable 属性的值为 true 时才运行事务：

if (!documents.isEmpty){
    for (document in documents) {
        val waitingRoomId = document.get("id").toString()
        val isAvailable = document.getBoolean("isAvailable")
        if(isAvailable) {
            runTransactionInWaitingRoom(waitingRoomId)
        }
    }
}

此解决方案背后的想法是仅在isAvailable 为真时运行事务。你现在在做什么，你总是在运行事务，在里面，如果条件不成立，取消事务。为什么这个解决方案不可行？假设您有 1 MIL 文档，其中只有 1 具有 isAvailable true，您愿意为了一个文档运行 1 MIL 事务吗？恐怕你不是。请记住，在 Firestore 中，执行的每个文档读取都需要一次读取操作。

更好的解决方案是直接在数据库中查询isAvailable 属性值为true 的文档：

waitingRoomRef
    .whereEqualTo("isAvailable", true) //Added
    .orderBy("isAvailable", Query.Direction.DESCENDING)
    .limit(1)
    .get()

在这种情况下，您将直接获得所需的文档。此操作的成本将等于查询返回的文档数。