如何让Sequelize识别MySQL主键并修复bulkCreate()插入问题

1. 先确认模型与关联配置的正确性 #

Supplier模型（必须保证主键自增） #

const Supplier = sequelize.define('Supplier', {
  supplier_id: {
    type: DataTypes.INTEGER,
    primaryKey: true,
    autoIncrement: true, // 核心：开启自增，确保数据库自动生成ID
    allowNull: false
  },
  seedcompany_name: {
    type: DataTypes.STRING,
    unique: true // 避免重复插入同名供应商
  }
  // 其他供应商字段按需添加
}, { timestamps: false });

TreeSeed模型（主键+外键关联） #

const TreeSeed = sequelize.define('TreeSeed', {
  seed_id: {
    type: DataTypes.INTEGER,
    primaryKey: true,
    autoIncrement: true,
    allowNull: false
  },
  supplier_id: {
    type: DataTypes.INTEGER,
    allowNull: false,
    references: {
      model: 'Suppliers', // 注意表名默认是复数，自定义表名需加tableName配置
      key: 'supplier_id'
    }
  }
  // 其他树种字段按需添加
}, { timestamps: false });

// 建立一对多关联
Supplier.hasMany(TreeSeed, { foreignKey: 'supplier_id' });
TreeSeed.belongsTo(Supplier, { foreignKey: 'supplier_id' });

2. 调整批量插入顺序：先插供应商，再插树种 #

TreeSeed依赖Supplier的supplier_id，必须保证供应商数据先入库，再处理树种数据。用findOrCreate避免重复插入：

async function batchInsert(rawTreeSeedList) {
  // 1. 提取并去重所有供应商名称
  const uniqueSupplierNames = [...new Set(rawTreeSeedList.map(item => item.seedcompany_name))];
  
  // 2. 批量插入/查询供应商，确保数据存在
  const supplierEntries = await Promise.all(
    uniqueSupplierNames.map(name => 
      Supplier.findOrCreate({
        where: { seedcompany_name: name },
        defaults: {} // 若有其他供应商字段，在这里补充
      })
    )
  );
  
  // 3. 建立供应商名称到ID的映射
  const nameToIdMap = {};
  supplierEntries.forEach(([supplier]) => {
    nameToIdMap[supplier.seedcompany_name] = supplier.supplier_id;
  });
  
  // 4. 处理树种数据，替换为合法的supplier_id
  const processedTreeSeeds = rawTreeSeedList.map(item => ({
    ...item,
    supplier_id: nameToIdMap[item.seedcompany_name],
    seedcompany_name: undefined // 移除无关字段
  }));
  
  // 5. 用事务保证插入原子性
  const transaction = await sequelize.transaction();
  try {
    await TreeSeed.bulkCreate(processedTreeSeeds, { transaction });
    await transaction.commit();
  } catch (err) {
    await transaction.rollback();
    throw err; // 抛出错误便于上层处理
  }
}

3. 解决seed_id为NULL的问题 #

• 检查数据库表结构：执行SQL DESCRIBE TreeSeeds;，确认seed_id是INT PRIMARY KEY AUTO_INCREMENT。如果不是，手动修改表或在开发环境用sequelize.sync({ alter: true })同步模型。
• 禁止手动设置seed_id：批量插入时不要给seed_id赋值，让数据库自动生成，否则会覆盖自增逻辑。

4. 排查工具函数与SQL日志 #

• 打印processedTreeSeeds，确认每个条目都有合法的supplier_id，且无seed_id字段。
• 开启Sequelize日志，查看执行的SQL语句：

const sequelize = new Sequelize('your_db', 'user', 'pwd', {
  // 其他配置
  logging: console.log // 打印所有执行的SQL
});

通过日志可以直观看到供应商是否执行了INSERT，树种插入语句的参数是否正确。

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