Mysql
 sql >> Datenbank >  >> RDS >> Mysql

Synchrones MySQL in Node.js

Normalerweise verwende ich für diese Art von Problem ein Muster wie das untenstehende. Kurz gesagt:Holen Sie sich eine Liste von Dingen und rufen Sie dann eine Funktion auf, um die Liste zu verarbeiten. diese Funktion ruft sich selbst auf, bis die Liste vollständig ist; Sammeln Sie die Ergebnisse unterwegs in einem Akkumulator; Wenn die Liste leer ist, geben Sie alles zurück, was Sie durch den Rückruf angesammelt haben. Es ist nur eine weitere Möglichkeit, das zu erreichen, was @Andrey Sidorov in seiner Antwort demonstriert hat.

//cb is (err, res) 
function getData(cb){
  var querystr = "SELECT * FROM groups";
  var result = "";

  dbClient.query(querystr, function (err, res, fields) {
      if (err)
          cb(err);
      else {
        var groups = [];
        for (var ndx in res)
          groups = groups.concat(res[ndx].members.split(","));

        getMembers(groups, [], cb);
      }
  });
}

function getMembers(members, sofar, cb){
  var member = members.shift();

  if (!member)
    cb(null, sofar);
  else {
    var memberquery;
    var params;

    if (member.substr(0,1) == "@") {
        memberquery = "SELECT name FROM groups WHERE id = ?";
        params = [member.substr(1, member.length-1)];
    } else {
        memberquery = "SELECT username FROM users WHERE id = ?";
        params = [member];
    }

    dbClient.query(memberquery, params, function(err, res) {
      if (err)
        cb(err);
      else {
        var membername = "";
        if (typeof res[0].username == "undefined") {
            membername = "@" + res[0].name;
        } else {
            membername = res[0].username;
        }

        sofar.push(membername);

        getMembers(members, sofar, cb);
      }
    });
  }
}