Changeset 2099 for trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/JobResultsAdapter.cs

Timestamp:

06/25/09 13:54:15 (15 years ago)

Author:

svonolfe

Message:

Further avoided out of memory exceptions by updating the JobResult DAO (#372)

File:

• trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/JobResultsAdapter.cs (modified) (3 diffs)

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

@@ -55 +55 @@
           row.SetJobIdNull();
 
-        if (result.Result != null)
-          row.JobResult = result.Result;
-        else
-          row.SetJobResultNull();
-
         if (result.ClientId != Guid.Empty)  {
           ClientInfo client = 
@@ -99 +94 @@
           result.JobId = Guid.Empty;
 
-        if (!row.IsJobResultNull())
-          result.Result = row.JobResult;
-        else
-          result.Result = null;
-
         if (!row.IsResourceIdNull())
           result.ClientId = row.ResourceId;
@@ -128 +118 @@
 
     #region IJobResultsAdapter Members
-    public ICollection<JobResult> GetResultsOf(Job job) {
-      if (job != null) {
+    public ICollection<JobResult> GetResultsOf(Guid jobId) {
         return 
           base.FindMultiple(
             delegate() {
-              return Adapter.GetDataByJob(job.Id);
+              return Adapter.GetDataByJob(jobId);
             });
-      }
-
-      return null;
     }
 
-    public JobResult GetLastResultOf(Job job) {
-       if (job != null) {
+    public JobResult GetLastResultOf(Guid jobId) {
         return 
           base.FindSingle(
             delegate() {
-              return Adapter.GetDataByLastResult(job.Id);
+              return Adapter.GetDataByLastResult(jobId);
             });
+    }
+
+    public SerializedJobResult GetSerializedJobResult(Guid jobResultId) {
+      return (SerializedJobResult)base.doInTransaction(
+        delegate() {
+          SerializedJobResult jobResult =
+            new SerializedJobResult();
+
+          jobResult.JobResult = GetById(jobResultId);
+          if (jobResult.JobResult != null) {
+            jobResult.SerializedJobResultData =
+              base.Adapter.GetSerializedJobResultById(jobResultId);
+
+            return jobResult;
+          } else {
+            return null;
+          }
+        });
+    }
+
+    public void UpdateSerializedJobResult(SerializedJobResult jobResult) {
+      if (jobResult != null &&
+        jobResult.JobResult != null) {
+        base.doInTransaction(
+          delegate() {
+            Update(jobResult.JobResult);
+            return base.Adapter.UpdateSerializedJobResultById(
+              jobResult.SerializedJobResultData,
+              jobResult.JobResult.Id);
+          });
       }
-
-      return null;
     }
     #endregion