diff --git a/Repositories/Resgrid.Repositories.DataRepository/DeleteRepository.cs b/Repositories/Resgrid.Repositories.DataRepository/DeleteRepository.cs index b4e5dca1..36ec0a70 100644 --- a/Repositories/Resgrid.Repositories.DataRepository/DeleteRepository.cs +++ b/Repositories/Resgrid.Repositories.DataRepository/DeleteRepository.cs @@ -24,8 +24,10 @@ public async Task DeleteDepartmentAndUsersAsync(int departmentId) if (Config.DataConfig.DatabaseType == DatabaseTypes.SqlServer) { - using (IDbConnection db = new SqlConnection(DataConfig.CoreConnectionString)) + using (var db = new SqlConnection(DataConfig.CoreConnectionString)) { + await db.OpenAsync(); + using (var transaction = db.BeginTransaction()) { var result = await db.ExecuteAsync(@" @@ -171,13 +173,13 @@ DELETE FROM [dbo].[MessageRecipients] WHERE MessageId IN (SELECT MessageId FROM DELETE FROM [dbo].[AspNetUsersExt] WHERE UserId = @ManagingUserId DELETE FROM [dbo].[AspNetUsers] WHERE Id = @ManagingUserId ", - new { DepartmentId = departmentId }); + new { DepartmentId = departmentId }, transaction); transaction.Commit(); } } - return false; + return true; } return false;