承诺自定义方法

Question

我对 Node 和 JS 世界还很陌生。我正在尝试实现的是 "modularize" 我的查询并在各种场景中重用它们。这是我的数据库管理员：

'use strict'

const mysql = require('mysql')
var Promise = require('bluebird')
var using = Promise.using
Promise.promisifyAll(require('mysql/lib/Connection').prototype)
Promise.promisifyAll(require('mysql/lib/Pool').prototype)
const config = require('./config')

var pool = mysql.createPool({
    connectionLimit: 100,
    host: config.dbHost,
    user: config.dbUser,
    password: config.dbPassword,
    database: config.db,
    debug: config.dbDebug
})

var getConnection = function () {
    return pool.getConnectionAsync()
        .disposer(function (connection) {
            return connection.release()
        })
}

var query = function (command) {
    return using(getConnection(), function (connection) {
        return connection.queryAsync(command)
    })
}

module.exports = {
    query: query
}

在一个单独的文件中，我想调用一个查询并根据该查询的结果然后调用另一个（第二个使用第一个的结果值）：

utils.method1()
    .then(function (value) {
        utils.method2(value)
    })
    .catch(function (error) {
        console.error('Error while retrieving product id: ' + error)
        res.json({ data: error })
    })

我如何"promisify"我的方法？ 更重要的是：这是分隔 mySQL 查询的正确方法吗？您能推荐一些最佳做法吗？

为了完整起见，这是我执行查询的方法 1：

module.exports = {
    method1: function () {
        // ...sql
        db.query(mysql.format(sql, params))
            .then(function (results) {
                return results[0].id // clearly this is not a promise
            })
            .catch(function (error) {
                console.error('Error while retrieving...: ' + error)
                res.status(500).send('Internal server error')
            })
    }
}

Answer 1

你实际上离承诺很近:)

当然，results[0].id不是承诺，而是一个的最终价值。

您应该做的是 return 您查询的承诺链：

return db.query(mysql.format(sql, params))
    .then(function (results) {
        return results[0].id // clearly this is not a promise
    })
    .catch(function (error) {
        console.error('Error while retrieving...: ' + error)
        res.status(500).send('Internal server error')
    })

这样做，您将 return 一个承诺，该承诺要么以您链的最后一个值解决，要么失败。您可以按照您的要求使用它：

method1.then(function(value){
    // Here, value is results[0].id
})
.catch(function(err){
    // Manage a failed query
});

关于 Promises 的工作原理，您可能想阅读很棒的post：https://blog.domenic.me/youre-missing-the-point-of-promises/

承诺自定义方法

Promisify Custom Method

mysql

node.js

promise

node-mysql

bluebird