Замена обратных вызовов обещаниями в узле.js

С птица можно использовать Promise.promisifyAll (и Promise.promisify), чтобы добавить обещание готовые методы любого объекта.

var Promise = require('bluebird');
// Somewhere around here, the following line is called
Promise.promisifyAll(connection);

exports.getUsersAsync = function () {
    return connection.connectAsync()
        .then(function () {
            return connection.queryAsync('SELECT * FROM Users')
        });
};

и использовать так:

getUsersAsync().then(console.log);

или

// Spread because MySQL queries actually return two resulting arguments, 
// which Bluebird resolves as an array.
getUsersAsync().spread(function(rows, fields) {
    // Do whatever you want with either rows or fields.
});

добавление измельчители

Bluebird поддерживает множество функций, одна из них-disposers, она позволяет безопасно утилизировать соединение после его окончания с помощью Promise.using и Promise.prototype.disposer. Вот пример из моего приложения:

function getConnection(host, user, password, port) {
    // connection was already promisified at this point

    // The object literal syntax is ES6, it's the equivalent of
    // {host: host, user: user, ... }
    var connection = mysql.createConnection({host, user, password, port});
    return connection.connectAsync()
        // connect callback doesn't have arguments. return connection.
        .return(connection) 
        .disposer(function(connection, promise) { 
            //Disposer is used when Promise.using is finished.
            connection.end();
        });
}

тогда используйте его так:

exports.getUsersAsync = function () {
    return Promise.using(getConnection()).then(function (connection) {
            return connection.queryAsync('SELECT * FROM Users')
        });
};

это автоматически завершит соединение, как только обещание разрешится со значением (или отклонит с Error).

узел.js версия 8.0.0+:

вы не должны использовать птица чтобы больше обещать методы API узла. Потому что, начиная с версии 8+ вы можете использовать родной util.обещай:

const util = require('util');

const connectAsync = util.promisify(connection.connectAsync);
const queryAsync = util.promisify(connection.queryAsync);

exports.getUsersAsync = function () {
    return connectAsync()
        .then(function () {
            return queryAsync('SELECT * FROM Users')
        });
};

теперь, не нужно использовать любую стороннюю lib, чтобы сделать promisify.

предполагая, что ваш API адаптера базы данных не выводит Promises сам ты можешь сделать что-то вроде:

exports.getUsers = function () {
    var promise;
    promise = new Promise();
    connection.connect(function () {
        connection.query('SELECT * FROM Users', function (err, result) {
            if(!err){
                promise.resolve(result);
            } else {
                promise.reject(err);
            }
        });
    });
    return promise.promise();
};

если API базы данных поддерживает Promises вы могли бы сделать что-то вроде: (здесь вы видите силу обещаний, ваш обратный вызов пух в значительной степени исчезает)

exports.getUsers = function () {
    return connection.connect().then(function () {
        return connection.query('SELECT * FROM Users');
    });
};

используя .then() чтобы вернуть новое (вложенное) обещание.

звонок с:

module.getUsers().done(function (result) { /* your code here */ });

---

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

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

тогда вы можете написать:

getUsers().then(callback)

callback будет вызван с результатом обещания, возвращенного от getUsers, т. е. result

используя библиотеку Q например:

function getUsers(param){
    var d = Q.defer();

    connection.connect(function () {
    connection.query('SELECT * FROM Users', function (err, result) {
        if(!err){
            d.resolve(result);
        }
    });
    });
    return d.promise;   
}

ниже код работает только для узла-v > 8.x

Я использую этот Promisified MySQL middleware для узла.js

прочитать эту статью создайте промежуточное программное обеспечение базы данных MySQL с узлом.js 8 и Async / Await