Changeset 417 for trunk/sources/HeuristicLab.CEDMA.Core/DatabaseOperatorLibrary.cs

Timestamp:

08/01/08 14:43:10 (16 years ago)

Author:

gkronber

Message:

worked on #211 (Full operator-graphs are stored multiple times in the database even though most of it is static anyway)

• created a new type of operator library that is connected to the CEDMA db and a view for it

File:

• trunk/sources/HeuristicLab.CEDMA.Core/DatabaseOperatorLibrary.cs (modified) (3 diffs)

trunk/sources/HeuristicLab.CEDMA.Core/DatabaseOperatorLibrary.cs

@@ -4 +4 @@
 using System.Text;
 using HeuristicLab.Core;
+using HeuristicLab.CEDMA.DB.Interfaces;
 
 namespace HeuristicLab.CEDMA.Core {
@@ -13 +14 @@
     }
 
-    private string dbUri;
-
-    public DatabaseOperatorLibrary(string dbUri)
-      : base() {
-      this.dbUri = dbUri;
-      group = new OperatorGroup();
+    private IDatabase database;
+    public IDatabase Database {
+      get { return database; }
+      set { this.database = value; }
     }
 
+    private Dictionary<IOperator, long> knownOperators;
+
+    public DatabaseOperatorLibrary()
+      : base() {
+      group = new OperatorGroup();
+      knownOperators = new Dictionary<IOperator, long>();
+    }
+
+    public void Save() {
+      Dictionary<IOperator, long> newKnownOperators = new Dictionary<IOperator,long>();
+      foreach(IOperator op in group.Operators) {
+        if(knownOperators.ContainsKey(op)) {
+          // update
+          long id =knownOperators[op]; 
+          Database.UpdateOperator(id, op.Name, PersistenceManager.SaveToGZip(op));
+          knownOperators.Remove(op);
+          newKnownOperators.Add(op, id);
+        } else {
+          // create new
+          long id = Database.InsertOperator(op.Name, PersistenceManager.SaveToGZip(op));
+          newKnownOperators.Add(op, id);
+        }
+      }
+      // delete operators from the table that are not present in the group anymore (remaining entries)
+      foreach(long id in knownOperators.Values) {
+        Database.DeleteOperator(id);
+      }
+      
+      knownOperators = newKnownOperators;
+    }
+
+    public void Restore() {
+      foreach(IOperator op in knownOperators.Keys) {
+        group.RemoveOperator(op);
+      }
+      knownOperators.Clear();
+      if(database == null) return;
+      foreach(OperatorEntry e in Database.GetOperators()) {
+        IOperator op = (IOperator)PersistenceManager.RestoreFromGZip(e.RawData);
+        knownOperators.Add(op, e.Id);
+        group.AddOperator(op);
+      }
+    }
 
     public override System.Xml.XmlNode GetXmlNode(string name, System.Xml.XmlDocument document, IDictionary<Guid, IStorable> persistedObjects) {
@@ -35 +77 @@
 
     public override IView CreateView() {
-      // return new DatabaseOperatorLibraryView(this);
-      return null;
+      Restore();
+      return new DatabaseOperatorLibraryView(this);
     }
   }