javascript - 解决后如何停止 promise 链？

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() 是 promise 包装的 API，用于从我制作的 MySQL 模块获取连接池。

我正在尝试做的是更新用户数据。为了节省服务器资源，如果没有要更新的数据，我避免更新(Object.keys(data).length === 0)。

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

我读了this post ，但没有奏效。为什么当我调用“return resolve();”时 promise 链没有停止？以及如何正确停止它？我真的很喜欢使用 Promises，但有时，这种事情让我发疯。能帮我解决这个问题将不胜感激。谢谢!

附言无论如何，我正在使用 Node v6.2.2。

Answer 1

Why the promise chain wasn't stopped when I called "return resolve();"?

您已经从当前的 then 回调中返回并履行了外部 promise 。但这并没有“停止”任何事情，然后 then 链仍然会通过使用回调的返回值进行解析来继续。

And how to I stop it properly?

您需要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(); // ???
            });
        });
    }
}