Changeset 2771 for branches/DeploymentServer Prototype/HeuristicLab.Services/HeuristicLab.Services.Deployment.DataAccess

Timestamp:

02/09/10 17:24:13 (14 years ago)

Author:

gkronber

Message:

Implemented and tested rudimentary WCF service interface on top of the Linq2Sql data access layer. #860

Location:

branches/DeploymentServer Prototype/HeuristicLab.Services/HeuristicLab.Services.Deployment.DataAccess

Files:

• PluginDescription.cs (modified) (2 diffs)
• PluginStore.cs (modified) (9 diffs)

branches/DeploymentServer Prototype/HeuristicLab.Services/HeuristicLab.Services.Deployment.DataAccess/PluginDescription.cs

@@ -34 +34 @@
 
     [DataMember(Name = "Dependencies")]
-    private IEnumerable<PluginDescription> dependencies;
-    public IEnumerable<PluginDescription> Dependencies {
+    private List<PluginDescription> dependencies;
+    public List<PluginDescription> Dependencies {
       get { return dependencies; }
     }
@@ -51 +51 @@
       this.name = name;
       this.version = version;
-      this.dependencies = new List<PluginDescription>(dependencies).AsReadOnly();
+      this.dependencies = new List<PluginDescription>(dependencies); //.AsReadOnly();
       //this.isDatabaseInstance = true;
     }

branches/DeploymentServer Prototype/HeuristicLab.Services/HeuristicLab.Services.Deployment.DataAccess/PluginStore.cs

