Changeset 2117 for trunk/sources/HeuristicLab.Hive.Server.ADODataAccess

Timestamp:

06/26/09 12:18:32 (15 years ago)

Author:

svonolfe

Message:

Streaming of Jobs and JobsResults directly from/to the DB (#680)

Location:

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

Files:

• JobAdapter.cs (modified) (2 diffs)
• JobResultsAdapter.cs (modified) (2 diffs)
• TableAdapterWrapper/JobAdapterWrapper.cs (modified) (2 diffs)
• TableAdapterWrapper/JobResultsAdapterWrapper.cs (modified) (2 diffs)

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

@@ -32 +32 @@
 using System.Data.SqlClient;
 using HeuristicLab.Hive.Server.ADODataAccess.TableAdapterWrapper;
+using System.IO;
 
 namespace HeuristicLab.Hive.Server.ADODataAccess {
@@ -436 +437 @@
           }
         });
+    }
+
+    public Stream GetSerializedJobStream(Guid jobId, bool useExistingConnection) {
+      return 
+        ((JobAdapterWrapper)base.DataAdapterWrapper).
+          GetSerializedJobStream(jobId, useExistingConnection);
     }
 

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

@@ -10 +10 @@
 using System.Data.SqlClient;
 using HeuristicLab.Hive.Server.ADODataAccess.TableAdapterWrapper;
+using System.IO;
 
 namespace HeuristicLab.Hive.Server.ADODataAccess {
@@ -152 +153 @@
     }
 
+    public Stream GetSerializedJobResultStream(Guid jobResultId, bool useExistingConnection) {
+      return
+        ((JobResultsAdapterWrapper)
+        base.DataAdapterWrapper).
+          GetSerializedJobResultStream(jobResultId, useExistingConnection);
+    }
+
     public void UpdateSerializedJobResult(SerializedJobResult jobResult) {
       if (jobResult != null &&

trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/TableAdapterWrapper/JobAdapterWrapper.cs

@@ -7 +7 @@
 using HeuristicLab.Hive.Contracts.BusinessObjects;
 using System.Data.Common;
+using System.IO;
+using System.Data.SqlTypes;
+using System.Data;
 
 namespace HeuristicLab.Hive.Server.ADODataAccess.TableAdapterWrapper {
@@ -39 +42 @@
     }
 
-    public byte[] GetSerializedJob(Guid jobId) {
-      return TransactionalAdapter.GetSerializedJobById(jobId);
-    }
+    public Stream GetSerializedJobStream(Guid jobId, 
+      bool useExistingConnection) {
+      SqlConnection connection = null;
+      SqlTransaction transaction = null;
 
-    public bool UpdateSerialiedJob(byte[] serializedJob, Guid jobId) {
-      return TransactionalAdapter.UpdateSerializedJob(serializedJob, jobId) > 0;
+      if (useExistingConnection) {
+        connection = 
+          base.Session.Connection as SqlConnection;
+
+        transaction =
+          adapter.Transaction;
+      } else {
+        connection =
+         ((SessionFactory)
+           (base.Session.Factory)).CreateConnection()
+           as SqlConnection;
+      }
+
+      VarBinarySource source =
+        new VarBinarySource(
+          connection, transaction,
+          "Job", "SerializedJob", "JobId", jobId);
+
+      return new VarBinaryStream(source);
     }
 

trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/TableAdapterWrapper/JobResultsAdapterWrapper.cs

@@ -7 +7 @@
 using HeuristicLab.Hive.Contracts.BusinessObjects;
 using System.Data.Common;
+using System.IO;
 
 namespace HeuristicLab.Hive.Server.ADODataAccess.TableAdapterWrapper {
@@ -36 +37 @@
     }
 
-    public byte[] GetSerializedJobResult(Guid jobResultId) {
-      return TransactionalAdapter.GetSerializedJobResultById(jobResultId);
-    }
+    public Stream GetSerializedJobResultStream(Guid jobResultId,
+      bool useExistingConnection) {
+      SqlConnection connection = null;
+      SqlTransaction transaction = null;
 
-    public bool UpdateSerialiedJobResult(byte[] serializedJobResult, Guid jobResultId) {
-      return TransactionalAdapter.UpdateSerializedJobResultById(serializedJobResult, jobResultId) > 0;
+      if (useExistingConnection) {
+        connection =
+          base.Session.Connection as SqlConnection;
+
+        transaction =
+          adapter.Transaction;
+      } else {
+        connection =
+         ((SessionFactory)
+           (base.Session.Factory)).CreateConnection()
+           as SqlConnection;
+      }
+
+      VarBinarySource source =
+        new VarBinarySource(
+          connection, transaction,
+          "JobResult", "JobResult", "JobResultId", jobResultId);
+
+      return new VarBinaryStream(source);
     }