Skip to content

事务

Jump to bottom
2881099 edited this page Dec 3, 2020 · 73 revisions

本文所有内容基于单机数据库事务，分布式数据库 TCC/SAGA 方案请移步：https://github.com/2881099/FreeSql.Cloud

1、UnitOfWork 事务

using (var uow = fsql.CreateUnitOfWork())
{
  var songRepo = fsql.GetRepository<Song>();
  var userRepo = fsql.GetRepository<User>();
  songRepo.UnitOfWork = uow; //手工绑定工作单元
  userRepo.UnitOfWork = uow;

  songRepo.Insert(new Song());
  userRepo.Update(...);

  uow.Orm.Insert(new Song()).ExecuteAffrows();
  //注意：uow.Orm 和 fsql 都是 IFreeSql
  //uow.Orm CRUD 与 uow 是一个事务（理解为临时 IFreeSql）
  //fsql CRUD 与 uow 不在一个事务

  uow.Commit();
}

参考：在 asp.net core 中使用 TransactionalAttribute + UnitOfWorkManager 实现多种事务传播

2、DbContext 事务

using (var ctx = fsql.CreateDbContext()) {
  var song = ctx.Set<Song>();
  var user = ctx.Set<User>();
  
  song.Add(new Song());
  user.Update(...);

  ctx.SaveChanges();
}

3、同线程事务

同线程事务，由 fsql.Transaction 管理事务提交回滚（缺点：不支持异步），比较适合 WinForm/WPF UI 主线程使用事务的场景。

用户购买了价值100元的商品：扣余额、扣库存。

fsql.Transaction(() =>  {
  //fsql.Ado.TransactionCurrentThread 获得当前事务对象

  var affrows = fsql.Update<User>()
    .Set(a => a.Wealth - 100)
    .Where(a => a.Wealth >= 100).ExecuteAffrows();
    //判断别让用户余额扣成负数
    
  if (affrows < 1)
    throw new Exception("用户余额不足");
    //抛出异常，回滚事务，事务退出

  affrows = fsql.Update<Goods>()
    .Set(a => a.Stock - 1)
    .Where(a => a.Stock >= 1).ExecuteAffrows();
    //判断别让用库存扣成负数
    
  if (affrows < 1)
    throw new Exception("商品库存不足");
    //抛出异常，回滚事务，事务退出
});

同线程事务使用简单，需要注意的限制：

  • 事务对象在线程挂载，每个线程只可开启一个事务连接，嵌套使用的是同一个事务；

  • 事务体内代码不可以切换线程，因此不可使用任何异步方法，包括FreeSql提供的数据库异步方法（可以使用任何 Curd 同步方法）；

4、外部事务

在与其他开源项目一起使用时，事务由外部开启，使用 WithTransaction 将事务对象传入执行。

await fsql.Update<xxx>()
  .WithTransaction(指定事务)
  .Set(a => a.Clicks + 1)
  .ExecuteAffrowsAsync();

ISelect、IInsert、IUpdate、IDelete，都支持 WithTransaction 方法。

5、更新排他锁

var user = fsql.Select<User>().ForUpdate(true).Where(a => a.Id == 1).ToOne();
//SELECT ... FROM User a for update nowait

for update 在 Oracle/PostgreSQL/MySql 是通用的写法，我们对 SqlServer 做了特别适配，执行的 SQL 语句大致如下：

SELECT ... FROM [User] a With(UpdLock, RowLock, NoWait)

6、示范代码

fsql.Transaction(() => //全局线程事务
{
  fsql.Insert(new Products()).ExecuteAffrows();
  fsql.Insert(new Products()).ExecuteAffrows();
});


using (var uow = fsql.CreateUnitOfWork()) //使用 UnitOfWork 事务
{
  var repo = uow.GetRepository<Products>();
  repo.Insert(new Products());

  uow.Orm.Insert(new Products()).ExecuteAffrows(); //正常
  fsql.Insert(new Products()).ExecuteAffrows(); //错误，没有传事务
  fsql.Insert(new Products()).WithTransaction(uow.GetOrBeginTransaction()).ExecuteAffrows(); //正常
}


using (var ctx = fsql.CreateDbContext()) //使用 DbContext 事务
{
  ctx.Add(new Products());

  ctx.Orm.Insert(new Products()).ExecuteAffrows(); //正常
  fsql.Insert(new Products()).ExecuteAffrows(); //错误，没有传事务
  fsql.Insert(new Products()).WithTransaction(ctx.UnitOfWork.GetOrBeginTransaction()).ExecuteAffrows(); //正常
}


using (var uowManager = new UnitOfWorkManager(fsql)) //使用 UnitOfWorkManager 管理类事务
{
  using (var uow = uowManager.Begin())
  {
    uow.Orm.Insert(new Products()).ExecuteAffrows(); //正常
    fsql.Insert(new Products()).ExecuteAffrows(); //错误，没有传事务
    fsql.Insert(new Products()).WithTransaction(uow.GetOrBeginTransaction()).ExecuteAffrows(); //正常

    using (var uow2 = uowManager.Begin()) //与 uow 同一个事务
    {
      var repo1 = fsql.GetRepository<Products>();
      repo1.UnitOfWork = uow2;
      repo1.Insert(new Products());

      uow2.Commit();//事务还未提交
    }

    uow.Commit();//事务提交
  }
}
  • IFreeSql Curd 方法若不是使用同线程事务，需要指定 WithTransaction 传入事务；
  • IUnitOfWork Orm 与工作单元事务一致；
  • FreeSql.IBaseRepository curd 方法需要指定 UnitOfWork 传递工作单元事务；
  • FreeSql.DbContext 自带事务；
  • UnitOfWorkManager 适合做跨方法事务；

扩展阅读：IFreeSql 事务另类玩法，理解上面各种事务场景之后再看会更佳

更多资料

Basic

使用指南

学习与交流

信息

Clone this wiki locally