Changeset 32261 for trunk/ippToPsps

Timestamp:

Aug 31, 2011, 4:08:34 PM (15 years ago)

Author:

rhenders

Message:

added method to return all batch IDs not yet loaded to ODM

File:

• trunk/ippToPsps/jython/ipptopspsdb.py (modified) (1 diff)

trunk/ippToPsps/jython/ipptopspsdb.py

@@ -130 +130 @@
 
     '''
+    Returns a list of processed batch IDs that have not yet been loaded to the ODM
+    '''
+    def getBatchIDsUnloadedToODM(self, epoch, dvoGpc1Label):
+
+        sql = "SELECT DISTINCT batch_id \
+               FROM batch \
+               WHERE timestamp > '" + epoch + "' \
+               AND dvo_db = '" + dvoGpc1Label + "' \
+               AND loaded_to_datastore = 1 \
+               AND loaded_to_ODM = 0"
+
+
+        ids = []
+        try:
+            rs = self.executeQuery(sql)
+            while (rs.next()):
+                ids.append(rs.getInt(1))
+        except:
+            self.logger.exception("Can't query for unloaded batch ids in ipptopsps Db")
+
+        rs.close()
+
+        self.logger.debug("Found %d unloaded items" % len(ids))
+
+        return ids
+
+    '''
     Returns a list of processed batch IDs that have not failed to load and are not yet merged, for this epoch and dvo label
     '''