从两个不同的 mysql 查询调用时，promise 返回 undefined

Question

我有两个运行承诺的 mysql 查询。

第一个是更新 mysql 表上的信息，然后解决问题并调用下一个 mysql 查询。问题是，当它调用下一个 mysql 查询时，promise 返回 UNDEFINED，我不知道为什么。当我在我的节点 js 服务器发布请求中 console.log 它时，它给出了未定义的。我在代码中记录了哪些区域存在问题。

UpdateUserPath = (data) => new Promise((resolve,reject)=>{
    data.UPDATE_DT = getDateTime();
    db.query('UPDATE path  UPDATE_DT = ?  where Owner = ?',
        [data.UPDATE_DT, data.Owner], function(err,results,fields){
        if(err){
            reject('Could not update user path');
        }else{
            if(results.affectedRows > 0){
                data.ID = null;
                data.UPDATE_DT = null;
                // The problem is here, when this gets resolved it calls the other function SaveUserPath
                resolve(saveUserPath(data));
            }else{
                reject('Could not update user path');
            }
        }
    });
});


saveUserPath = (data) => new Promise((resolve, reject) => {
    db.query('INSERT INTO path SET ?', data, function (error, results, fields) {
        if (error) {
            reject('Could not insert path');
        }else{
            var Id = results.insertId;

            db.query('UPDATE path SET ORIG_ID = ? where ID = ?',[Id, Id], function(err,results,fields){
                if(err){
                    reject('Could not insert row to path  table - saveuserpath');
                }else{
                    if(results.affectedRows > 0){
                       // THIS INFORMATION HERE IS UNDEFINED
                        return resolve(results[0]);
                    }else{
                        reject('Could not update path');
                    }
                }
            });
        }
    });
});

在服务器中它被这样调用。

getUserPath(req.session.userid).then((path_data)=>{
                path_data.status = 1;
                UpdateUserPath(path_data).then((result)=>{
                    console.log(result); // THIS IS UNDEFINED
                });
            });

我想知道resolve(saveUserPath(data)); 是否是调用不在服务器外部的另一个承诺的正确方法。 我正考虑这样做。

UpdateUserPath(path_data).then((result)=>{
   saveUserPath(result).then((result_save) => {
     console.log(result_save); // THIS MIGHT WORK 
   });
});

但是为什么正常的方式是错误的。

Answer 1

我有几个猜测为什么它不起作用，但是有很多错误的地方，所以最好只是清理代码以更好地设计。

当在一个基于 Promise 的接口中组合多个异步回调驱动的操作时，您确实希望在底层函数的最低级别上 Promisify，然后您可以利用 Promise 的优势实现所有控制流和错误处理。我认为这也将使您的问题消失，并可能修复其他几个错误。

// promisify db.query()
// if a promisified interface is built into your database, use that one instead
db.queryP = function(q, d) {
    return new Promise((resolve, reject) {
        db.query(q, d, (err, results, fields) => {
            if (err) {
                reject(err);
            } else {
                resolve(results);
            }
        });
    });
}

UpdateUserPath = function(data) {
    data.UPDATE_DT = getDateTime();
    let q = 'UPDATE path  UPDATE_DT = ?  where Owner = ?';
    return db.queryP(q, [data.UPDATE_DT, data.Owner]).then(results => {
        if (results.affectedRows > 0) {
            data.ID = null;
            data.UPDATE_DT = null;
            return saveUserPath(data);
        } else {
            throw new Error('Could not update user path');
        }
    });
}

saveUserPath = function(data) {
    let q = 'INSERT INTO path SET ?'
    return db.queryP(q, data).then(results => {
        let q2 = 'UPDATE path SET ORIG_ID = ? where ID = ?';
        var Id = results.insertId;
        return db.queryP(q2, [Id, Id]).then(results2 => {
            if (results2.affectedRows > 0) {
                return results2[0];
            } else {
                throw new Error('Could not update path');
            }
        });
    });
}

getUserPath(req.session.userid).then(path_data => {
    path_data.status = 1;
    return UpdateUserPath(path_data);
}).then(result => {
    // process result here
}).catch(err => {
    // process error here
});