Changeset 10024 for trunk/ippTools/src/pzgetimfiles.c

Timestamp:

Nov 16, 2006, 2:57:02 PM (20 years ago)

Author:

jhoblitt

Message:

complete support of the new database schema

File:

• trunk/ippTools/src/pzgetimfiles.c (modified) (6 diffs)

trunk/ippTools/src/pzgetimfiles.c

@@ -139 +139 @@
     long imfiles = psArrayLength(newImfiles);
 
+    // start a transaction so it's all rows or nothing
+    if (!psDBTransaction(config->dbh)) {
+        psError(PS_ERR_UNKNOWN, false, "database error");
+        return false;
+    }
+
     // if the fileset was empty (no files) then we can bail out early
     if (imfiles == 0) {
+        psFree(newImfiles);
+
         char *query = 
             "UPDATE summitExp"
@@ -148 +156 @@
             " AND telescope = '%s'";
         if (!p_psDBRunQuery(config->dbh, query, imfiles, filesetid, camera, telescope)) {
-            psError(PS_ERR_UNKNOWN, false, "database error");
-            return false;
-        }
-        psFree(newImfiles);
+            // rollback
+            if (!psDBRollback(config->dbh)) {
+                psError(PS_ERR_UNKNOWN, false, "database error");
+            }
+            psError(PS_ERR_UNKNOWN, false, "database error");
+            return false;
+        }
+
+        // remove the pzPendingExp entry for this exp (fileset)
+        {
+            char *query = 
+                "DELETE FROM pzPendingExp"
+                " WHERE"
+                "   exp_id = '%s'"
+                "   AND camera = '%s'"
+                "   AND telescope = '%s'";
+            if (!p_psDBRunQuery(config->dbh, query, filesetid, camera, telescope)) {
+                // rollback
+                if (!psDBRollback(config->dbh)) {
+                    psError(PS_ERR_UNKNOWN, false, "database error");
+                }
+                psError(PS_ERR_UNKNOWN, false, "database error");
+                return false;
+            }
+        }
+
+        // point of no return
+        if (!psDBCommit(config->dbh)) {
+            psError(PS_ERR_UNKNOWN, false, "database error");
+            return false;
+        }
+
         return true;
     } 
-
-    // start a transaction so it's all rows or nothing
-    if (!psDBTransaction(config->dbh)) {
-        psError(PS_ERR_UNKNOWN, false, "database error");
-        return false;
-    }
 
     // try not to insert duplicate pzPendingExp/pzPendingImfile entries
@@ -179 +209 @@
     }
 
+    // load the imfiles (files) into the temp table
     {
         char *query = "INSERT INTO incoming (exp_id, camera, telescope, bytes, md5sum, class, class_id, uri) VALUES (?, ?, ?, ?, ?, ?, ?, ?)";
@@ -206 +237 @@
     psFree(newImfiles);
 
+    // queue the imfiles (files) in pzPendingImfile
     {
         char *query = 
@@ -238 +270 @@
     }
 
-
+    // move imfiles (files) from the temp table into summitImfiles
     {
         char *query = 
@@ -271 +303 @@
     }
 
-    // update summitExp.imfiles
+    // update summitExp.imfiles (should have been NULL)
     {
         char *query = 
             "UPDATE summitExp"
             " SET imfiles = (SELECT COUNT(*) FROM summitImfile"
-            "   WHERE exp_id = '%s'"
+            "   WHERE"
+            "       exp_id = '%s'"
+            "       AND camera = '%s'"
+            "       AND telescope = '%s'"
+            ")" 
+            " WHERE"
+            "   exp_id = '%s'"
             "   AND camera = '%s'"
-            "   AND telescope = '%s'"
-            ")" 
-            " WHERE exp_id = '%s'"
-            " AND camera = '%s'"
-            " AND telescope = '%s'";
+            "   AND telescope = '%s'";
         if (!p_psDBRunQuery(config->dbh, query, filesetid, camera, telescope, filesetid, camera, telescope)) {
-            psError(PS_ERR_UNKNOWN, false, "database error");
-            return false;
-        }
-    }
-
+            // rollback
+            if (!psDBRollback(config->dbh)) {
+                psError(PS_ERR_UNKNOWN, false, "database error");
+            }
+            psError(PS_ERR_UNKNOWN, false, "database error");
+            return false;
+        }
+    }
+
+    // remove the pzPendingExp entry for this exp (fileset)
+    {
+        char *query = 
+            "DELETE FROM pzPendingExp"
+            " WHERE"
+            "   exp_id = '%s'"
+            "   AND camera = '%s'"
+            "   AND telescope = '%s'";
+        if (!p_psDBRunQuery(config->dbh, query, filesetid, camera, telescope)) {
+            // rollback
+            if (!psDBRollback(config->dbh)) {
+                psError(PS_ERR_UNKNOWN, false, "database error");
+            }
+            psError(PS_ERR_UNKNOWN, false, "database error");
+            return false;
+        }
+    }
+
+    // point of no return
     if (!psDBCommit(config->dbh)) {
         psError(PS_ERR_UNKNOWN, false, "database error");