Changeset 35804

Timestamp:

Jul 12, 2013, 1:16:28 PM (13 years ago)

Author:

eugene

Message:

delete dvoDetectionsFull before inserting

File:

• trunk/Ohana/src/dvopsps/src/insert_detections_dvopsps.c (modified) (3 diffs)

trunk/Ohana/src/dvopsps/src/insert_detections_dvopsps.c

@@ -182 +182 @@
   if (!PARALLEL_MANUAL && !PARALLEL_SERIAL) {
     int status = HostTableWaitJobsGetIO (table, __FILE__, __LINE__, VERBOSE);
+    if (VERBOSE) fprintf (stderr, "done reading remote tables, status: %d\n", status);
     if (!status) return FALSE;
   }
@@ -198 +199 @@
     }
 
+    // explicitly delete all entries
+    char query[256];
+    sprintf (query, "delete from dvoDetectionFull");
+    if (mysql_query (mysql, query)) {
+      fprintf (stderr, "failed to delete existing entries\n");
+      fprintf (stderr, "%s\n", mysql_error (mysql));
+      return FALSE;
+    }
+    if (VERBOSE) fprintf (stderr, "deleted existing entries\n");
+    
     for (i = 0; i < table->Nhosts; i++) {
       if ((detections = DetectionsLoad (table->hosts[i].results, &Ndetections)) == NULL) {
@@ -205 +216 @@
         return FALSE;
       }
+      if (VERBOSE) fprintf (stderr, "read %d detections from %s\n", Ndetections, table->hosts[i].hostname);
       free (table->hosts[i].results);
       table->hosts[i].results = NULL;