Результаты сбора синхронных вызовов node.js

Question

У меня есть таблица, где люди сохраняют свое время (в секундах), где они были активны. Я хотел бы написать функцию, которая собирает общее время в другой таблице с именем gather.

Для каждой строки я проверяю, существует ли запись в таблице gather. В зависимости от этого результата я делаю вставку или обновление.

db.serialize(function() { 
    db.each("SELECT * from TEST", function(err, row) { 
     db.get("SELECT * from GATHER where name = " + row.name "", function(err, row) { 
      if(row === undefined || row === null){ 
       var stmt = db.prepare("INSTER INTO gather (name, time) VALUE(?,?)"); 
       stmt.run([name, seconds], function(error){ 
        console.log('lastInsert ' + this.lastID); 
       }); 
       stmt.finalize(); 
      }else{ 
       seconds += row.time;//increment time 
       var stmt = db.prepare("UPDATE gather SET time = ? WHERE name = ?"); 
       stmt.run([seconds, row.name], function(error){ 
        console.log('lastInsert ' + row.idProcessed); 
       }); 
       stmt.finalize(); 
      } 
     }); 
    }); 
}); 

Проблема, заключающаяся в том, что sqlite работает асинхронно. Поэтому в моей таблице gather создано несколько записей, хотя строки должны быть обновлены.

Что было бы правильным способом запустить эту функцию синхронно? Должен ли я ограничивать линии и вызывать функцию каждую секунду или есть умный способ?

Answer 1

Вы можете использовать async. Например (но сначала вы должны прочитать заключительные замечания в конце):

var async = require('async'); 

var data = {} 

var yourFirstSelect() = function(callback){ 
    //You do your first select 
    //... 
    db.get("SELECT * from TEST", function(err, row) { 
    if(row){ 
     data.name = row.name; 
     data.otherInterestingAttribute = row.otherInterestingAttribute; 
     callback(err, data); 
    }else{ 
     callback('Row is null'); 
    } 
    }) 
    //.. 
} 

var yourSecondSelect() = function(data, callback){ 
    //You do your second select 
    //... 
    db.get("SELECT * from GATHER where name = " + data.name "", function(err, row) { //Note that I'm using data instead of row 
    if(row){ 
     data.seconds = row.seconds; 
     data.otherInterestingAttribute = row.otherInterestingAttribute; 
     callback(err, data); 
    }else{ 
     callback('Row is null'); 
    } 
    }) 
    //.. 
} 

var decide() = function(data, callback){ 
    if (data.somethingExists) { //Do your validations 
    data.type = 'update'; 
    callback(err, data); 
    } else { 
    data.type = 'insert'; 
    callback(err, data); 
    } 
} 

var update() = function(data,callback){ 
    if (data.type === 'update') { 
    //... 
    //Do your stuff in order to update 
    seconds += row.time;//increment time 
     var stmt = db.prepare("UPDATE gather SET time = ? WHERE name = ?"); 
      stmt.run([seconds, row.name], function(error){ 
      console.log('update ' + row.idProcessed); 
      }); 
     stmt.finalize(); 
    //... 
    } else { 
    callback(err,data); 
    } 
} 

var insert() = function(data,callback){ 
    if (data.type === 'insert') { 
    //... 
    //Do your stuff in order to insert 
    var stmt = db.prepare("INSTER INTO gather (name, time) VALUE(?,?)"); 
     stmt.run([data.name, data.seconds], function(error){ 
      console.log('lastInsert ' + this.lastID); 
      callback(err,data); 
     }); 
     stmt.finalize(); 
    //... 
    } else { 
    callback(err,data); 
    } 
} 

var niceWorkflow = function(){ 
    async.waterfall([ 
     yourFirstSelect, 
     yourSecondSelect, 
     decide, 
     update, 
     insert 
    ], 
    function (err, result) { 
    console.log('Done'); 
    }) 
} 

//and call your workflow 
niceWorkflow(); 

Конечно же, это не рабочий код 100%, я написал его, чтобы посмотреть еще один способ сделать то, что вы пытаетесь. Многие переменные, валидации и т. Д. Являются лишь примерами, и я намеренно забыл db.each, чтобы не быть слишком расширенным и запутывающим вас и пытаться ответить на ваш последний вопрос Is there a smarter way?.

Answer 2

Вы также можете использовать Q.all от Q library. Он вернет обещание после того, как все обещания будут решены. Это одно обещание терпит неудачу, тогда Q.all будет отвергнут.