使用查询构建器的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);