# 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();
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

参考:在 asp.net core 中使用 TransactionalAttribute + UnitOfWorkManager 实现多种事务传播 (opens new window)

# 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();
}
1
2
3
4
5
6
7
8
9

# 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("商品库存不足");
    //抛出异常,回滚事务,事务退出
});
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

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

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

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

# 4、外部事务

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

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

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
1
2

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

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

# 6、示范代码

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

using (var uow = fsql.CreateUnitOfWork()) //使用 UnitOfWork 事务
{
  fsql.Insert(new Products()).ExecuteAffrows(); //错误,没有传事务
  fsql.Insert(new Products()).WithTransaction(uow.GetOrBeginTransaction()).ExecuteAffrows();
  fsql.Insert(new Products()).WithTransaction(uow.GetOrBeginTransaction()).ExecuteAffrows();

  var repo1 = uow.GetRepository<Products>();
  repo1.Insert(new Products());
}

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

  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())
  {
    fsql.Insert(new Products()).ExecuteAffrows(); //错误,没有传事务
    fsql.Insert(new Products()).WithTransaction(uow.GetOrBeginTransaction()).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();//事务提交
  }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
  • IFreeSql curd 方法若不是使用同线程事务,需要指定 WithTransaction 传入事务;
  • FreeSql.IBaseRepository curd 方法需要指定 UnitOfWork 传递工作单元事务;
  • FreeSql.DbContext 自带事务;
  • UnitOfWorkManager 适合做跨方法事务;

扩展阅读:IFreeSql 事务另类玩法,理解上面各种事务场景之后再看会更佳 (opens new window)