如何在无预定义模型时用Sequelize向MySQL批量插入JSON数组数据

完全可以实现，不需要提前预定义固定的Sequelize模型，常用有两种可行方案，都支持5万+量级的批量数据插入：

方案1：动态创建临时模型后批量插入 #

这种方案可以复用Sequelize模型的内置能力，不需要手动拼接SQL，适合表结构不固定或者想复用ORM能力的场景。
操作步骤：

• 取JSON数组的第一条数据作为样本，推断字段列表和对应类型，也可以手动指定类型避免自动推断偏差
• 调用sequelize.define动态生成临时模型，绑定目标数据表
• 调用bulkCreate方法批量插入，配置分批参数避免请求过大
  代码示例：

// 前置条件：已初始化sequelize实例，待插入JSON数组为rawData
const sampleRecord = rawData[0];
const fieldAttributes = {};
// 这里示例统一设置为STRING类型，可根据实际业务调整类型推断逻辑
Object.keys(sampleRecord).forEach(fieldKey => {
  fieldAttributes[fieldKey] = { type: Sequelize.STRING };
});
// 动态生成临时模型，绑定目标表
const TempInsertModel = sequelize.define('TempInsertModel', fieldAttributes, {
  tableName: '你的实际目标表名',
  timestamps: false // 不需要自动加createdAt、updatedAt字段时关闭
});
// 批量插入，设置分批大小降低数据库压力
await TempInsertModel.bulkCreate(rawData, {
  batchSize: 1000, // 可根据数据库配置调整为1000~5000
  validate: false // 不需要字段校验时可关闭，提升插入速度
});

方案2：直接执行原始SQL批量插入 #

这种方案性能更高，适合你明确知道目标表结构，不想生成额外临时模型的场景。
操作步骤：

• 提取所有JSON对象的公共字段列表，拼接插入SQL的字段部分
• 生成参数化占位符，扁平化所有插入值避免SQL注入风险
• 调用sequelize.query执行插入，大数据量建议分批处理
  代码示例：

// 前置条件：已初始化sequelize实例，待插入JSON数组为rawData
const fieldList = Object.keys(rawData[0]);
// 生成占位符，比如(?,?,?),(?,?,?)的格式
const valuePlaceholders = rawData.map(() => `(${fieldList.map(() => '?').join(',')})`).join(',');
// 扁平化所有插入值为一维数组
const insertValues = rawData.flatMap(record => fieldList.map(field => record[field]));

const insertSql = `INSERT INTO 你的实际目标表名 (${fieldList.join(',')}) VALUES ${valuePlaceholders}`;
await sequelize.query(insertSql, {
  replacements: insertValues,
  type: Sequelize.QueryTypes.INSERT
});

注意事项 #

• 5万条数据不管用哪种方案都建议分批插入，避免内存溢出或者数据库连接超时，分批大小可根据数据库性能调整在1000~5000区间
• 插入前可暂时关闭目标表的索引、外键约束，插入完成后再重建，能大幅提升插入速度
• 动态模型方案如果出现字段类型不匹配问题，可以手动调整fieldAttributes中的类型定义，避免数据转换错误

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