Changeset 419 for trunk/sources/HeuristicLab.CEDMA.DB/Database.cs

Timestamp:

08/01/08 17:59:19 (16 years ago)

Author:

gkronber

Message:

worked on #211 need to patch the operator-graph of an agent before execution (replacing the OperatorLinks with their targets).

work in progress...

File:

• trunk/sources/HeuristicLab.CEDMA.DB/Database.cs (modified) (5 diffs)

trunk/sources/HeuristicLab.CEDMA.DB/Database.cs

@@ -55 +55 @@
             }
             using(DbCommand cmd = cnn.CreateCommand()) {
-              cmd.CommandText = "CREATE TABLE Agent (ID integer primary key autoincrement, ProjectId integer, ParentAgentId integer, Name text, Status text default "+ProcessStatus.Unknown+", CreationTime DateTime, RawData Blob)";
+              cmd.CommandText = "CREATE TABLE Agent (ID integer primary key autoincrement, ProjectId integer, ParentAgentId integer, Name text, Status text default " + ProcessStatus.Unknown + ", CreationTime DateTime, RawData Blob)";
               cmd.Transaction = t;
               cmd.ExecuteNonQuery();
@@ -365 +365 @@
             agent.Status = status;
             agent.Id = r.GetInt32(0);
-            agent.Name = r.IsDBNull(1)?"":r.GetString(1);
+            agent.Name = r.IsDBNull(1) ? "" : r.GetString(1);
             agent.RawData = (byte[])r.GetValue(2);
             agents.Add(agent);
@@ -389 +389 @@
                 agent.ParentAgentId = null;
                 agent.Id = r.GetInt32(0);
-                agent.Name = r.IsDBNull(1)?"-":r.GetString(1);
+                agent.Name = r.IsDBNull(1) ? "-" : r.GetString(1);
                 agent.Status = (ProcessStatus)Enum.Parse(typeof(ProcessStatus), r.GetString(2));
                 agent.RawData = (byte[])r.GetValue(3);
@@ -421 +421 @@
                 agent.ParentAgentId = parentAgentId;
                 agent.Id = r.GetInt32(0);
-                agent.Name = r.IsDBNull(1)?"-":r.GetString(1);
+                agent.Name = r.IsDBNull(1) ? "-" : r.GetString(1);
                 agent.Status = (ProcessStatus)Enum.Parse(typeof(ProcessStatus), r.GetString(2));
                 agent.RawData = (byte[])r.GetValue(3);
@@ -523 +523 @@
       return operators;
     }
+    public OperatorEntry GetOperator(long id) {
+      rwLock.EnterReadLock();
+      try {
+        using(DbConnection cnn = new SQLiteConnection(connectionString)) {
+          cnn.Open();
+          using(DbCommand c = cnn.CreateCommand()) {
+            c.CommandText = "Select id, name, rawdata from Operator where id=@Id";
+            DbParameter idParam = c.CreateParameter();
+            idParam.ParameterName = "@Id";
+            idParam.Value = id;
+            c.Parameters.Add(idParam);
+            using(DbDataReader r = c.ExecuteReader()) {
+              r.Read();
+              OperatorEntry op = new OperatorEntry();
+              op.Id = r.GetInt32(0);
+              op.Name = r.IsDBNull(1) ? "-" : r.GetString(1);
+              op.RawData = (byte[])r.GetValue(2);
+              return op;
+            }
+          }
+        }
+      } finally {
+        rwLock.ExitReadLock();
+      }
+    }
     #endregion