Changeset 35057

Timestamp:

Jan 25, 2013, 9:01:58 PM (13 years ago)

Author:

eugene

Message:

add method to insert StackDetectionCalib values using select into + load from file

Location:

branches/eam_branches/ipp-20121219/ippToPsps/jython

Files:

• gpc1db.py (modified) (1 diff)
• stackbatch.py (modified) (3 diffs)

branches/eam_branches/ipp-20121219/ippToPsps/jython/gpc1db.py

@@ -237 +237 @@
         else:
             files = glob.glob(path + ".smf")
-
-            
 
         # XXX EAM : test output

branches/eam_branches/ipp-20121219/ippToPsps/jython/stackbatch.py

@@ -2 +2 @@
 
 import os.path
+import glob
 import sys
 
@@ -717 +718 @@
     calling the load data infile '/tmp/name' into table;
     '''
-    def populateStackDetectionCalib(self):
+    def populateStackDetectionCalibInsertUpdate(self):
         self.logger.infoPair("Processing table", "StackDetectionCalib")
         tableName = "StackDetectionCalib"
@@ -757 +758 @@
         self.scratchDb.updateAllRows(tableName, "dataRelease", str(self.config.dataRelease))
         
-    
-
+    def populateStackDetectionCalib(self):
+
+        tableName = "StackDetectionCalib"
+        self.logger.infoPair("Processing table", tableName)
+
+        imageID = self.scratchDb.getImageIDFromExternID(self.header['IMAGEID'])
+        self.logger.infoPair("obtained","imageID")
+
+        dumpFile = "/tmp/datadump/genetest.xx.dat"
+        files = glob.glob(dumpFile)
+        if len(files) > 0:
+            os.unlink(dumpFile)
+
+        # insert all detections into table
+        sql = "SELECT \
+          a.objID,    \
+          a.stackDetectID, \
+          a.ippObjID,      \
+          a.ippDetectID,   \
+          a.filterID,      \
+          a.surveyID,      \
+          b.ra,            \
+          b.dec_,          \
+          b.raErr,         \
+          b.decErr,        \
+          b.zp,            \
+          b.zpErr,         \
+          b.expTime,       \
+          b.airMass,       \
+          a.dataRelease    \
+         FROM              \
+           StackDetection as a \
+         JOIN " + self.scratchDb.dvoDetectionTable + " as b \
+         ON (a.stackDetectID = b.detectID) where b.imageID = " + str(imageID) + \
+         " INTO OUTFILE '" + dumpFile + "'"
+        print "sql: ", sql
+        self.scratchDb.execute(sql)
+
+        sql = "LOAD DATA INFILE '" + dumpFile + "' INTO TABLE " + tableName
+        print "sql: ", sql
+        self.scratchDb.execute(sql)
+        self.scratchDb.updateAllRows(tableName, "dataRelease", str(self.config.dataRelease))
 
     '''