Changeset 1947 for trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/JobAdapter.cs

Timestamp:

05/29/09 13:42:05 (15 years ago)

Author:

svonolfe

Message:

Added assigned resources to job adapter (#372)

File:

• trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/JobAdapter.cs (modified) (8 diffs)

trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/JobAdapter.cs

@@ -42 +42 @@
     private ManyToManyRelationHelper<
       dsHiveServerTableAdapters.RequiredPluginsTableAdapter,
-      dsHiveServer.RequiredPluginsRow> manyToManyRelationHelper = null;
+      dsHiveServer.RequiredPluginsRow> pluginsManyToManyRelationHelper = null;
 
     private ManyToManyRelationHelper<
       dsHiveServerTableAdapters.RequiredPluginsTableAdapter,
-      dsHiveServer.RequiredPluginsRow> ManyToManyRelationHelper {
-      get {
-        if (manyToManyRelationHelper == null) {
-          manyToManyRelationHelper =
+      dsHiveServer.RequiredPluginsRow> PluginsManyToManyRelationHelper {
+      get {
+        if (pluginsManyToManyRelationHelper == null) {
+          pluginsManyToManyRelationHelper =
             new ManyToManyRelationHelper<dsHiveServerTableAdapters.RequiredPluginsTableAdapter,
               dsHiveServer.RequiredPluginsRow>(new RequiredPluginsAdapterWrapper(), 1);
         }
 
-        manyToManyRelationHelper.Session = Session as Session;
-
-        return manyToManyRelationHelper;
+        pluginsManyToManyRelationHelper.Session = Session as Session;
+
+        return pluginsManyToManyRelationHelper;
+      }
+    }
+
+    private ManyToManyRelationHelper<
+      dsHiveServerTableAdapters.AssignedResourcesTableAdapter,
+      dsHiveServer.AssignedResourcesRow> assignedManyToManyRelationHelper = null;
+
+    private ManyToManyRelationHelper<
+      dsHiveServerTableAdapters.AssignedResourcesTableAdapter,
+      dsHiveServer.AssignedResourcesRow> AssignedManyToManyRelationHelper {
+      get {
+        if (assignedManyToManyRelationHelper == null) {
+          assignedManyToManyRelationHelper =
+            new ManyToManyRelationHelper<dsHiveServerTableAdapters.AssignedResourcesTableAdapter,
+              dsHiveServer.AssignedResourcesRow>(new AssignedResourcesAdapterWrapper(), 0);
+        }
+
+        assignedManyToManyRelationHelper.Session = Session as Session;
+
+        return assignedManyToManyRelationHelper;
       }
     }
@@ -95 +115 @@
 
         return pluginInfoAdapter;
+      }
+    }
+
+    private IProjectAdapter projectAdapter = null;
+
+    private IProjectAdapter ProjectAdapter {
+      get {
+        if (projectAdapter == null) {
+          projectAdapter =
+            this.Session.GetDataAdapter<Project, IProjectAdapter>();
+        }
+
+        return projectAdapter;
       }
     }
@@ -163 +196 @@
           job.MemoryNeeded = default(int);
 
+        if (!row.IsProjectIdNull())
+          job.Project = ProjectAdapter.GetById(
+            row.ProjectId);
+        else
+          job.Project = null;
+
         ICollection<Guid> requiredPlugins =
-          ManyToManyRelationHelper.GetRelationships(job.Id);
+          PluginsManyToManyRelationHelper.GetRelationships(job.Id);
         
         job.PluginsNeeded.Clear();
@@ -173 +212 @@
           job.PluginsNeeded.Add(pluginInfo);
         }
+
+        job.AssignedResourceIds =
+          new List<Guid>(
+            AssignedManyToManyRelationHelper.GetRelationships(job.Id));
 
         return job;
@@ -234 +277 @@
 
         row.MemoryNeeded = job.MemoryNeeded;
+
+        if (job.Project != null)
+          row.ProjectId = job.Project.Id;
+        else
+          row.SetProjectIdNull();
       }
 
@@ -303 +351 @@
 
     public ICollection<Job> GetJobsByProject(Guid projectId) {
-      throw new NotImplementedException();
+      return
+         base.FindMultiple(
+           delegate() {
+             return Adapter.GetDataByProjectId(projectId);
+           });
     }
 
     protected override void doUpdate(Job obj) {
+      ProjectAdapter.Update(obj.Project);
+      
       base.doUpdate(obj);
 
@@ -324 +378 @@
       }
 
-      ManyToManyRelationHelper.UpdateRelationships(
+      PluginsManyToManyRelationHelper.UpdateRelationships(
         obj.Id, relationships);
+
+      AssignedManyToManyRelationHelper.UpdateRelationships(
+        obj.Id, obj.AssignedResourceIds);
     }
 
@@ -343 +400 @@
 
           //delete all relationships
-          ManyToManyRelationHelper.UpdateRelationships(job.Id,
+          PluginsManyToManyRelationHelper.UpdateRelationships(job.Id,
             new List<Guid>());