Как многократно выполнять запрос mysjl nodejs, пока не появится желаемый результат? - PullRequest
Новая
       14

Как многократно выполнять запрос mysjl nodejs, пока не появится желаемый результат?

0 голосов
/ 05 января 2019 
conn.connect(function (err) {
        if (err) throw err;
        var prizeCode = generatePrizeCode();// this method return a 5-digit code
        var query = "SELECT * FROM user WHERE code = ? ";
        var values = [[prizeCode]];
        conn.query(query, [values], function (err, result) {
            if (err) throw err;
            // Here I want to re-execute the above query if the result is not empty 
        });
    });

В приведенном выше коде я хочу выполнить запрос, если результат содержит данные. Но я не могу использовать цикл, подобный следующему псевдокоду, 

// if the result is empty, the generated code does not exist in database. So it can be used.
while(result.length != 0){
    var result = conn.query("SELECT * FROM user WHERE code = abc");
}

Как мне этого добиться?

Ответы [ 3 ]

0 голосов
/ 05 января 2019 

var mysql = require('mysql');
var pool  = mysql.createPool({
  host     : 'YOUR_HOST_NAME',
  user     : 'YOUR_USER_NAME',
  password : 'YOUR_PASSWORD',
  database : 'YOUR_DATABASE'
});

pool.getConnection(function(err, connection) {
  // connected! (unless `err` is set)
});


connection = mysql.createPool
var retryLimit=0;

var getData = function () {
if(retryLimit <= 50)
{
retryLimit++;
connection.query('SELECT * FROM user WHERE code = abc', function (error, results, fields) {
  if (error) {throw error;}
  else if(result.length <1) {
getData();
//call the same method again.
}
});
}
}


getData();

Вы можете добавить еще операторы и делать что хотите.

0 голосов
/ 09 января 2019

Вам придется использовать функции обратного вызова или обещания / асинхронные. Вот как это можно написать с помощью обратных вызовов: 

const mysql = require('mysql');

const retryLimit = 50;

const connection = mysql.createConnection({
  database: 'test',
  host: 'localhost',
  password: 'hunter2',
  user: 'dave',
});

function getData(attempts, cb) {
  if (attempts < retryLimit) { // we haven't exausted our attempts yet
    const code = generatePrizeCode();
    connection.query('SELECT * FROM user WHERE code = ?', code, (err, result) => {
      if (err) {
        return cb(err);
      }
      if (result.length > 0) { // code already exists
        getData(attempts + 1, cb); // recurse
      } else { // this is a new code
        cb(null, code); // return the new code via the callback function
      }
    });
  } else { // we have exausted our attempts
    return cb(new Error('retry limit exceeded'));
  }
}

getData(0, (err, code) => {
  // do what you want here, e.g., console.log(code)
  connection.end();
});

Обратите внимание, что это может привести к сбою узла, если вы выполняете слишком много раз и превышаете максимальный стек вызовов. Одним из способов решения этой проблемы является вызов setImmediate или setTimeout вместо прямого повторения. Вместо строки 

getData(attempts + 1, cb); // recurse

использование 

setImmediate(() => {
  getData(attempts + 1, cb); // recurse
});

или 

// recurse, using setImmediate every 1000th time
if (attempts % 1000 === 0) {
  setImmediate(() => {
    getData(attempts + 1, cb); // recurse
  });
} else {
  getData(attempts + 1, cb); // recurse
}

Использование обещаний и стиля async / await могло бы сильно это очистить и, вероятно, больше походить на то, к чему вы привыкли (обратите внимание, что здесь используется библиотека promise-mysql): 

const mysql = require('promise-mysql');

async function getData(connection) {
  const retryLimit = 50;
  for (let i = 0; i < retryLimit; i++) {
    const code = generatePrizeCode();
    const result = await connection.query('SELECT * FROM user WHERE code = ?', code);
    if (result.length === 0) { // this code doesn't exist yet
      return code;
    }
  }
  throw new Error('retry limit exceeded');
}

(async () => {
  try {
    const connection = await mysql.createConnection({
      database: 'test',
      host: 'localhost',
      password: 'hunter2',
      user: 'dave',
    });
    try {
      const code = await getData(connection);
      // do what you want here, e.g., console.log(code)
    } finally {
      connection.end();
    }
  } catch (err) {
    console.log(err);
  }
})();
0 голосов
/ 05 января 2019

В основном вам нужно будет работать с асинхронными \ ожидающими или обещаниями (почти так же). https://javascript.info/async-await https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise

таким образом, вы сможете вернуться только тогда, когда получите правильный результат для вас.

...