如何在Firebase Realtime DB中实现批量增删的原子操作

你可以通过Firebase原生的多位置更新能力实现两个操作的原子性绑定，所有修改会在服务端一次性执行，要么全部成功要么全部失败，不会产生数据不一致问题。

修改后代码 #

createSoldLead(soldLead: SoldLeadModel): void {
  // 构造批量更新对象，key为数据库完整路径，value为对应位置要写入的值
  const updates = {};
  const leadId = soldLead.id.toString();
  // 新增数据到soldLeads节点
  updates[`groups/${this.groupId}/soldLeads/${leadId}`] = soldLead;
  // 删除leads节点对应数据，设置为null在Firebase中等同于删除操作
  updates[`groups/${this.groupId}/leads/${leadId}`] = null;

  // 提交批量更新请求
  this.angularFireDatabase.object('/').update(updates);
}

实现说明 #

• 所有修改操作都被封装到同一个更新对象中，只触发一次服务端请求
• Firebase服务端会保证这批更新的原子性：任意一个路径的操作执行失败，所有修改都会回滚
• 不需要额外引入其他依赖，完全兼容AngularFire的现有API使用逻辑
• 如果需要监听操作结果，可以给update方法返回的Observable添加订阅，error回调触发时代表所有操作都未生效，next回调触发代表所有操作都执行成功：

  this.angularFireDatabase.object('/').update(updates)
    .subscribe({
      next: () => console.log('批量操作成功'),
      error: (err) => console.error('批量操作失败，已全部回滚', err)
    });
  

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