2016-10-17 1 views
1
  var promises = []; 
      promises.push(
       sequelize.transaction(function(t1) { 
        return models.car_service.findAll({ 
         where: sequelize.and(
          { "id_dtc": 6}, 
          { "id_car": 95 } 
         ), 
         transaction: t1, 
         lock: t1.LOCK.UPDATE, 
         logging: console.log 
        }).then(function(result) { 
         console.log(result.dataValues); 
         if(!result.dataValues){ 
         return models.car_service.create(
          { 
           id_dtc: 6, 
           id_car: 95, 
           priority: config.get('apiConfig.coreControllerConfig.createIssueOptions.DTCPriority'), 
           status: 'new', 
           dtc_is_pending: false 
          }); 
         } 
        }) 
       }) 
      ); 
      promises.push(
       sequelize.transaction(function(t2) { 
        return models.car_service.findAll({ 
         where: sequelize.and(
          { "id_dtc": 6}, 
          { "id_car": 95 } 
         ), 
         transaction: t2, 
         lock: t2.LOCK.UPDATE, 
         logging: console.log 
        }).then(function(result) { 
         console.log(result.dataValues); 
         if(! result.dataValues){ 
         return models.car_service.create(
          { 
           id_dtc: 6, 
           id_car: 95, 
           priority: config.get('apiConfig.coreControllerConfig.createIssueOptions.DTCPriority'), 
           status: 'new', 
           dtc_is_pending: false 
          }); 
         } 
        }) 
       }) 
      ); 
      return promise.all(promises).then(function(results) { 
       console.log(results); 
      }); 

журнал являетсяПочему транзакция sequelize t.lock.UPDATE не блокирует другую транзакцию?

Executing (14a1c614-c2f1-46a1-a99f-89bc92ca23dc): SELECT "id", "status",  "priority", "mileage", "done_at", "created_at", "updated_at", "id_car", "id_service_type", "id_service_edmunds", "id_service_customized", "id_recall_recallmasters", "id_service_archive", "id_service_mmy", "id_service_preset", "id_dtc", "dtc_is_pending" FROM "car_service" AS "car_service" WHERE ("car_service"."id_dtc" = 6 AND "car_service"."id_car" = 95) FOR UPDATE; 
Executing (084558cc-730d-441a-a794-aaa27898db77): SELECT "id", "status", "priority", "mileage", "done_at", "created_at", "updated_at", "id_car", "id_service_type", "id_service_edmunds", "id_service_customized", "id_recall_recallmasters", "id_service_archive", "id_service_mmy", "id_service_preset", "id_dtc", "dtc_is_pending" FROM "car_service" AS "car_service" WHERE ("car_service"."id_dtc" = 6 AND "car_service"."id_car" = 95) FOR UPDATE; 

undefined 
undefined 

Кто-нибудь знает, почему я до сих пор добавив 2 одинаковые строки в таблице, я думал, что замок ряд должен заблокировать сделку, которая есть выбор для обновления?

ответ

0

Вы должны передать в соответствующий объект транзакции {transaction: t1} или {transaction: t2} как вариант во втором запросе транзакций. (in the documentation)

 Смежные вопросы

  • Нет связанных вопросов^_^