@@ -10 +10 @@
   public class PluginStore {
 
-    private PluginStoreClassesDataContext ctx;
     public PluginStore() {
-      ctx = new PluginStoreClassesDataContext();
-    }
-
+    }
+
+    #region context creating members
     public IEnumerable<ProductDescription> Products {
       get {
-        return from p in ctx.Products
-               let plugins = from pair in ctx.ProductPlugins
-                             from plugin in ctx.Plugins
-                             where pair.ProductId == p.Id
-                             where plugin.Id == pair.PluginId
-                             select plugin
-               select MakeProductDescription(p, plugins);
-      }
-    }
-
-    private ProductDescription MakeProductDescription(Product p, IQueryable<Plugin> plugins) {
-      var desc = new ProductDescription(p.Id, p.Name, new Version(p.Version), from plugin in plugins
-                                                                              select MakePluginDescription(plugin));
-      return desc;
-    }
-
-    private PluginDescription MakePluginDescription(Plugin plugin) {
-      var desc = new PluginDescription(plugin.Id, plugin.Name, new Version(plugin.Version), from dep in GetDependencies(plugin)
-                                                                                            select MakePluginDescription(dep));
-      return desc;
-    }
-
-    private IEnumerable<Plugin> GetDependencies(Plugin plugin) {
-      return from pair in ctx.Dependencies
-             from dependency in ctx.Plugins
-             where pair.PluginId == plugin.Id
-             where pair.DependencyId == dependency.Id
-             select dependency;
+        using (var ctx = new PluginStoreClassesDataContext()) {
+          return (from p in ctx.Products
+                  let plugins = from pair in ctx.ProductPlugins
+                                from plugin in ctx.Plugins
+                                where pair.ProductId == p.Id
+                                where plugin.Id == pair.PluginId
+                                select plugin
+                  select MakeProductDescription(ctx, p, plugins)).ToList();
+        }
+      }
     }
 
     public IEnumerable<PluginDescription> Plugins {
       get {
-        return from plugin in ctx.Plugins
-               select MakePluginDescription(plugin);
+        using (var ctx = new PluginStoreClassesDataContext()) {
+          return (from plugin in ctx.Plugins
+                  select MakePluginDescription(ctx, plugin)).ToList();
+        }
       }
     }
 
     public byte[] PluginFile(PluginDescription pluginDescription) {
-      return GetExistingPlugin(pluginDescription.Name, pluginDescription.Version).PluginPackage.Data.ToArray();
+      using (var ctx = new PluginStoreClassesDataContext()) {
+        return GetExistingPlugin(ctx, pluginDescription.Name, pluginDescription.Version).PluginPackage.Data.ToArray();
+      }
     }
 
     public void Persist(PluginDescription pluginDescription, byte[] pluginPackage) {
-      try {
-        using (var transaction = new TransactionScope()) {
-          Plugin pluginEntity = InsertOrUpdatePlugin(pluginDescription);
-          if (pluginEntity.PluginPackage == null) {
-            // insert
-            pluginEntity.PluginPackage = MakePluginPackage(pluginDescription, pluginPackage);
-          } else {
-            // update
-            pluginEntity.PluginPackage.Data = pluginPackage;
+      using (var ctx = new PluginStoreClassesDataContext()) {
+        try {
+          using (var transaction = new TransactionScope()) {
+            Plugin pluginEntity = InsertOrUpdatePlugin(ctx, pluginDescription);
+            if (pluginEntity.PluginPackage == null) {
+              // insert
+              pluginEntity.PluginPackage = MakePluginPackage(pluginDescription, pluginPackage);
+            } else {
+              // update
+              pluginEntity.PluginPackage.Data = pluginPackage;
+            }
+            ctx.SubmitChanges();
+            transaction.Complete();
           }
-          ctx.SubmitChanges();
-          transaction.Complete();
-        }
-      }
-      catch (SqlException ex) {
-        throw new ArgumentException("Something went wrong while trying to persist plugin", ex);
-      }
-      catch (InvalidOperationException ex) {
-        throw new ArgumentException("Something went wrong while trying to persist plugin", ex);
+        }
+        catch (SqlException ex) {
+          throw new ArgumentException("Something went wrong while trying to persist plugin", ex);
+        }
+        catch (InvalidOperationException ex) {
+          throw new ArgumentException("Something went wrong while trying to persist plugin", ex);
+        }
       }
     }
 
     public void Persist(ProductDescription product) {
-      try {
-        using (var transaction = new TransactionScope()) {
-          InsertOrUpdateProduct(product);
-          foreach (var plugin in product.Plugins) {
-            InsertOrUpdatePlugin(plugin);
+      using (var ctx = new PluginStoreClassesDataContext()) {
+        try {
+          using (var transaction = new TransactionScope()) {
+            foreach (var plugin in product.Plugins) {
+              var pluginEntity = GetExistingPlugin(ctx, plugin.Name, plugin.Version);
+              UpdatePlugin(ctx, pluginEntity, plugin);
+            }
+            InsertOrUpdateProduct(ctx, product);
+            ctx.SubmitChanges();
+            transaction.Complete();
           }
-          ctx.SubmitChanges();
-          transaction.Complete();
-        }
-      }
-      catch (SqlException ex) {
-        throw new ArgumentException("Something went wrong while trying to persist product", ex);
-      }
-      catch (InvalidOperationException ex) {
-        throw new ArgumentException("Something went wrong while trying to persist product", ex);
-      }
-    }
-
-    private void InsertOrUpdateProduct(ProductDescription product) {
+        }
+        catch (SqlException ex) {
+          throw new ArgumentException("Something went wrong while trying to persist product", ex);
+        }
+        catch (InvalidOperationException ex) {
+          throw new ArgumentException("Something went wrong while trying to persist product", ex);
+        }
+      }
+    }
+
+    #endregion
+
+    #region insert/update product
+    private void InsertOrUpdateProduct(PluginStoreClassesDataContext ctx, ProductDescription product) {
       var productEntity = (from p in ctx.Products
                            where p.Name == product.Name
@@ -113 +106 @@
       product.Id = productEntity.Id;
 
-      DeleteOldPlugins(productEntity);
+      DeleteOldPlugins(ctx, productEntity);
 
       foreach (var plugin in product.Plugins) {
-        var existingPlugin = GetExistingPlugin(plugin.Name, plugin.Version);
+        var existingPlugin = GetExistingPlugin(ctx, plugin.Name, plugin.Version);
         ProductPlugin prodPlugin = new ProductPlugin();
         prodPlugin.PluginId = existingPlugin.Id;
@@ -124 +117 @@
     }
 
-    private void DeleteOldPlugins(Product productEntity) {
+    private void DeleteOldPlugins(PluginStoreClassesDataContext ctx, Product productEntity) {
       var oldPlugins = (from p in ctx.ProductPlugins
                         where p.ProductId == productEntity.Id
@@ -131 +124 @@
       ctx.SubmitChanges();
     }
-
-    private Plugin InsertOrUpdatePlugin(PluginDescription pluginDescription) {
+    #endregion
+
+    #region insert/update plugins
+    private Plugin InsertOrUpdatePlugin(PluginStoreClassesDataContext ctx, PluginDescription pluginDescription) {
       var pluginEntity = (from p in ctx.Plugins
                           where p.Name == pluginDescription.Name
@@ -142 +137 @@
         ctx.SubmitChanges();
       }
+
+      UpdatePlugin(ctx, pluginEntity, pluginDescription);
+      return pluginEntity;
+    }
+
+    private void UpdatePlugin(PluginStoreClassesDataContext ctx, Plugin pluginEntity, PluginDescription pluginDescription) {
+      // delete cached entry
+      if (pluginDescriptions.ContainsKey(pluginEntity)) pluginDescriptions.Remove(pluginEntity);
+
       pluginDescription.Id = pluginEntity.Id;
 
-      DeleteOldDependencies(pluginEntity);
+      DeleteOldDependencies(ctx, pluginEntity);
 
       foreach (var dependency in pluginDescription.Dependencies) {
-        var dependencyEntity = GetExistingPlugin(dependency.Name, dependency.Version);
+        var dependencyEntity = GetExistingPlugin(ctx, dependency.Name, dependency.Version);
         Dependency d = new Dependency();
         d.PluginId = pluginDescription.Id;
@@ -153 +157 @@
         ctx.Dependencies.InsertOnSubmit(d);
       }
-      return pluginEntity;
-
-    }
-
-    private void DeleteOldDependencies(Plugin pluginEntity) {
+    }
+
+
+
+    private void DeleteOldDependencies(PluginStoreClassesDataContext ctx, Plugin pluginEntity) {
       var oldDependencies = (from dep in ctx.Dependencies
                              where dep.PluginId == pluginEntity.Id
@@ -165 +169 @@
       ctx.SubmitChanges();
     }
-
-    private Plugin GetExistingPlugin(string name, Version version) {
-      return (from p in ctx.Plugins
-              where p.Name == name
-              where p.Version == version.ToString()
-              select p).Single();
+    #endregion
+
+    #region product <-> productDescription transformation
+    private ProductDescription MakeProductDescription(PluginStoreClassesDataContext ctx, Product p, IQueryable<Plugin> plugins) {
+      var desc = new ProductDescription(p.Id, p.Name, new Version(p.Version), from plugin in plugins
+                                                                              select MakePluginDescription(ctx, plugin));
+      return desc;
+    }
+    private Product MakeProductFromDescription(ProductDescription desc) {
+      var product = new Product();
+      product.Id = desc.Id;
+      product.Name = desc.Name;
+      product.Version = desc.Version.ToString();
+      return product;
+    }
+    #endregion
+
+    #region plugin <-> pluginDescription transformation
+    // cache for plugin descriptions
+    private Dictionary<Plugin, PluginDescription> pluginDescriptions = new Dictionary<Plugin, PluginDescription>();
+    private PluginDescription MakePluginDescription(PluginStoreClassesDataContext ctx, Plugin plugin) {
+      if (!pluginDescriptions.ContainsKey(plugin)) {
+        // no cached description -> create new
+        var desc = new PluginDescription(plugin.Id, plugin.Name, new Version(plugin.Version), from dep in GetDependencies(ctx, plugin)
+                                                                                              select MakePluginDescription(ctx, dep));
+        pluginDescriptions[plugin] = desc;
+      }
+      return pluginDescriptions[plugin];
     }
 
@@ -181 +207 @@
     }
 
-    private Product MakeProductFromDescription(ProductDescription desc) {
-      var product = new Product();
-      product.Id = desc.Id;
-      product.Name = desc.Name;
-      product.Version = desc.Version.ToString();
-      return product;
-    }
-
     private PluginPackage MakePluginPackage(PluginDescription pluginDescription, byte[] pluginPackage) {
       var package = new PluginPackage();
@@ -196 +214 @@
       return package;
     }
+
+    #endregion
+
+    #region helper queries
+    private Plugin GetExistingPlugin(PluginStoreClassesDataContext ctx, string name, Version version) {
+      return (from p in ctx.Plugins
+              where p.Name == name
+              where p.Version == version.ToString()
+              select p).Single();
+    }
+
+    private IEnumerable<Plugin> GetDependencies(PluginStoreClassesDataContext ctx, Plugin plugin) {
+      return from pair in ctx.Dependencies
+             from dependency in ctx.Plugins
+             where pair.PluginId == plugin.Id
+             where pair.DependencyId == dependency.Id
+             select dependency;
+    }
+    #endregion
   }
 }