bookshelf.js операции блокировки

Question

Есть ли возможность создавать транзакции с атомной базой данных с книжной полкой? У меня проблема с дубликатами в базе данных. Проблематично код, как показано ниже:

bookshelf.transaction(function (t) { 
    var modelLocation = new Models.Location({'name':event.venue}); 
    modelLocation.fetch({transacting:t}) 
     .then(function (fetchedLocation) { 
      if (!fetchedLocation) { 
       modelLocation.save(null,{transacting:t}).then(function (savedModel) { 
        t.commit(savedModel) 
       }).catch(function (err) { 
        t.rollback(err) 
       }); 
      } 
      else{ 
       t.commit(fetchedLocation) 
      } 
     }) 
}) 

я вызвать метод, содержащий этот код почти Simultaniously и асинхронно в 20 раз. Из этих 20 имеется 5 дублирующих наборов данных. В результате получается около 2-3 дубликатов в базе данных. Текущее обходное решение состоит в том, чтобы обернуть все это в setTimeout со случайным интервалом между 0 и 10 секундами, который почти никогда не дает мне дубликатов. Но это, очевидно, не готовое к производству решение.

Answer 1

ОК, поэтому, в конце концов, я решил пойти с библиотекой async.js и это очередь. Очередь гарантирует, что одновременно выполняются максимум n задач асинхронной работы. В этом случае 1. Я создал модуль, который экспортирует экземпляр очереди. Таким образом, я могу использовать его для нескольких модулей. Он просто ждет обещания выполнить.

var async = require('async'); 

module.exports = async.queue(function (task, callback) { 
    task().then(function() { 
     callback(); 
    }); 
},1); 

Затем в модуле, где мне нужна «атомную» транзакция У меня есть следующий код:

var queue = require('./transactionQueue'); 
... 
... 
queue.push(function(){ 
    return bookshelf.transaction(function (t) { 
     var modelLocation = new Models.Location({'name':event.venue}); 
     return modelLocation 
      .fetch({transacting:t}) 
      .then(function (fetchedLocation) { 
       if (!fetchedLocation) { 
        return modelLocation 
         .save(null,{transacting:t}); 
       } 
      }); 
    }); 
}); 

Очень важно, чтобы обернуть транзакцию в функцию, так что не будет выполнено верно далеко.

Answer 2

Поскольку транзакции книжной полки являются обещаниями, вам не нужно явно звонить commit() или rollback(). Просто позвольте исполненному обещанию взять на себя обязательства, или вы можете заставить откат, выбросив исключение.

В вашем коде есть, видимо, небольшая ошибка, которая может быть причиной проблемы: аргумент отсутствует из fetch() «s then() - этот аргумент является результатом от fetch() вызова, экземпляра, если объект был найден или null если не.

bookshelf.transaction(function (t) { 
    var modelLocation = new Models.Location({'name':event.venue}); 
    return modelLocation 
    .fetch() 
    .then(function (fetchedLocation) { 
     if (!fetchedLocation) { 
      modelLocation 
       .save(null,{transacting:t}); 
     } 
    })l 
}); 

Я не могу проверить это сейчас, но я надеюсь, что это поможет.