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

Timestamp:

12/17/08 14:46:06 (15 years ago)

Author:

svonolfe

Message:

Implemented JobResultsAdapter (#372)

File:

• trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/JobResultsAdapter.cs (modified) (1 diff)

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

@@ -12 +12 @@
                     dsHiveServer.JobResultRow>,
     IJobResultsAdapter {
-    #region Overrides
-    protected override dsHiveServer.JobResultRow Convert(JobResult obj, dsHiveServer.JobResultRow row) {
-      throw new NotImplementedException();
+    #region Fields
+    dsHiveServer.JobResultDataTable data =
+        new dsHiveServer.JobResultDataTable();
+
+    private IClientAdapter clientAdapter = null;
+
+    private IClientAdapter ClientAdapter {
+      get {
+        if (clientAdapter == null)
+          clientAdapter = ServiceLocator.GetClientAdapter();
+
+        return clientAdapter;
+      }
     }
 
-    protected override JobResult Convert(dsHiveServer.JobResultRow row, JobResult obj) {
-      throw new NotImplementedException();
+    private IJobAdapter jobAdapter = null;
+
+    private IJobAdapter JobAdapter {
+      get {
+        if (jobAdapter == null)
+          jobAdapter = ServiceLocator.GetJobAdapter();
+
+        return jobAdapter;
+      }
+    }
+    #endregion
+
+    #region Overrides
+    protected override dsHiveServer.JobResultRow Convert(JobResult result,
+      dsHiveServer.JobResultRow row) {
+      if (row != null && result != null) {
+        if (result.Job != null)
+          row.JobId = result.Job.Id;
+        else
+          row.SetJobIdNull();
+
+        if (result.Result != null)
+          row.JobResult = result.Result;
+        else
+          row.SetJobResultNull();
+
+        if (result.Client != null)
+          row.ResourceId = result.Client.Id;
+        else
+          row.SetResourceIdNull();
+
+        return row;
+      } else
+        return null;
+    }
+
+    protected override JobResult Convert(dsHiveServer.JobResultRow row, 
+      JobResult result) {
+      if (row != null && result != null) {
+        result.Id = row.JobResultId;
+
+        if (!row.IsJobIdNull())
+          result.Job = JobAdapter.GetById(row.JobId);
+        else
+          result.Job = null;
+
+        if (!row.IsJobResultNull())
+          result.Result = row.JobResult;
+        else
+          result.Result = null;
+
+        if (!row.IsResourceIdNull())
+          result.Client = ClientAdapter.GetById(row.ResourceId);
+        else
+          result.Client = null;
+
+        return result;
+      } else
+        return null;
+    }
+
+    protected override void UpdateRow(dsHiveServer.JobResultRow row) {
+      adapter.Update(row);
     }
 
     protected override dsHiveServer.JobResultRow InsertNewRow(JobResult obj) {
-      throw new NotImplementedException();
-    }
+      dsHiveServer.JobResultRow row = data.NewJobResultRow();
+      data.AddJobResultRow(row);
 
-    protected override void UpdateRow(dsHiveServer.JobResultRow row) {
-      throw new NotImplementedException();
+      return row;
     }
 
     protected override IEnumerable<dsHiveServer.JobResultRow> FindById(long id) {
-      throw new NotImplementedException();
+      return adapter.GetDataById(id);
     }
 
     protected override IEnumerable<dsHiveServer.JobResultRow> FindAll() {
-      throw new NotImplementedException();
+      return adapter.GetData();
     }
     #endregion
 
     #region IJobResultsAdapter Members
-    public override void Update(JobResult ob) {
-      throw new NotImplementedException();
-    }
+    public override void Update(JobResult result) {
+      if (result != null) {
+        ClientAdapter.Update(result.Client);
+        JobAdapter.Update(result.Job);
 
-    public override JobResult GetById(long id) {
-      throw new NotImplementedException();
-    }
-
-    public override ICollection<JobResult> GetAll() {
-      throw new NotImplementedException();
-    }
-
-    public override bool Delete(JobResult obj) {
-      throw new NotImplementedException();
+        base.Update(result);
+      }
     }
 
     public ICollection<JobResult> GetResultsOf(Job job) {
-      throw new NotImplementedException();
+      if (job != null) {
+        return 
+          base.FindMultiple(
+            delegate() {
+              return adapter.GetDataByJob(job.Id);
+            });
+      }
+
+      return null;
     }
     #endregion