Changeset 2221 for branches/HeuristicLab.Modeling Database Backend/sources/HeuristicLab.Modeling.Database.SQLServerCompact

Timestamp:

08/03/09 11:33:15 (15 years ago)

Author:

mkommend

Message:

performance improvements by reusing the datacontext (ticket #712)

File:

• branches/HeuristicLab.Modeling Database Backend/sources/HeuristicLab.Modeling.Database.SQLServerCompact/3.2/DatabaseService.cs (modified) (7 diffs)

branches/HeuristicLab.Modeling Database Backend/sources/HeuristicLab.Modeling.Database.SQLServerCompact/3.2/DatabaseService.cs

@@ -17 +17 @@
     public DatabaseService(string connection) {
       this.connection = connection;
-      using (ModelingDataContext ctx = new ModelingDataContext(connection)) {
-        if (!ctx.DatabaseExists())
-          ctx.CreateDatabase();
-      }
+      Connect();
+      if (!ctx.DatabaseExists())
+        ctx.CreateDatabase();
     }
 
     private void EmptyDatabase() {
-      using (ModelingDataContext ctx = new ModelingDataContext(connection)) {
-        ctx.DeleteDatabase();
-        ctx.CreateDatabase();
-      }
+      ctx.DeleteDatabase();
+      ctx.CreateDatabase();
+    }
+
+    private ModelingDataContext ctx;
+    public void Connect() {
+      if (ctx != null)
+        return;
+
+      ctx = new ModelingDataContext(connection);
+      DataLoadOptions dlo = new DataLoadOptions();
+      dlo.LoadWith<ModelResult>(mr => mr.Result);
+      dlo.LoadWith<InputVariableResult>(ir => ir.Variable);
+      dlo.LoadWith<InputVariableResult>(ir => ir.Result);
+      dlo.LoadWith<Model>(m => m.TargetVariable);
+      ctx.LoadOptions = dlo;
+    }
+
+    public void Disconnect() {
+      if (ctx == null)
+        return;
+      ctx.Dispose();
+      ctx = null;
     }
 
@@ -103 +121 @@
 
     public Dataset GetDataset() {
-      using (ModelingDataContext ctx = new ModelingDataContext(connection)) {
-        if (ctx.Problems.Count() != 1)
-          throw new InvalidOperationException("Could not get dataset. No or more than one problems are persisted in the database.");
-
-        Problem problem = ctx.Problems.Single();
-        return problem.Dataset;
-      }
+      if (ctx.Problems.Count() != 1)
+        throw new InvalidOperationException("Could not get dataset. No or more than one problems are persisted in the database.");
+
+      Problem problem = ctx.Problems.Single();
+      return problem.Dataset;
+
     }
 
     public Problem GetOrCreateProblem(Dataset dataset) {
       Problem problem;
-      using (ModelingDataContext ctx = new ModelingDataContext(connection)) {
-        if (ctx.Problems.Count() == 0)
-          problem = PersistProblem(dataset);
-        else
-          problem = ctx.Problems.Single();
-        if (problem.Dataset.ToString() != dataset.ToString())
-          throw new InvalidOperationException("Could not persist dataset. The database already contains a different dataset.");
-      }
+      if (ctx.Problems.Count() == 0)
+        problem = PersistProblem(dataset);
+      else
+        problem = ctx.Problems.Single();
+      if (problem.Dataset.ToString() != dataset.ToString())
+        throw new InvalidOperationException("Could not persist dataset. The database already contains a different dataset.");
       return problem;
     }
@@ -165 +180 @@
     public Dictionary<string, Variable> GetAllVariables() {
       Dictionary<string, Variable> dict = new Dictionary<string, Variable>();
-      using (ModelingDataContext ctx = new ModelingDataContext(connection)) {
-        dict = ctx.Variables.ToDictionary<Variable, string>(delegate(Variable v) { return v.Name; });
-      }
+      dict = ctx.Variables.ToDictionary<Variable, string>(delegate(Variable v) { return v.Name; });
       return dict;
     }
@@ -192 +205 @@
 
     public IEnumerable<IResult> GetAllResults() {
-      using (ModelingDataContext ctx = new ModelingDataContext(connection)) {
-        return ctx.Results.ToList().Cast<IResult>();
-      }
+      return ctx.Results.ToList().Cast<IResult>();
     }
 
     public IEnumerable<IResult> GetAllResultsForInputVariables() {
-      using (ModelingDataContext ctx = new ModelingDataContext(connection)) {
-        return (from ir in ctx.InputVariableResults select ir.Result).Distinct().ToList().Cast<IResult>();
-      }
+      return (from ir in ctx.InputVariableResults select ir.Result).Distinct().ToList().Cast<IResult>();
     }
 
@@ -207 +216 @@
     #region ModelResult
     public IEnumerable<IModelResult> GetModelResults(IModel model) {
-      ModelingDataContext ctx = new ModelingDataContext(connection);
-      DataLoadOptions dlo = new DataLoadOptions();
-      dlo.LoadWith<ModelResult>(mr => mr.Result);
-      ctx.LoadOptions = dlo;
-
       var results = from result in ctx.ModelResults
                     where result.Model == model
@@ -217 +221 @@
       return results.ToList().Cast<IModelResult>();
     }
-
-    public void GetAllModelResults() {
-      ModelingDataContext ctx = new ModelingDataContext(connection);
-      DataLoadOptions dlo = new DataLoadOptions();
-      dlo.LoadWith<ModelResult>(mr => mr.Result);
-      dlo.LoadWith<ModelResult>(mr => mr.Model);
-      ctx.LoadOptions = dlo;
-
-      var results = from result in ctx.ModelResults
-                    select result;
-      results.ToList();     
-
-    }
     #endregion
 
     #region InputVariableResults
     public IEnumerable<IInputVariableResult> GetInputVariableResults(IModel model) {
-      ModelingDataContext ctx = new ModelingDataContext(connection);
-      DataLoadOptions dlo = new DataLoadOptions();
-      dlo.LoadWith<InputVariableResult>(ir => ir.Variable);
-      dlo.LoadWith<InputVariableResult>(ir => ir.Result);      
-      ctx.LoadOptions = dlo;
-
       var inputResults = from ir in ctx.InputVariableResults
                          where ir.Model == model
@@ -250 +235 @@
     #region Model
     public IEnumerable<IModel> GetAllModels() {
-      ModelingDataContext ctx = new ModelingDataContext(connection);
-      DataLoadOptions dlo = new DataLoadOptions();
-      dlo.LoadWith<Model>(m => m.TargetVariable);
-      ctx.LoadOptions = dlo;
       return ctx.Models.ToList().Cast<IModel>();
     }
 
     public byte[] GetModelData(IModel model) {
-      using (ModelingDataContext ctx = new ModelingDataContext(connection)) {
-        var data = (from md in ctx.ModelData
-                    where md.Model == model
-                    select md);
-        if (data.Count() == 0)
-          return null;
-        return data.Single().Data;
-      }
+      var data = (from md in ctx.ModelData
+                  where md.Model == model
+                  select md);
+      if (data.Count() == 0)
+        return null;
+      return data.Single().Data;
     }
     #endregion