3

Eu tenho um forEach que percorre uma lista de códigos e dentro dele tenho um select que consulta os registros do banco de dados. Após o forEach, os dados são mandados do meu servidor até o meu cliente, mas o forEach não espera o resultado do SELECT chegar para executar o próximo elemento.

Como posso fazer para o forEach esperar o resultado

lista.forEach(function (row) {
   db.query("select * from cad_prospectos where = ?", [row.codigo], function(err, pesquisa){
     result.push(pesquisa)
   })
})
cb(result)   

minha função de retorno cb retorna vazio

6
  • Colocar o código que você tem atualmente vai ajudar a responder a pergunta...
    – Vinícius
    Commented 24/11/2017 às 11:05
  • Coloquei o código espero que consiga entender. Commented 24/11/2017 às 11:11
  • Saberia dizer se db.query retorna um Promise? Aliás, ele é nativo do NodeJS ou é de algum pacote?
    – Woss
    Commented 24/11/2017 às 11:33
  • Ele é do pacote do Firebird Firebird.attach(firebirdConfig, function (err, db) Commented 24/11/2017 às 11:41
  • Se o query devolve um Promisse pode guardar todos num array e utilizar Promisse.all
    – Isac
    Commented 24/11/2017 às 11:58

3 Respostas 3

2

Podes usar Promise e Promise.all para fazer isso. A biblioteca async é excelente mas fazia mais sentido antes de as Promises terem sido integradas na linguagem.

Assim o teu código poderia ser:

function selectAsync(cod) {
  return new Promise((res, rej) => {
    db.query("select * from cad_prospectos where = ?", [cod], (err, data) => {
      if (err) rej(err);
      else res(data);
    });
  });
}

const selects = lista.map(row => selectAsync(row.codigo));
Promise.all(selects).then(cb).catch(console.log);
1
  • 1
    Pois é, assim funcionou bem so fiz algumas alterações para retornar pro meu cliente, não ficou como eu pensava que iria ficar mas esta funcionando perfeitamente e é isto que importa, muito obrigado. Commented 24/11/2017 às 16:29
2

Trabalhe com Promessas:

function consulta(lista) {
    var defer = $q.defer();
    var pesquisas = [];
    var queue = 0; // tamanho da fila a processar
    lista.forEach(function (row) {
       queue++; // adiciona uma pesquisa na fila
       db.query("select * from cad_prospectos where = ?", [row.codigo], function(err, pesquisa){
         pesquisas.push(pesquisa);
         queue--; // pesquisa terminada, sai da fila
         if(queue === 0) { 
            // quando a fila zerar, retorna todas as pesquisas
            defer.resolve(pesquisas); 
         }
       });
    });
    // retorna uma promessa de pesquisas;
    return defer.promise;
}

Para consumir isso:

consulta()
  .then(function (pesquisas) { 
    console.log('pesquisas', pesquisas); 
   });

Para saber mais: https://www.promisejs.org/

2

Acredito que o db.query não retorne uma Promise, mas você pode criar uma promise para que ela retorne quando houver um resultado para sua consulta, algo parecido com o código abaixo;

// Função a ser executada para cada elemento da lista
var fn = function asyncQuery(row) {
  // Retorna uma promise que será finalizada quando o db.query for executado
  return new Promise(resolve => {
    db.query("select * from cad_prospectos where = ?", [row.codigo], function(err, pesquisa) {
      resolve(pesquisa)
    })
  });
};

// Executa a função fn para cada elemento da lista
var promises = lista.map(fn)

// Aguarda a finalização de todas as promises e obtem seu resultado
Promise.all(promises).then(result => cb(result))

1
  • 1
    Sim isso me ajudou bastante já estou quase conseguindo, estou pesquisando na biblioteca do "async" se existe alguma função que pode me ajudar também. Commented 24/11/2017 às 12:23

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .