|
|
|
@ -30,8 +30,6 @@ namespace Volo.Abp.Uow.EntityFrameworkCore |
|
|
|
|
|
|
|
public async Task CommitAsync() |
|
|
|
{ |
|
|
|
await DbContextTransaction.CommitAsync(CancellationTokenProvider.Token); |
|
|
|
|
|
|
|
foreach (var dbContext in AttendedDbContexts) |
|
|
|
{ |
|
|
|
if (dbContext.As<DbContext>().HasRelationalTransactionManager() && |
|
|
|
@ -42,6 +40,8 @@ namespace Volo.Abp.Uow.EntityFrameworkCore |
|
|
|
|
|
|
|
await dbContext.Database.CommitTransactionAsync(CancellationTokenProvider.Token); |
|
|
|
} |
|
|
|
|
|
|
|
await DbContextTransaction.CommitAsync(CancellationTokenProvider.Token); |
|
|
|
} |
|
|
|
|
|
|
|
public void Dispose() |
|
|
|
@ -51,8 +51,6 @@ namespace Volo.Abp.Uow.EntityFrameworkCore |
|
|
|
|
|
|
|
public async Task RollbackAsync(CancellationToken cancellationToken) |
|
|
|
{ |
|
|
|
await DbContextTransaction.RollbackAsync(CancellationTokenProvider.FallbackToProvider(cancellationToken)); |
|
|
|
|
|
|
|
foreach (var dbContext in AttendedDbContexts) |
|
|
|
{ |
|
|
|
if (dbContext.As<DbContext>().HasRelationalTransactionManager() && |
|
|
|
@ -63,6 +61,8 @@ namespace Volo.Abp.Uow.EntityFrameworkCore |
|
|
|
|
|
|
|
await dbContext.Database.RollbackTransactionAsync(CancellationTokenProvider.FallbackToProvider(cancellationToken)); |
|
|
|
} |
|
|
|
|
|
|
|
await DbContextTransaction.RollbackAsync(CancellationTokenProvider.FallbackToProvider(cancellationToken)); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|