如何在读取完对象数组后关闭Sequelize数据库连接？

我编写了一段从对象数组读取数据并加载到MS SQL数据库的脚本，若不调用Sequelize.close，代码会在无后续对象时陷入等待状态。希望在读取完对象数组后关闭数据库连接，现有代码如下：

async.eachSeries(grouparrobj,(item,cb) =>{ 
  async.each(item,(items,callback)=>{ 
    var queryvar = `INSERT INTO ${tablename} (ID,NAME) VALUES ('${items.ID}','${items.name}')`; 
    sequelize.query(queryvar).then(results =>{ 
      callback(); 
    }) 
  },(err,result) =>{ 
    if (err) { 
      console.log('Error',err); 
    } else{ 
      console.log(`Finished processing level ${item}`) 
      cb(); 
    } 
  }) 
}, (err,success) => cb(err,success); )

请问该如何实现此需求？

解决方案 #

嘿，这个问题我之前处理过！核心思路就是在所有异步插入操作完全结束后，调用sequelize.close()——而async.eachSeries最外层的最终回调，就是干这个的最佳时机，因为它只会在所有层级的迭代都完成（不管成功还是失败）后才触发。

另外还要补个小细节：你原来的代码里没捕获sequelize.query()的错误，万一插入失败，callback()永远不会执行，整个流程会直接卡住，连关闭连接的机会都没有，所以必须加上错误捕获。

修改后的完整代码如下：

async.eachSeries(grouparrobj, (item, cb) => {
  async.each(item, (items, callback) => {
    var queryvar = `INSERT INTO ${tablename} (ID,NAME) VALUES ('${items.ID}','${items.name}')`;
    sequelize.query(queryvar)
      .then(results => {
        callback();
      })
      // 捕获查询错误，避免流程卡住
      .catch(queryErr => {
        console.log('插入数据出错:', queryErr);
        callback(queryErr);
      });
  }, (err, result) => {
    if (err) {
      console.log('Error processing item:', err);
      // 传递错误给外层回调
      cb(err);
    } else {
      console.log(`Finished processing level ${item}`);
      cb();
    }
  });
}, (finalErr, success) => {
  // 所有操作完成后，执行关闭连接
  sequelize.close()
    .then(() => {
      console.log('数据库连接已成功关闭');
      // 触发最终的回调逻辑
      cb(finalErr, success);
    })
    .catch(closeErr => {
      console.log('关闭数据库连接时出错:', closeErr);
      // 优先传递关闭时的错误，没有的话用之前的操作错误
      cb(closeErr || finalErr, success);
    });
});

关键说明 #

1. 关闭时机：最外层async.eachSeries的第三个参数是全局完成回调，此时所有层级的数组遍历和数据库插入都已结束，在这里调用sequelize.close()刚好能满足你的需求。
2. 错误处理：给sequelize.query()添加.catch()，确保任何插入错误都能被捕获并传递到回调函数，避免异步流程“挂起”。
3. 连接关闭的异步处理：sequelize.close()本身是异步操作，所以要用.then()和.catch()处理它的结果，确保连接确实被关闭，同时能处理关闭过程中可能出现的异常。

内容的提问来源于stack exchange，提问作者alangilbi