Free cookie consent management tool by TermsFeed Policy Generator

source: branches/HiveStatistics/sources/HeuristicLab.Services.Hive.DataAccess/3.3/TransactionManager.cs @ 11177

Last change on this file since 11177 was 11040, checked in by mroscoe, 10 years ago
File size: 3.4 KB
Line 
1#region License Information
2/* HeuristicLab
3 * Copyright (C) 2002-2012 Heuristic and Evolutionary Algorithms Laboratory (HEAL)
4 *
5 * This file is part of HeuristicLab.
6 *
7 * HeuristicLab is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation, either version 3 of the License, or
10 * (at your option) any later version.
11 *
12 * HeuristicLab is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with HeuristicLab. If not, see <http://www.gnu.org/licenses/>.
19 */
20#endregion
21
22using System;
23using System.IO;
24using System.Transactions;
25
26namespace HeuristicLab.Services.Hive.DataAccess {
27  public class TransactionManager : ITransactionManager {
28    public void UseTransaction(Action call, bool repeatableRead = false, bool longRunning = false) {
29      int n = 10;
30      while (n > 0) {
31        TransactionScope transaction = CreateTransaction(repeatableRead, longRunning);
32        try {
33          call();
34          transaction.Complete();
35          n = 0;
36        }
37        catch (System.Data.SqlClient.SqlException e) {
38          n--; // probably deadlock situation, let it roll back and repeat the transaction n times
39          LogFactory.GetLogger(typeof(TransactionManager).Namespace).Log(string.Format("Exception occured, repeating transaction {0} more times. Details: {1}", n, e.ToString()));
40          //var log = new StreamWriter(@"C:\Temp\AbortedTransactions.log", true);
41          //log.WriteLine(DateTime.Now + ": Transaction aborted: " + n + " (" + e.Message + ")");
42          //log.WriteLine(e.StackTrace);
43          //log.Close();
44          if (n <= 0) throw;
45        }
46        finally {
47          transaction.Dispose();
48        }
49      }
50    }
51
52    public T UseTransaction<T>(Func<T> call, bool repeatableRead = false, bool longRunning = false) {
53      int n = 10;
54      while (n > 0) {
55        TransactionScope transaction = CreateTransaction(repeatableRead, longRunning);
56        try {
57          T result = call();
58          transaction.Complete();
59          n = 0;
60          return result;
61        }
62        catch (System.Data.SqlClient.SqlException e) {
63          n--; // probably deadlock situation, let it roll back and repeat the transaction n times
64          LogFactory.GetLogger(typeof(TransactionManager).Namespace).Log(string.Format("Exception occured, repeating transaction {0} more times. Details: {1}", n, e.ToString()));
65          if (n <= 0) throw;
66        }
67        finally {
68          transaction.Dispose();
69        }
70      }
71      throw new Exception("This code should not be reached");
72    }
73
74    private TransactionScope CreateTransaction(bool repeatableRead, bool longRunning) {
75      var options = new TransactionOptions();
76      if (repeatableRead)
77        options.IsolationLevel = IsolationLevel.RepeatableRead;
78      else
79        options.IsolationLevel = IsolationLevel.ReadUncommitted;
80
81      if (longRunning)
82        options.Timeout = Settings.Default.LongRunningDatabaseCommandTimeout;
83
84      return new TransactionScope(TransactionScopeOption.Required, options);
85    }
86  }
87}
Note: See TracBrowser for help on using the repository browser.