使用查询构建器的TypeORM事务

基础概念

TypeORM 是一个强大的 ORM（对象关系映射）库，用于 Node.js 环境，支持多种数据库。事务是数据库操作中的一个重要概念，它确保一组数据库操作要么全部成功，要么全部失败，从而保持数据的一致性。

类型

TypeORM 支持两种类型的事务：

显式事务：开发者手动开始和结束事务。
隐式事务：某些数据库操作自动开启事务，并在操作完成后提交或回滚。

应用场景

金融交易：如银行转账，需要确保资金从一个账户转移到另一个账户的过程是原子的。
订单处理：创建订单、扣减库存和更新用户积分等操作需要作为一个整体执行。
数据同步：在不同数据库之间同步数据时，确保数据的一致性。

示例代码

以下是一个使用 TypeORM 查询构建器进行事务处理的示例：

import { getManager } from 'typeorm';
import { User } from './entity/User'; // 假设你有一个 User 实体

async function transferMoney(fromId: number, toId: number, amount: number) {
  const entityManager = getManager();

  try {
    // 开始事务
    await entityManager.transaction(async transactionalEntityManager => {
      // 查找转出账户
      const fromUser = await transactionalEntityManager.findOne(User, fromId);
      if (!fromUser || fromUser.balance < amount) {
        throw new Error('Insufficient balance');
      }

      // 查找转入账户
      const toUser = await transactionalEntityManager.findOne(User, toId);
      if (!toUser) {
        throw new Error('Recipient not found');
      }

      // 更新转出账户余额
      fromUser.balance -= amount;
      await transactionalEntityManager.save(fromUser);

      // 更新转入账户余额
      toUser.balance += amount;
      await transactionalEntityManager.save(toUser);
    });

    console.log('Money transferred successfully');
  } catch (error) {
    console.error('Failed to transfer money:', error.message);
    // 事务会自动回滚
  }
}

// 调用函数
transferMoney(1, 2, 100);