節點回調 - 代碼不能正常工作

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把它包起來。