解决后如何停止承诺链？

Question

我想在通过某些条件解决后停止 Promise 链。下面的代码可能有助于理解我在说什么。

function update(id, data) {
    return new Promise((resolve, reject) => {
        let conn;

        pool.get()
        .then((db) => {
            conn = db;

            if(Object.keys(data).length === 0) {
                return resolve({ updated: 0 });
            }
            else {
                return generateHash(data.password);
            }
        })
        .then((hash) => {
            conn.query("UPDATE ... ", (err, queryResult) => {
                if(err) {
                    throw err;
                }

                resolve({ updated: queryResult.affectedRows });
            });
        })
        .catch((err) => { ... })
    });
}

请注意，pool.get() 是承诺包装的 API，用于从我制作的 MySQL 模块获取连接池。

我想要做的是更新用户数据。为了节省服务器资源，如果没有数据要更新，我避免更新（Object.keys（data）.length === 0）。

当我尝试这段代码时，即使没有要更新的数据，第二次 then(update db) 也总是发生！

我读了this post，但没有用。为什么当我调用“return resolve();”时承诺链没有停止？以及如何正确停止它？我真的很喜欢使用 Promises，但有时，这种事情会让我发疯。非常感谢帮助我解决这个问题。谢谢！

附：反正我用的是node v6.2.2。

Answer 1

为什么当我调用“return resolve();”时，promise 链没有停止？

您已经从当前的then 回调中返回并履行了外部承诺。但这并没有“停止”任何事情，那么then 链仍将继续通过回调的返回值进行解析。

以及如何正确停止它？

您需要put the then call inside the if 才能应用该条件：

pool.get()
.then((db) => {
    …
    if (Object.keys(data).length === 0) {
        …({ updated: 0 });
    } else {
        return generateHash(data.password)
        .then((hash) => {
            conn.query("UPDATE ... ", (err, queryResult) => {
                …
            });
        })
    }
})
.catch((err) => { ... })

无论如何，您都应该避免使用Promise constructor antipattern！你应该只使用promisify query 方法：

function query(conn, cmd) {
    return new Promise((resolve, reject) => {
        conn.query(cmd, (err, queryResult) => {
            if (err) reject(err); // Don't throw!
            else resolve(queryResult);
        });
    });
}

然后使用它：

function update(id, data) {
    return pool.get()
    .then(conn => {
        if (Object.keys(data).length === 0) {
            conn.close(); // ???
            return { updated: 0 };
        } else {
            return generateHash(data.password)
            .then(hash => {
                return query(conn, "UPDATE ... ")
            }).then(queryResult => {
                conn.close(); // ???
                return { updated: queryResult.affectedRows };
            }, err => {
                …
                conn.close(); // ???
            });
        }
    });
}

请注意，如果您事先知道不会进行任何查询，则从池中获取连接可能没有意义，因此您可能应该将 if 放在顶层：

function update(id, data) {
   if (Object.keys(data).length === 0) {
       return Promise.resolve({ updated: 0 });
    } else {
       return pool.get()
       .then(conn => {
            return generateHash(data.password)
            .then(hash => {
                return query(conn, "UPDATE ... ")
            }).then(queryResult => {
                conn.close(); // ???
                return { updated: queryResult.affectedRows };
            }, err => {
                …
                conn.close(); // ???
            });
        });
    }
}

Answer 2

这是使用if 语句的好情况：

function update(id, data) {
    if (Object.keys(data).length === 0) {
        return Promise.resolve({ updated: 0 }); 
    }

    let conn;

    return pool.get()
        .then((db) => {
            conn = db;

            return generateHash(data.password);
        })
        .then((hash) => {
            return new Promise(function (resolve, reject) {
                conn.query("UPDATE ... ", (err, queryResult) => {
                    if(err) {
                        reject(err);
                    }

                    resolve({ updated: queryResult.affectedRows });
                });
            });
        })
        .catch((err) => { ... })
}