Firestore 事务有条件更新？

Question

我正在尝试检查保存在数据库中的值是否与用户选择匹配，如果匹配则更新它，否则不执行任何操作。

我尝试了以下方法，但出现异常：

原因：com.google.firebase.firestore.FirebaseFirestoreException：事务中读取的每个文档也必须写入。

这是我的代码：

//update toolbar titles if they match
final DocumentReference adminDocRef = mDbase.collection("admins").document(adminID);
mDbase.runTransaction(new Transaction.Function<Void>() {
    @Override
    public Void apply(@NonNull Transaction transaction) throws FirebaseFirestoreException {
        DocumentSnapshot adminSnapshot = transaction.get(adminDocRef);
        String toolbarTitle = adminSnapshot.getString("displayedUser");
        if (userName.equals(toolbarTitle)) {
            transaction.update(adminDocRef, "displayedUser", userName);
        }
        // Success
        return null;
    }
})
        .addOnSuccessListener(new OnSuccessListener<Void>() {
    @Override
    public void onSuccess(Void aVoid) {
        Log.d(TAG, "Transaction success!");
    }
})
        .addOnFailureListener(new OnFailureListener() {
            @Override
            public void onFailure(@NonNull Exception e) {
                Log.w(TAG, "Transaction failure.", e);
            }
        });  

交易可以有条件吗？如果不是，你将如何解决这个问题？必须做一个单独的 get 然后在其中嵌套一个更新似乎很愚蠢。

任何帮助将不胜感激。

谢谢！

Answer 1

有一个类似的answer 来自Alex ，来自documentation

交易可能因以下原因而失败：

• 事务在写操作之后包含读操作。读操作必须始终在任何写操作之前。 //not your case
• 事务读取了在事务之外修改的文档。在这种情况下，事务会自动再次运行。事务被重试有限次。

在你的情况下，我会尝试

if (userName.equals(toolbarTitle)) {
//transaction operations 
}

看看有没有用！

Answer 2

因此，为了有条件地更新我的工具栏标题，我必须以这种方式级联我的 Firestore 操作：

DocumentReference adminDocRef = mDbase.collection("admins").document(adminID);
    adminDocRef.get().addOnCompleteListener(activity, new OnCompleteListener<DocumentSnapshot>() {
        @Override
        public void onComplete(@NonNull Task<DocumentSnapshot> task) {
            if (task.isSuccessful()) {
                DocumentSnapshot document = task.getResult();
                if (document.exists()) {
                    //assign document value to toolbarTitle
                    toolbarTitle = document.getString("displayedUser");
                    if (userName.equals(toolbarTitle)) {
                        DocumentReference adminDocRef = mDbase.collection("admins").document(adminID);
                        adminDocRef
                                .update("displayedUser", toolbarTitle)
                                .addOnSuccessListener(new OnSuccessListener<Void>() {
                                    @Override
                                    public void onSuccess(Void aVoid) {
                                        Log.d(TAG, "Displayed child has been updated");
                                    }
                                })
                                .addOnFailureListener(new OnFailureListener() {
                                    @Override
                                    public void onFailure(@NonNull Exception e) {
                                        Log.w(TAG, "Error: updating displayed child", e);
                                    }
                                });
                        Log.d(TAG, "DocumentSnapshot data: " + document.getData());
                    }

                } else {
                    Log.d(TAG, "No such document");
                }
            } else {
                Log.d(TAG, "get failed with ", task.getException());
            }
        }
    });

我不得不这样做有点令人失望，因为将它包装在事务中似乎更有意义。我希望他们允许事务中的条件行为。

Answer 3

实际上，google 有一个名为 Tasks 的类，您可以使用它来使 firestore 调用同步。

因此，按照您的示例，您可以将其修复为：

try {
        DocumentSnapshot adminDocument = Tasks.await(adminDocRef.get());
        if (adminDocument.exists()) {
            String toolbarTitle = adminDocument.getString("displayedUser");
            if (userName.equals(toolbarTitle)) {
                Tasks.await(adminDocRef.update("displayedUser", userName));
                //Success
            }
        }
    } catch (ExecutionException e) {
        //Error
        e.printStackTrace();
    } catch (InterruptedException e) {
        //Error
        e.printStackTrace();
    }

这样你不需要监听器，同时它是一个有条件的更新。我知道这已经晚了，但希望它会帮助某人。

[更新]： 请注意，不应在主线程上调用 Tasks.await(...)，解决方案是使用 AsyncTask。