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

Timestamp:

03/31/09 01:33:37 (16 years ago)

Author:

svonolfe

Message:

Added transaction management (#527)

File:

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

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

@@ -6 +6 @@
 using HeuristicLab.Hive.Contracts.BusinessObjects;
 using HeuristicLab.DataAccess.ADOHelper;
+using HeuristicLab.Hive.Server.ADODataAccess.dsHiveServerTableAdapters;
+using System.Data.Common;
+using System.Data.SqlClient;
 
 namespace HeuristicLab.Hive.Server.ADODataAccess {
+  class JobResultsAdapterWrapper :
+    DataAdapterWrapperBase<dsHiveServerTableAdapters.JobResultTableAdapter,
+                    JobResult,
+                    dsHiveServer.JobResultRow> {    
+    public override void UpdateRow(dsHiveServer.JobResultRow row) {
+      TransactionalAdapter.Update(row);
+    }
+
+    public override dsHiveServer.JobResultRow InsertNewRow(JobResult obj) {
+      dsHiveServer.JobResultDataTable data =
+        new dsHiveServer.JobResultDataTable();
+
+      dsHiveServer.JobResultRow row = data.NewJobResultRow();
+      row.JobResultId = obj.Id;
+      data.AddJobResultRow(row);
+
+      return row;
+    }
+
+    public override IEnumerable<dsHiveServer.JobResultRow> FindById(Guid id) {
+      return TransactionalAdapter.GetDataById(id);
+    }
+
+    public override IEnumerable<dsHiveServer.JobResultRow> FindAll() {
+      return TransactionalAdapter.GetData();
+    }
+
+    protected override void SetConnection(DbConnection connection) {
+      adapter.Connection = connection as SqlConnection;
+    }
+
+    protected override void SetTransaction(DbTransaction transaction) {
+      adapter.Transaction = transaction as SqlTransaction;
+    }
+  }
+
   class JobResultsAdapter: 
     DataAdapterBase<dsHiveServerTableAdapters.JobResultTableAdapter, 
@@ -19 +58 @@
       get {
         if (clientAdapter == null)
-          clientAdapter = ServiceLocator.GetClientAdapter();
+          clientAdapter =
+            this.Session.GetDataAdapter<ClientInfo, IClientAdapter>();
 
         return clientAdapter;
@@ -30 +70 @@
       get {
         if (jobAdapter == null)
-          jobAdapter = ServiceLocator.GetJobAdapter();
+          jobAdapter =
+            this.Session.GetDataAdapter<Job, IJobAdapter>();
 
         return jobAdapter;
@@ -36 +77 @@
     }
     #endregion
+
+    public JobResultsAdapter(): base(new JobResultsAdapterWrapper()) {
+    }
 
     #region Overrides
@@ -117 +161 @@
         return null;
     }
-
-    protected override void UpdateRow(dsHiveServer.JobResultRow row) {
-      Adapter.Update(row);
-    }
-
-    protected override dsHiveServer.JobResultRow InsertNewRow(JobResult obj) {
-      dsHiveServer.JobResultDataTable data =
-        new dsHiveServer.JobResultDataTable();
-
-      dsHiveServer.JobResultRow row = data.NewJobResultRow();
-      row.JobResultId = obj.Id;
-      data.AddJobResultRow(row);
-
-      return row;
-    }
-
-    protected override IEnumerable<dsHiveServer.JobResultRow> FindById(Guid id) {
-      return Adapter.GetDataById(id);
-    }
-
-    protected override IEnumerable<dsHiveServer.JobResultRow> FindAll() {
-      return Adapter.GetData();
-    }
     #endregion
 
     #region IJobResultsAdapter Members
-    public override void Update(JobResult result) {
+    protected override void doUpdate(JobResult result) {
       if (result != null) {
         ClientAdapter.Update(result.Client);
         JobAdapter.Update(result.Job);
 
-        base.Update(result);
+        base.doUpdate(result);
       }
     }