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

Timestamp:

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

Author:

svonolfe

Message:

Added transaction management (#527)

File:

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

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

@@ -29 +29 @@
 using HeuristicLab.DataAccess.Interfaces;
 using HeuristicLab.DataAccess.ADOHelper;
+using HeuristicLab.Hive.Server.ADODataAccess.dsHiveServerTableAdapters;
+using System.Data.Common;
+using System.Data.SqlClient;
 
 namespace HeuristicLab.Hive.Server.ADODataAccess {
+  class ClientAdapterWrapper :
+    DataAdapterWrapperBase<
+        dsHiveServerTableAdapters.ClientTableAdapter,
+    ClientInfo,
+    dsHiveServer.ClientRow> {
+    public override void UpdateRow(dsHiveServer.ClientRow row) {
+      TransactionalAdapter.Update(row);
+    }
+
+    public override dsHiveServer.ClientRow
+      InsertNewRow(ClientInfo client) {
+      dsHiveServer.ClientDataTable data =
+        new dsHiveServer.ClientDataTable();
+
+      dsHiveServer.ClientRow row = data.NewClientRow();
+      row.ResourceId = client.Id;
+      data.AddClientRow(row);
+
+      return row;
+    }
+
+    public override IEnumerable<dsHiveServer.ClientRow>
+      FindById(Guid id) {
+      return TransactionalAdapter.GetDataById(id);
+    }
+
+    public override IEnumerable<dsHiveServer.ClientRow>
+      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 ClientAdapter: 
-    CachedDataAdapter<
+    DataAdapterBase<
       dsHiveServerTableAdapters.ClientTableAdapter, 
       ClientInfo, 
-      dsHiveServer.ClientRow, 
-      dsHiveServer.ClientDataTable>,
+      dsHiveServer.ClientRow>,
     IClientAdapter {
     #region Fields
@@ -44 +86 @@
       get {
         if (resAdapter == null)
-          resAdapter = ServiceLocator.GetResourceAdapter();
+          resAdapter =
+            this.Session.GetDataAdapter<Resource, IResourceAdapter>();
 
         return resAdapter;
@@ -55 +98 @@
       get {
         if (clientGroupAdapter == null) {
-          clientGroupAdapter = ServiceLocator.GetClientGroupAdapter();
+          clientGroupAdapter =
+            this.Session.GetDataAdapter<ClientGroup, IClientGroupAdapter>();
         }
 
@@ -67 +111 @@
       get {
         if (jobAdapter == null) {
-          jobAdapter = ServiceLocator.GetJobAdapter();
+          this.Session.GetDataAdapter<Job, IJobAdapter>();
         }
 
@@ -75 +119 @@
     #endregion
 
-    public ClientAdapter():
-      base(ServiceLocator.GetDBSynchronizer()) {
-      parentAdapters.Add(this.ResAdapter as ICachedDataAdapter);
-    }
-
+    public ClientAdapter(): 
+      base(new ClientAdapterWrapper()) {
+    }
 
     #region Overrides
@@ -146 +188 @@
     }
 
-    protected override void UpdateRow(dsHiveServer.ClientRow row) {
-      Adapter.Update(row);
-    }
-
-    protected override dsHiveServer.ClientRow
-      InsertNewRow(ClientInfo client) {
-      dsHiveServer.ClientDataTable data =
-        new dsHiveServer.ClientDataTable();
-
-      dsHiveServer.ClientRow row = data.NewClientRow();
-      row.ResourceId = client.Id;
-      data.AddClientRow(row);
-
-      return row;
-    }
-
-    protected override dsHiveServer.ClientRow
-      InsertNewRowInCache(ClientInfo client) {
-      dsHiveServer.ClientRow row = cache.NewClientRow();
-      row.ResourceId = client.Id;
-      cache.AddClientRow(row);
-
-      return row;
-    }
-
-    protected override void FillCache() {
-      Adapter.FillByActive(cache);
-    }
-
-    protected override void SynchronizeWithDb() {
-      Adapter.Update(cache);
-    }
-
-    protected override bool PutInCache(ClientInfo obj) {
-      return (obj.State != State.offline && obj.State != State.nullState);
-    }
-
-    protected override IEnumerable<dsHiveServer.ClientRow>
-      FindById(Guid id) {
-      return Adapter.GetDataById(id);
-    }
-
-    protected override dsHiveServer.ClientRow
-      FindCachedById(Guid id) {
-      return cache.FindByResourceId(id);
-    }
-
-    protected override IEnumerable<dsHiveServer.ClientRow>
-      FindAll() {
-      return FindMultipleRows(
-        new Selector(Adapter.GetData),
-        new Selector(cache.AsEnumerable<dsHiveServer.ClientRow>));
-    }
-
     #endregion
 
     #region IClientAdapter Members
-    public override void Update(ClientInfo client) {
+    protected override void doUpdate(ClientInfo client) {
       if (client != null) {
         ResAdapter.Update(client);
 
-        base.Update(client);
+        base.doUpdate(client);
       }
     }
@@ -219 +207 @@
     }
 
-    public override bool Delete(ClientInfo client) {
+    protected override bool doDelete(ClientInfo client) {
       bool success = false;
       Guid locked = Guid.Empty;
@@ -240 +228 @@
           }
 
-          success = base.Delete(client) && 
+          success = base.doDelete(client) && 
             ResAdapter.Delete(client);
         }