Node.js Синхронные запросы с MySQL

Question

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

Я стараюсь держаться подальше от необходимости гнездовых обратных вызовов, потому что он получает вид грязно, что мне нужно помочь в поиске, если есть способ создания синхронных запросов с узлом-Mysql

Вот что я Я пытаюсь достичь.

connection.query("select 1 as email from users where email = " + connection.escape(email), function(err, rows, fields) { 
    if(err) { 
     var error = { 
      error_message: err.code, 
      error_number: err.errno 
     }; 

     return res.send(error); 
    } 

    if(rows.length > 0) { 
     var error = { 
      message: 'Email Address is Taken', 
      code: 2 
     }; 
     return res.send(error); 
    } 
}); 

connection.query("insert into users (email, password) values ("+connection.escape(email)+", "+connection.escape(hash)+")", function(err, rows, fields) { 
      if(err) { 
       var error = { 
        error_message: err.code, 
        error_number: err.errno 
       }; 

       return res.send(error); 
      } 
     }); 

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

Я знаю, что я могу вложить второй запрос в первый запрос и поставить, если в другом, но это то, что я не хочу делать, потому что, хотя у меня есть эти два запроса, у меня также есть возможность использовать bcrypt для шифрования пароль, который также должен быть вложен.

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

Answer 1

Как сказал jfriend00 выше, если вы собираетесь разрабатывать в node.js, тогда вам ДОЛЖНО стать комфортно писать асинхронный код.

"прикован обещания", вероятно, ваш лучший выбор:

• https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise/then

• http://html5hive.org/node-js-quickies-working-with-mysql/

ДОПОЛНЕНИЕ:

Этот учебник показывает обещание сцепления с Node.js SQL-запросы. Он также обсуждает, как вы можете использовать Q и/или Step, чтобы упростить код:

• http://code.tutsplus.com/tutorials/managing-the-asynchronous-nature-of-nodejs--net-36183

Answer 2

Вы могли бы просто использовать модуль для узла, который обеспечивает синхронные функции. Здесь вы найдете модуль, который предоставляет функции sync/async для работы с mysql.

https://github.com/Will-I4M/node-mysql-libmysqlclient

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

var config = require("./config.json") ; 
var mysql = require('mysql-libmysqlclient') ; 
var client = mysql.createConnectionSync(config.host, config.user, config.password, config.database) ; 

var query = "SELECT * FROM Users ;" ; 
var handle = client.querySync(query) ; 
var results = handle.fetchAllSync() ; 

console.log(JSON.stringify(results)) ; 

Answer 3

Для большинства вещей, которые я коды в Node.js, мне нравится асинхронный код. Однако я полностью понимаю, что асинхронный код чрезвычайно и опасно несовместим с необходимостью писать и поддерживать бизнес-логику. Я использовал множество альтернативных методов. Модули, чтобы сделать вещи синхронными, по-прежнему оставляют вас с проблемами с областью данных, которые усложняют ситуацию. Обещания работали лучше для меня. Используя этот подход, я обнаружил, что практически пишу интерпретатор для нового языка поверх JavaScript. Я могу показаться абсурдным, но самый практичный и безопасный метод для меня оказался для использования модуля shelljs и клиента оболочки mysql.Это не большая производительность исполнения, но она значительно улучшает производительность разработчика и обеспечивает четкую и упорядоченную бизнес-логику, что крайне важно для бизнес-логики. Вот фрагмент кода, чтобы привести пример некоторых из того, что я создал:

var shell = require ('shelljs');

module.exports = { пользователя: '', пароль: '',

runSql:function(sql) { 
      var command = "echo '" + sql.replace(/'/g,"'\\''") + "' | mysql -u" + this.user.replace(/'/g,"'\\''") + " -p'" + this.password.replace(/'/g,"'\\''") + "'"; 
      var raw = shell.exec(command, {silent:true}).stdout; 
      //console.log('BASH -> MySQL YIELD: "' + raw + '"'); 
      if(raw.substr(0,5) === 'ERROR') { 
        console.log('ERROR Resulting from: ' + sql + '\n' + raw); 
        return []; 
      } 
      var rows = raw.split('\n'); 
      var names = []; 
      for(var r = 0; r < rows.length; r += 1) { 
        columns = rows[r].split('\t'); 

        // Capture column names 
        if(r === 0) { 
          names = columns; 
          continue; 
        } 

        // Reformat row into named valued 
        var fields = {}; 
        for(var c = 0; c < columns.length; c += 1) { 
          fields[names[c]] = columns[c]; 
        } 
        rows[r] = fields; 
      }; 

      // Eliminate extraneous first and last rows 
      rows.splice(0,1); 
      rows.splice(rows.length-1,1); 

      return rows; 
    },