Changeset 36826 for branches/eam_branches/ipp-20140423/ippToPsps/jython/ipptopspsdb.py

Timestamp:

Jun 7, 2014, 5:36:39 AM (12 years ago)

Author:

eugene

Message:

merge changes from trunk

File:

• branches/eam_branches/ipp-20140423/ippToPsps/jython/ipptopspsdb.py (modified) (3 diffs)

branches/eam_branches/ipp-20140423/ippToPsps/jython/ipptopspsdb.py

@@ -1116 +1116 @@
         ,queue_ST \
         ,queue_OB \
+        ,queue_DF \
+        ,queue_DO \
+        ,queue_FW \
+        ,queue_FO \
         ,parallel \
         ,P2_smf_version \
@@ -1162 +1166 @@
             if rs.getInt(20) == 1: self.skychunk.batchTypes.append("ST")
             if rs.getInt(21) == 1: self.skychunk.batchTypes.append("OB")
+            if rs.getInt(22) == 1: self.skychunk.batchTypes.append("DF")
+            if rs.getInt(23) == 1: self.skychunk.batchTypes.append("DO")
+            if rs.getInt(24) == 1: self.skychunk.batchTypes.append("FW")
+            if rs.getInt(25) == 1: self.skychunk.batchTypes.append("FO")
 
             self.skychunk.force = True # TODO
             self.skychunk.parallel = False # TODO
 
-            if rs.getInt(22) == 1: self.skychunk.parallel = True
-            self.skychunk.P2_smf_version = rs.getString(23)
-            self.skychunk.ST_cmf_version = rs.getString(24)
-            self.skychunk.trange_start = rs.getString(25)
-            self.skychunk.trange_end = rs.getString(26) 
+            if rs.getInt(26) == 1: self.skychunk.parallel = True
+            self.skychunk.P2_smf_version = rs.getString(27)
+            self.skychunk.ST_cmf_version = rs.getString(28)
+            self.skychunk.trange_start = rs.getString(29)
+            self.skychunk.trange_end = rs.getString(30) 
 
             if self.skychunk.parallel: print "USING parallel"
@@ -1643 +1651 @@
         # self.logger.infoPair("Items written to alt Db", "%d" % count)
 
+
+    '''
+    Creates a temporary table and shoves it full of stage_ids and ra/dec coords
+    '''
+    def storeAllItemsInDvodb(self, rows, dvo_db, batchType):
+
+        #try:
+        #    self.execute("DROP TABLE all_pending")
+        #except:
+        #    pass
+
+        #self.execute("CREATE TEMPORARY TABLE all_pending (stage_id bigint(20), ra_bore float, dec_bore float)")
+        for row in rows:
+
+            try:
+                uniq = dvo_db + "."+ batchType + "." + str(row[0])
+                sql = "INSERT INTO dvodb (dvo_db, batch_type, stage_id, ra_center, dec_center, uniq_key) \
+                       VALUES ( '" + dvo_db + "', '" + batchType + "'," + str(row[0]) + "," + str(row[1]) + " \
+                       , " + str(row[2]) + ", '"+uniq+"' ) " 
+                print "sql 1: ", sql
+                self.execute(sql)
+            except: continue
+
+        #count = self.getRowCount("all_pending")
+        #self.logger.infoPair("Items written to Db", "%d" % count)
+
+
+
     '''
     Gets all items in the all_pending temporary table within the bounds of this box