Changeset 9257 for trunk/sources/HeuristicLab.Services.Hive.DataAccess

Timestamp:

02/28/13 13:57:49 (12 years ago)

Author:

ascheibe

Message:

#2019

• added missing transactions in the Hive service
• split scheduling transaction into smaller transactions
• improved speed of job uploading (AddTask)
• changed highest isolation level from Serializable to RepeatableRead as phantom reads shouldn't be a problem

File:

• trunk/sources/HeuristicLab.Services.Hive.DataAccess/3.3/TransactionManager.cs (modified) (4 diffs)

trunk/sources/HeuristicLab.Services.Hive.DataAccess/3.3/TransactionManager.cs

@@ -22 +22 @@
 using System;
 using System.Transactions;
-using HeuristicLab.Services.Hive.DataAccess;
 
-namespace HeuristicLab.Services.Hive.DataAccess {  
-  public class TransactionManager : ITransactionManager {    
-    public void UseTransaction(Action call, bool serializable = false, bool longRunning = false) {
+namespace HeuristicLab.Services.Hive.DataAccess {
+  public class TransactionManager : ITransactionManager {
+    public void UseTransaction(Action call, bool repeatableRead = false, bool longRunning = false) {
       int n = 10;
       while (n > 0) {
-        TransactionScope transaction = CreateTransaction(serializable, longRunning);
+        TransactionScope transaction = CreateTransaction(repeatableRead, longRunning);
         try {
           call();
@@ -37 +36 @@
         catch (System.Data.SqlClient.SqlException e) {
           n--; // probably deadlock situation, let it roll back and repeat the transaction n times
-          LogFactory.GetLogger(typeof(TransactionManager).Namespace).Log(string.Format("Exception occured, repeating transaction {0} more times. Details: {1}", n, e.ToString()));          
+          LogFactory.GetLogger(typeof(TransactionManager).Namespace).Log(string.Format("Exception occured, repeating transaction {0} more times. Details: {1}", n, e.ToString()));
           if (n <= 0) throw;
         }
@@ -46 +45 @@
     }
 
-    public T UseTransaction<T>(Func<T> call, bool serializable = false, bool longRunning = false) {
+    public T UseTransaction<T>(Func<T> call, bool repeatableRead = false, bool longRunning = false) {
       int n = 10;
       while (n > 0) {
-        TransactionScope transaction = CreateTransaction(serializable, longRunning);
+        TransactionScope transaction = CreateTransaction(repeatableRead, longRunning);
         try {
           T result = call();
@@ -68 +67 @@
     }
 
-    private TransactionScope CreateTransaction(bool serializable, bool longRunning) {
+    private TransactionScope CreateTransaction(bool repeatableRead, bool longRunning) {
       var options = new TransactionOptions();
-      if (serializable)
-        options.IsolationLevel = IsolationLevel.Serializable;
+      if (repeatableRead)
+        options.IsolationLevel = IsolationLevel.RepeatableRead;
       else
         options.IsolationLevel = IsolationLevel.ReadUncommitted;