King_Tech/Blog.Core
King_Tech/Blog.Core
2
0
Fork 0
mirror of https://github.com/anjoy8/Blog.Core.git synced 2024-09-20 23:48:27 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

防止同一范围内，异步执行事务误触非当前线程事务

Browse Source
This commit is contained in:
Linlccc 2022-02-26 14:39:05 +08:00
parent c0b6a75c79
commit 3ba865704a
1 changed files with 27 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
Blog.Core.Repository/UnitOfWork/UnitOfWork.cs
View File

@ -8,9 +8,12 @@ namespace Blog.Core.Repository.UnitOfWork
{
private readonly ISqlSugarClient _sqlSugarClient;
private int _tranCount { get; set; }
public UnitOfWork(ISqlSugarClient sqlSugarClient)
{
_sqlSugarClient = sqlSugarClient;
_tranCount = 0;
}
/// <summary>
@ -25,25 +28,40 @@ namespace Blog.Core.Repository.UnitOfWork
public void BeginTran()
{
GetDbClient().BeginTran();
lock (this)
{
_tranCount++;
GetDbClient().BeginTran();
}
}
public void CommitTran()
{
try
lock (this)
{
GetDbClient().CommitTran(); //
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
GetDbClient().RollbackTran();
_tranCount--;
if (_tranCount == 0)
{
try
{
GetDbClient().CommitTran();
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
GetDbClient().RollbackTran();
}
}
}
}
public void RollbackTran()
{
GetDbClient().RollbackTran();
lock (this)
{
_tranCount--;
GetDbClient().RollbackTran();
}
}
}