Changeset 13994 for branches/backtrack/ippTools/src/camtool.c

Timestamp:

Jul 2, 2007, 3:46:36 PM (19 years ago)

Author:

jhoblitt

Message:

refactor camtool & db to preserve metadata history

File:

• branches/backtrack/ippTools/src/camtool.c (modified) (7 diffs)

branches/backtrack/ippTools/src/camtool.c

@@ -203 +203 @@
 
     // find the chipProcessedExp exposures that we want to queue up.
-    psString query = psStringCopy("SELECT * FROM chipProcessedExp");
+//    psString query = psStringCopy("SELECT * FROM chipRun WHERE chipRun.state = 'stop'");
+    psString query = pxDataGet("camtool_find_chip_id.sql");
+    if (!query) {
+        psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
+        return false;
+    }
 
     if (where) {
-        psString whereClause = psDBGenerateWhereSQL(where, "chipProcessedExp");
+        psString whereClause = psDBGenerateWhereSQL(where, "");
         psFree(where);
         psStringAppend(&query, " %s", whereClause);
@@ -245 +250 @@
         psMetadata *md = output->data[i];
 
-        chipProcessedExpRow *row = chipProcessedExpObjectFromMetadata(md);
+        chipRunRow *row = chipRunObjectFromMetadata(md);
         if (!row) {
-            psError(PS_ERR_UNKNOWN, false, "failed to convert metadata into chipProcessedExp");
+            psError(PS_ERR_UNKNOWN, false, "failed to convert metadata into chipRun");
             psFree(output);
             return false;
@@ -601 +606 @@
     }
 
-    // start a transaction so we don't end up with an exp_tag is both
-    // camPendingExp & camProcessedExp
     if (!psDBTransaction(config->dbh)) {
         psError(PS_ERR_UNKNOWN, false, "database error");
@@ -609 +612 @@
     }
 
-    camPendingExpRow *pendingRow = camPendingExpObjectFromMetadata(output->data[0]);
+    camRunRow *pendingRow = camRunObjectFromMetadata(output->data[0]);
     psFree(output);
     // create a new camProcessedImfile object
@@ -615 +618 @@
         pendingRow->cam_id,
         pendingRow->chip_id,
-        pendingRow->workdir,
-        pendingRow->label,
-        pendingRow->reduction,
-        pendingRow->expgroup,
-        pendingRow->dvodb,
         uri,
         bg,
@@ -637 +635 @@
         code
     );
+    psFree(pendingRow);
 
     // insert the new row into the camProcessedImfile table
@@ -646 +645 @@
         psError(PS_ERR_UNKNOWN, false, "database error");
         psFree(row);
-        psFree(pendingRow);
-        return false;
-    }
+        return false;
+    }
+
+    // since there is only one exp per 'run' set camRun.state = 'stop'
+    if (!pxcamRunSetState(config, row->cam_id, "stop")) {
+        psError(PS_ERR_UNKNOWN, false, "failed to change camRun.state for cam_id: %" PRId64, row->cam_id);
+        psFree(row);
+        return false;
+    }
+
     psFree(row);
 
-    // delete the camPendingExp row from the database
-    if (!camPendingExpDeleteObject(config->dbh, pendingRow)) {
-        // rollback
-        if (!psDBRollback(config->dbh)) {
-            psError(PS_ERR_UNKNOWN, false, "database error");
-        }
-        psError(PS_ERR_UNKNOWN, false, "database error");
-        psFree(pendingRow);
-        return false;
-    }
-
-    psFree(pendingRow);
-
-    // point of no return for camPendingExp -> camProcessedExp
     if (!psDBCommit(config->dbh)) {
         psError(PS_ERR_UNKNOWN, false, "database error");