Flutter+Firebase中，事务内执行批量更新是否正确？

原代码的核心问题是错误地将事务（Transaction）和写入批次（WriteBatch）混用，这会导致操作脱离事务的原子性保障，具体问题点：

1. 事务内部应通过transaction对象执行所有读写操作，而非单独创建writeBatch，否则批次操作不受事务的快照隔离和原子性约束
2. 查询广告时直接调用fs.collection().get()，没有通过事务对象查询，无法保证数据的一致性
3. 在事务内部手动调用writeBatch.commit()是多余且错误的，事务的提交由runTransaction自动处理

方案一：使用纯事务（推荐，强一致性保障） #

适合需要确保「用户标记删除」和「所有广告标记删除」原子性执行的场景（要么全部成功，要么全部失败）：

/// Marks user as deleted
Future<void> storeMarkAsDeleted() async {
  final fs = FirebaseFirestore.instance;
  
  return fs.runTransaction((transaction) async {
    // 1. 通过事务查询用户文档（事务内的读取受快照隔离保护）
    final userDoc = fs.collection(collectionName).doc(id);
    final userSnapshot = await transaction.get(userDoc);
    
    if (!userSnapshot.exists) {
      throw Exception("User document does not exist");
    }

    // 2. 通过事务查询该用户的所有广告（必须用transaction.get保证一致性）
    final adsQuery = fs.collection("ads").where("ownerId", isEqualTo: id);
    final adsSnapshot = await transaction.get(adsQuery);

    // 3. 标记用户为已删除
    transaction.update(userDoc, {
      "deleted": true,
    });

    // 4. 批量标记所有广告为已删除
    for (final adDoc in adsSnapshot.docs) {
      transaction.update(adDoc.reference, {
        "clearedForSale": false,
        "deleted": true,
      });
    }

    // 无需手动提交，runTransaction会自动处理事务提交
  });
}

方案二：使用纯写入批次（性能更高，无事务重试） #

如果你的场景不需要事务的快照隔离和重试机制（比如能确保查询到的广告数据在提交前不会被修改），可以用WriteBatch实现原子批量更新：

/// Marks user as deleted
Future<void> storeMarkAsDeleted() async {
  final fs = FirebaseFirestore.instance;
  final batch = fs.batch();

  // 1. 查询用户文档
  final userDoc = fs.collection(collectionName).doc(id);
  final userSnapshot = await userDoc.get();
  
  if (!userSnapshot.exists) {
    throw Exception("User document does not exist");
  }

  // 2. 查询该用户的所有广告
  final adsSnapshot = await fs.collection("ads").where("ownerId", isEqualTo: id).get();

  // 3. 添加用户删除操作到批次
  batch.update(userDoc, {
    "deleted": true,
  });

  // 4. 添加所有广告删除操作到批次
  for (final adDoc in adsSnapshot.docs) {
    batch.update(adDoc.reference, {
      "clearedForSale": false,
      "deleted": true,
    });
  }

  // 提交批次（原子执行所有操作）
  await batch.commit();
}

两种方案的差异 #

• 事务：会对读取的文档加乐观锁，若事务执行期间文档被其他修改，会自动重试事务，适合需要强一致性的场景
• 写入批次：仅执行批量写操作，无重试机制，性能更高，但无法处理查询到提交之间的数据变更风险

内容的提问来源于stack exchange，提问作者Stéphane de Luca