Changeset 417 for trunk/sources/HeuristicLab.CEDMA.DB

Timestamp:

08/01/08 14:43:10 (16 years ago)

Author:

gkronber

Message:

worked on #211 (Full operator-graphs are stored multiple times in the database even though most of it is static anyway)

• created a new type of operator library that is connected to the CEDMA db and a view for it

File:

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

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

@@ -65 +65 @@
             }
             using(DbCommand cmd = cnn.CreateCommand()) {
-              cmd.CommandText = "CREATE TABLE Operator (ID integer primary key autoincrement, Name text, RawData text)";
+              cmd.CommandText = "CREATE TABLE Operator (ID integer primary key autoincrement, Name text, RawData Blob)";
               cmd.Transaction = t;
               cmd.ExecuteNonQuery();
@@ -200 +200 @@
     }
 
-    public long InsertOperator(string name, string rawData) {
+    public long InsertOperator(string name, byte[] rawData) {
       rwLock.EnterWriteLock();
       try {
@@ -230 +230 @@
     #endregion
 
-    #region update agent/run
+    #region update agent, run, operator
     public void UpdateAgent(long id, string name) {
       rwLock.EnterWriteLock();
@@ -312 +312 @@
     }
 
+    public void UpdateOperator(long id, string name, byte[] rawData) {
+      rwLock.EnterWriteLock();
+      try {
+        using(SQLiteConnection cnn = new SQLiteConnection(connectionString)) {
+          cnn.Open();
+          using(SQLiteTransaction t = cnn.BeginTransaction()) {
+            using(SQLiteCommand c = cnn.CreateCommand()) {
+              c.Transaction = t;
+              c.CommandText = "Update Operator set Name=@Name, RawData=@RawData where id=@Id";
+              DbParameter rawDataParam = c.CreateParameter();
+              DbParameter nameParam = c.CreateParameter();
+              DbParameter idParam = c.CreateParameter();
+              rawDataParam.ParameterName = "@RawData";
+              rawDataParam.Value = rawData;
+              idParam.ParameterName = "@Id";
+              idParam.Value = id;
+              nameParam.ParameterName = "@Name";
+              nameParam.Value = name;
+              c.Parameters.Add(rawDataParam);
+              c.Parameters.Add(nameParam);
+              c.Parameters.Add(idParam);
+              c.ExecuteNonQuery();
+            }
+            t.Commit();
+          }
+        }
+      } finally {
+        rwLock.ExitWriteLock();
+      }
+    }
+
     #endregion
 
-    #region get agent/result/sub-result
+    #region get agent/result/sub-result/operator
 
     public ICollection<AgentEntry> GetAgents(ProcessStatus status) {
@@ -481 +512 @@
                 op.Id = r.GetInt32(0);
                 op.Name = r.IsDBNull(1) ? "-" : r.GetString(1);
-                op.RawData = r.GetString(2);
+                op.RawData = (byte[])r.GetValue(2);
                 operators.Add(op);
               }
@@ -491 +522 @@
       }
       return operators;
+    }
+    #endregion
+
+    #region delete operator
+    public void DeleteOperator(long id) {
+      rwLock.EnterWriteLock();
+      try {
+        using(DbConnection cnn = new SQLiteConnection(connectionString)) {
+          cnn.Open();
+          using(DbTransaction t = cnn.BeginTransaction()) {
+            using(DbCommand c = cnn.CreateCommand()) {
+              c.Transaction = t;
+              c.CommandText = "Delete from Operator where id=@Id";
+              DbParameter idParam = c.CreateParameter();
+              idParam.ParameterName = "@Id";
+              idParam.Value = id;
+              c.Parameters.Add(idParam);
+              c.ExecuteNonQuery();
+            }
+            t.Commit();
+          }
+        }
+      } finally {
+        rwLock.ExitWriteLock();
+      }
     }
     #endregion