mysql - 使用异步等待插入每个

Question

查询执行错误

var records = [{name:'John',age:24},{name:'Sarah',age:28},{name:'Linda',age:23}];

connection.getSession().then(session => {
   async function insertRecords() {
      await Promise.all(records.map(async function (element) {
         let util = {};
         util['name'] = element['name'];
         util['age'] = element['age'] || null;                   
         let query = `INSERT INTO users SET
           name =?,
           age=?
           ON DUPLICATE KEY UPDATE
            name=VALUES(name),
            age=VALUES(age)`;

        session.sql(query).bind([util.name, util.age]).execute()
           .then(() => {})
           .catch((error) => {
              console.error('cannot execute the query');
              console.error('error', error);
           });
      }))
   }

   insertRecords()
      .then(data => console.log('data', data))
      .catch(err => console.log('err', err))

}).catch((err) => {
    console.error(err);
    session.close();
});

我在执行时收到以下错误。

{ 严重性:0， 代码:5015， sqlState: 'HY000', msg: '参数太多' } }

Answer 1

在您的 Promise.all 中，你map上records但您的解析器函数不会返回任何内容。您需要返回一个 promise 。为此，您只需替换 session.sql block 包含以下内容:return session.sql(query).bind([util.name, util.age]).execute() .

这会将 Promise 数组返回到 Promise.all ，并且它会起作用。当您调用 insertRecords 时，错误处理已经完成。函数，因此您无需在解析器中担心它。