From bcfe85220ba26c448acddde4a0d6fcc3c9dd38f0 Mon Sep 17 00:00:00 2001 From: Bernd Schoolmann Date: Wed, 29 Jan 2025 19:05:30 +0100 Subject: [PATCH] Remove rollback --- .../Repositories/UserRepository.cs | 42 +++++++------------ 1 file changed, 16 insertions(+), 26 deletions(-) diff --git a/src/Infrastructure.Dapper/Repositories/UserRepository.cs b/src/Infrastructure.Dapper/Repositories/UserRepository.cs index d092c6fbcb..469ceafe22 100644 --- a/src/Infrastructure.Dapper/Repositories/UserRepository.cs +++ b/src/Infrastructure.Dapper/Repositories/UserRepository.cs @@ -262,37 +262,27 @@ public class UserRepository : Repository, IUserRepository connection.Open(); await using var transaction = connection.BeginTransaction(); - try + if (user.AccountRevisionDate == null) { - if (user.AccountRevisionDate == null) - { - user.AccountRevisionDate = user.RevisionDate; - } + user.AccountRevisionDate = user.RevisionDate; + } - ProtectData(user); - await connection.ExecuteAsync( - $"[{Schema}].[{Table}_Update]", - user, - transaction: transaction, - commandType: CommandType.StoredProcedure); + ProtectData(user); + await connection.ExecuteAsync( + $"[{Schema}].[{Table}_Update]", + user, + transaction: transaction, + commandType: CommandType.StoredProcedure); - // Update re-encrypted data - foreach (var action in updateDataActions) - { - await action(connection, transaction); - } - transaction.Commit(); - } - catch + // Update re-encrypted data + foreach (var action in updateDataActions) { - transaction.Rollback(); - throw; - } - finally - { - connection.Close(); - UnprotectData(user); + await action(connection, transaction); } + transaction.Commit(); + + connection.Close(); + UnprotectData(user); }