Sequelize批量操作引发MariaDB连接占用过高及超时问题求助

我开发的Web应用允许用户上传含记录的制表符分隔文件，由ExpressJs（NodeJS）编写的后端API处理。使用Sequelize执行CRUD操作时，发现当文件包含200+条记录时，Sequelize的数据库连接占用量极高，进而引发SequelizeConnectionAcquireTimeoutError，因无法获取数据库连接导致操作失败。

在API层中，我直接遍历传入的数百条记录，为每条记录触发INSERT和UPDATE操作。由于Sequelize的CRUD操作是JavaScript Promise，且Node为单线程架构，这些请求会被排队，前数百个请求占用数据库连接，剩余请求因连接池的获取超时设置而超时。

除了使用队列机制或循环内限流外，是否有其他解决方法？

• 使用Sequelize批量操作API
  放弃单条记录的create/update，改用bulkCreate处理批量插入，一次SQL语句插入多条记录；对于更新操作，可以收集需要更新的记录数据，使用update配合where条件批量更新，或者用bulkCreate的updateOnDuplicate参数，在插入时自动更新重复键的记录。示例：

  // 批量插入，存在则更新指定字段
  await Model.bulkCreate(records, {
    updateOnDuplicate: ['field1', 'field2']
  });
  

  这种方式能大幅减少数据库连接请求次数，降低连接池压力。

• 用事务复用单个连接
  将所有批量操作包裹在Sequelize事务中，事务会复用同一个数据库连接，不会占用连接池中的多个连接。即使处理数百条记录，也只会占用一个连接，避免连接耗尽。示例：

  const transaction = await sequelize.transaction();
  try {
    await Model.bulkCreate(records, { transaction });
    // 其他批量操作...
    await transaction.commit();
  } catch (err) {
    await transaction.rollback();
    throw err;
  }
  

• 优化CRUD逻辑，合并查询与操作
  先通过一次批量查询区分新增和更新记录：比如用findAll查询所有已存在的记录ID，将上传记录拆分为新增列表和更新列表，分别执行批量插入和批量更新，避免每条记录单独发起查询和操作。

• 调整连接池配置（辅助优化）
  可以适当调整Sequelize连接池的max（最大连接数）和acquire（连接获取超时时间）参数，但这只是缓解手段，核心还是减少连接请求次数。示例：

  const sequelize = new Sequelize({
    // 其他配置
    pool: {
      max: 10, // 根据数据库性能调整
      acquire: 60000, // 延长超时时间，单位毫秒
      idle: 10000
    }
  });
  

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