使用Sequelize时，如何将关联记录ID传递至关联的Publishing模型？

我来帮你搞定这个关联建立的问题！核心问题在于你当前用async.parallel同时执行三个操作，导致创建Publishing时还拿不到更新后的Post和刚创建的Event的ID，而且创建Publishing时也没有传入这两个关键的关联ID。下面是具体的解决方案：

第一步：确认模型关联已正确定义 #

首先要确保你的Sequelize模型之间已经配置了正确的关联关系，这样Sequelize才能正确处理外键约束：

// Post 模型
Post.hasMany(Publishing, { foreignKey: 'postId' });

// Event 模型
Event.hasMany(Publishing, { foreignKey: 'eventId' });

// Publishing 模型
Publishing.belongsTo(Post, { foreignKey: 'postId' });
Publishing.belongsTo(Event, { foreignKey: 'eventId' });

第二步：调整执行顺序，传递关联ID #

因为Publishing的创建依赖于Post的更新结果和Event的创建结果，所以不能再用并行执行，需要改成顺序执行。这里推荐用更简洁易读的async/await替代async.parallel，代码如下：

async publishPost(req) {
  try {
    // 1. 更新Post状态并获取更新后的Post实例
    const post = await Post.findOne({
      where: { id: req.query.post_id },
      attributes: ['id', 'state']
    });
    await post.update({ state: 2 });

    // 2. 创建Event并获取新创建的Event实例
    const event = await Event.create({
      instructions: req.query.instructions
    });

    // 3. 创建Publishing，传入postId和eventId建立关联
    const publishing = await Publishing.create({
      postId: post.id,
      eventId: event.id,
      start_date: req.query.startDate,
      end_date: req.query.endDate
    });

    // 返回所有操作结果
    return { updatedPost: post, createdEvent: event, createdPublishing: publishing };
  } catch (error) {
    throw error; // 也可以根据业务需求自定义错误处理逻辑
  }
}

如果你坚持使用async库的替代方案 #

如果你还是想用async库的话，可以用async.waterfall来传递前一步的结果到后一步，保证依赖顺序：

publishPost(req) {
  return new Promise((resolve, reject) => {
    async.waterfall([
      // 第一步：更新Post状态
      (callback) => {
        Post.findOne({
          where: { id: req.query.post_id },
          attributes: ['id', 'state']
        })
        .then(post => post.update({ state: 2 }))
        .then(updatedPost => callback(null, updatedPost))
        .catch(err => callback(err));
      },
      // 第二步：创建Event，接收上一步的更新后Post
      (updatedPost, callback) => {
        Event.create({ instructions: req.query.instructions })
        .then(createdEvent => callback(null, updatedPost, createdEvent))
        .catch(err => callback(err));
      },
      // 第三步：创建Publishing，接收更新后Post和新Event
      (updatedPost, createdEvent, callback) => {
        Publishing.create({
          postId: updatedPost.id,
          eventId: createdEvent.id,
          start_date: req.query.startDate,
          end_date: req.query.endDate
        })
        .then(createdPublishing => callback(null, { updatedPost, createdEvent, createdPublishing }))
        .catch(err => callback(err));
      }
    ], (error, result) => {
      if (error) reject(error);
      else resolve(result);
    });
  });
}

为什么这样能解决问题？ #

• 顺序执行保证了在创建Publishing时，我们已经拿到了更新后的Post的id和刚创建的Event的id
• 显式将postId和eventId传入Publishing.create()，让Sequelize能正确设置外键，从而建立三者的关联关系

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