节点回调 - 代码不能正常工作

Question

这是我在一个节点中的代码 - 表示一旦sql事务成功完成就发送一封电子邮件！

router.post('/',function(req,res,next){ 
    sql.connect(config).then(function() { 
     var request = new sql.Request(); 
     request.query(`update projects set CIP_NCIP= '${req.body.cip_noncip}' , Capital_Expense ='${req.body.capital_expensed}' , Approval_Status ='Approved' where Project_ID ='${req.body.projid}'`).then(function(recordset) { 
      console.log('Recordset: ' + recordset); 
      console.log('Affected: ' + request.rowsAffected); 
     }).catch(function(err) { 
      if(err) { 
       console.log('Request error: ' + err); 
      } 
     }) 
    }).then(
     transporter.sendMail(mailOptions, function(error, info){ 
      if (error) { 
       console.log(error); 
      } else { 
       console.log('Email sent: ' + info.response); 
      } 
     })).catch(function(err) { 
     if (err) { 
      console.log('SQL Connection Error: ' + err); 
     } 

    }); 
}); 

SQL插入似乎工作，但它不是执行的代码

transporter.sendMail(mailOptions, function(error, info){ 
       if (error) { 
        console.log(error); 
       } else { 
        console.log('Email sent: ' + info.response); 
       } 
      }) 

相当新的回调和ES5该位。建议表示欢迎

Answer 1

根据你当前的代码，你没有以正确的顺序（这可能是也可能不是问题）做实际的事情。试试这个：

var request = sql.Request(); 
sql.connect(config) 
    .then(function() { 
     console.log('UPDATING RECORD...'); 
     return request.query(`update projects set CIP_NCIP= '${req.body.cip_noncip}' , Capital_Expense ='${req.body.capital_expensed}' , Approval_Status ='Approved' where Project_ID ='${req.body.projid}'`); 
    }) 
    .catch(function(err) { 
     if (err) { 
      console.log(`SQL Connection Error: ${err}`); 
     } 
    }) 
    .then(function(recordset) { 
     console.log('Recordset: ' + recordset); 
     console.log('Affected: ' + request.rowsAffected); 
     console.log('SENDING EMAIL...'); 
     return transporter.sendMail(mailOptions); 
    }) 
    .catch(function(err) { 
     if (err) { 
      console.log(`Nodemailer Err: ${err}`); 
     } 
    }) 
    .then(function() { 
     console.log('COMPLETE'); 
    });   
    console.log('CONNECTING...'); 

以上是利用承诺的最大范围内，包括一些记录，应该帮助你缩小那里的问题。这里

FWIW是它会怎样看在ES6（不调试日志记录）

sql.connect(config) 
    .then(() => sql.Request().query('...')) 
    .catch(err => console.error(`SQL Error ${err}`)) 
    .then(() => transporter.sendMail(mailOptions)) 
    .catch(err => console.error(`Nodemailer err: ${err}`); 

Answer 2

看起来你忘了通过执行您提供通过.then方法连接功能原样

return request.query(`update projects set CIP_NCIP= '${req.body.cip_noncip}' , Capital_Expense ='${req.body.capital_expensed}' , Approval_Status ='Approved' where Project_ID ='${req.body.projid}'`).then(function(recordset) { 
      console.log('Recordset: ' + recordset); 
      console.log('Affected: ' + request.rowsAffected); 
     }).catch(function(err) { 
      if(err) { 
       console.log('Request error: ' + err); 
      } 
     }) 

Answer 3

一个承诺如下承诺链返回承诺。

在你的情况有：

sql.connect(config) 
    .then(function() { ... }) 
    .then(valueNotAFunction); 

如果then执行的函数的返回值是一个承诺本身，那么接下来的块等待完成前一个。

的代码块：

transporter.sendMail(mailOptions, function(error, info){ 
    if (error) { 
     console.log(error); 
    } else { 
     console.log('Email sent: ' + info.response); 
    } 
})) 

立即执行，而不是之后在链上一功能已完成。

此外request.query评估为承诺，你不回到链。

您的代码应该是这样的：

sql.connect(config) 
    .then(function() { .... ; return request.query(...) }) 
    .then(function() { .... ; return transporter.sendMail(....) }) 
    .catch(function(error) { console.error(error); }); 

记住transporter.sendMail可能不计算的承诺，所以你可能要与some promisification library把它包起来。