Firebase事务api调用当前数据为空

Question

当我使用 transaction()来更新一个位置时，该位置的数据返回null，即使该位置有一些数据。

我在同一位置读取数据后尝试transaction() ，此时它在该位置给出所有数据。

如果情况如上所述，我如何使用transaction() ?

Answer 1

事务以Amazon的SimpleDB或数据库分片集群的方式工作。也就是说，它们是"最终一致的"，而不是保证一致的。

因此，当您使用事务时，处理函数可能会使用本地值(在某些情况下，如果从未被检索，则为null)调用多次，然后再次使用同步值(无论服务器上的值是什么)。

的例子:

pathRef.transaction(function(curValue) {
    // this part is eventually consistent and may be called several times
}, function(error, committed, ss) {
    // this part is guaranteed consistent and will match the final value set
});

无论如何，这确实是您必须处理事务的心态。您应该总是期望有多个调用，因为第一个事务可能与另一个更改发生冲突并被拒绝。您不能使用事务的处理方法来获取服务器值(尽管您可以从成功回调中读取它)。

阻止本地触发事件

事务发生时，在到达服务器进行延迟补偿之前触发本地事件。如果事务失败，则本地事件将被恢复(触发更改或删除事件)。

您可以在事务上使用applyLocally属性来覆盖此行为，这会使本地结果变慢，但确保仅在本地触发服务器值。

pathRef.transaction(function(curValue) {
    // this is still called multiple times
}, function(error, committed, ss) {
    // this part is guaranteed consistent and will match the final value set
}, 
    // by providing a third argument of `true`, no local event
    // is generated with the locally cached value.
true);

Answer 2

您需要遵循以下模式:

var pinRef = firebase.database().ref('vm-pin-generator');
pinRef.transaction(function(oldPin) {
    // Check if the result is NOT NULL:
    if (oldPin != null) {
        return localPinIncrementor(oldPin);
    } else {
        // Return a value that is totally different 
        // from what is saved on the server at this address:
        return 0;
    }
}, function(error, committed, snapshot) {
    if (error) {
        console.log("error in transaction");
    } else if (!committed) {
        console.log("transaction not committed");
    } else {
        console.log("Transaction Committed");
    }
}, true);

Firebase通常在第一次检索键时返回空值，但在保存时检查新值是否与旧值相似。如果没有，firebase将再次运行整个过程，这一次服务器将返回正确的值。

添加null检查并返回一个完全意想不到的值(本例中为0)将使firebase再次运行循环。

Answer 3

简单地展示一个示例实现来详细说明@Kato接受上面的答案，并使用自定义upsert函数:

  /**
   * Transactional insert or update record
   * @param  {String} type - object type (table or index) to build lookup path
   * @param  {String} id - object ID that will be concat with path for lookup
   * @param  {Object} data - new object (or partial with just edited fields)
   * @return {Object}       new version of object
   */
  const upsert = (type, id, data) => {
    return new Promise((resolve, reject) => {
      if (!type) {
        log.error('Missing db object type')
        reject(new TypeError('Missing db object type'))
      }
      if (!id) {
        log.error('Missing db object id')
        reject(new TypeError('Missing db object id'))
      }
      if (!data) {
        log.error('Missing db data')
        reject(new TypeError('Missing db data'))
      }
      // build path to resource
      const path = `${type}/${id}`
      log.debug(`Upserting record '${path}' to database`)
      try {
        const ref = service.ref(path)
        ref.transaction(record => {
          if (record === null) {
            log.debug(`Creating new record`) // TODO: change to debug
            return data
          } else if (record) {
            log.debug(`Updating existing record`) // TODO: change to debug
            const updatedRecord = Object.assign({}, record, data)
            return updatedRecord
          } else {
            return record
          }
        }, (error, committed, snapshot) => {
          if (error) {
            log.error(`Error upserting record in database`)
            log.error(error.message)
            reject(error)
          } else if (committed) {
            log.debug(`Saved update`)
          } else {
            log.debug(`Record unchanged`)
          }
          if (snapshot) {
            resolve(snapshot.val())
          } else {
            log.info(`No snapshot found in transaction so returning original data object`)
            resolve(data)
          }
        })
      } catch (error) {
        log.error(error)
        reject(error)
      }
    })
  }