使用Strapi搭配MySQL时如何实现数据库commit与rollback事务操作

Strapi底层基于Knex.js实现数据库操作，事务能力直接复用Knex的事务机制，适配MySQL等所有支持事务的数据库，具体实现方法如下：

操作步骤 #

方式1：手动控制事务（灵活控制提交/回滚时机） #

• 第一步：开启事务，获取事务实例

  const transaction = await strapi.db.connection.transaction();
  

• 第二步：执行事务内的所有数据库操作，所有操作都需要绑定同一个事务实例
  Strapi的Query Engine、Entity Service都支持transacting参数，写法一致：

  try {
    // 示例操作1：创建文章
    const newArticle = await strapi.db.query('api::article.article').create({
      data: {
        title: '测试文章',
        content: '事务测试内容'
      },
      transacting: transaction // 绑定事务实例
    });
  
    // 示例操作2：更新关联分类数据
    await strapi.entityService.update('api::category.category', 1, {
      data: {
        articles: [...existingArticles, newArticle.id]
      },
      transacting: transaction // 绑定同一个事务实例
    });
  
    // 所有操作执行成功，提交事务
    await transaction.commit();
    return { success: true, data: newArticle };
  } catch (error) {
    // 任意操作报错，回滚所有事务内的操作
    await transaction.rollback();
    return { success: false, error: error.message };
  }
  

方式2：自动管理事务（简化写法） #

如果不需要手动控制提交/回滚时机，可以直接给transaction方法传入回调函数，Knex会自动处理提交和回滚逻辑：

• 回调执行无报错：自动提交事务，返回回调的返回值
• 回调执行报错：自动回滚事务，抛出错误

try {
  const newArticle = await strapi.db.connection.transaction(async (trx) => {
    // 事务内所有操作绑定入参的trx实例
    const article = await strapi.db.query('api::article.article').create({
      data: { title: '自动事务测试' },
      transacting: trx
    });
    await strapi.entityService.update('api::category.category', 1, {
      data: { articles: [...existingArticles, article.id] },
      transacting: trx
    });
    return article;
  });
  return { success: true, data: newArticle };
} catch (error) {
  return { success: false, error: error.message };
}

注意事项 #

• 仅MySQL的InnoDB引擎支持事务：MyISAM引擎不支持事务能力，Strapi默认创建的MySQL表均为InnoDB引擎，手动修改过表引擎的需要先确认
• 所有事务内的操作必须绑定同一个事务实例：未指定transacting参数的操作不会被纳入事务，出错时不会回滚
• 手动管理事务时必须调用commit/rollback：忘记调用会导致数据库连接泄漏，影响服务稳定性

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