Changeset 31323 for trunk/ippToPsps/jython/gpc1db.py

Timestamp:

Apr 19, 2011, 10:58:16 AM (15 years ago)

Author:

rhenders

Message:

method to get imageIDs for a given stack; method to get sky_ids for a given dvo db

File:

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

trunk/ippToPsps/jython/gpc1db.py

@@ -51 +51 @@
 
     '''
+    Gets a list of sky_ids in this DVO database
+    '''
+    def getSkyIDsInThisDVODb(self, dvoDb):
+
+        self.logger.debug("Querying GPC1 for sky_ids in this DVO database: " + dvoDb)
+
+        sql = "SELECT DISTINCT stage_id \
+               FROM addRun \
+               WHERE stage = 'staticsky' \
+               AND dvodb = '" + dvoDb + "'"
+
+        print sql
+
+        try:
+            rs = self.stmt.executeQuery(sql)
+        except:
+            self.logger.exception("Can't query for sky_ids")
+
+        skyIDs = []
+        while (rs.next()):
+            skyIDs.append(rs.getInt(1))
+
+        rs.close()
+
+        return skyIDs
+
+    '''
+    Gets a list of PSPS image IDs for this stack ID
+    '''
+    def getImageIDsForThisStackID(self, stackID):
+
+        self.logger.debug("Querying GPC1 for image IDs for stack ID: " + stackID)
+
+        sql = "SELECT DISTINCT CONCAT(exp_id, SUBSTR(class_id, 3, 4)) FROM ( \
+               SELECT DISTINCT exp_id,class_id \
+               FROM warpSkyCellMap \
+               JOIN warpRun USING(warp_id) \
+               JOIN stackInputSkyfile USING(warp_id) \
+               JOIN stackRun USING(stack_id,skycell_id) \
+               JOIN fakeRun USING(fake_id) \
+               JOIN camRun USING(cam_id)  \
+               JOIN chipRun USING(chip_id) \
+               WHERE stackRun.stack_id = " + stackID + ") AS a"
+
+        try:
+            rs = self.stmt.executeQuery(sql)
+        except:
+            self.logger.exception("Can't query for imageIDs")
+
+        imageIDs = []
+        while (rs.next()):
+            imageIDs.append(rs.getString(1))
+        rs.close()
+
+        return imageIDs
+
+
+    '''
     Gets all cmf files for this sky_id. handles both absolute paths and neb paths
     '''
     def getStackStageCmfs(self, skyID):
 
-        self.logger.debug("Querying for stack cmf files")
+        self.logger.debug("Querying GPC1 for stack cmf files")
 
         sql = "SELECT path_base, num_inputs \