Changeset 37241
- Timestamp:
- Aug 12, 2014, 3:38:38 PM (12 years ago)
- Location:
- branches/eam_branches/ipp-20140717/ippToPsps/jython
- Files:
-
- 5 edited
-
detectionbatch.py (modified) (1 diff)
-
mysql.py (modified) (3 diffs)
-
objectbatch.py (modified) (1 diff)
-
scratchdb.py (modified) (2 diffs)
-
stackbatch.py (modified) (8 diffs)
Legend:
- Unmodified
- Added
- Removed
-
branches/eam_branches/ipp-20140717/ippToPsps/jython/detectionbatch.py
r37232 r37241 381 381 382 382 sql = sqlLine.makeRaw(") SELECT ", " FROM " + ippTableName) 383 print "sql: " + sql 384 385 self.scratchDb.execute(sql) 383 384 try: self.scratchDb.execute(sql) 385 except: 386 self.logger.errorPair("failed sql: ", sql) 387 raise 386 388 387 389 # NOTE : Flux limits : in the current PSPS schema, negative fluxes -
branches/eam_branches/ipp-20140717/ippToPsps/jython/mysql.py
r37179 r37241 83 83 ''' 84 84 def lockTable(self, table): 85 print "Locking table: " + table85 # print "Locking table: " + table 86 86 self.execute("LOCK TABLES " + table + " WRITE") 87 87 … … 90 90 ''' 91 91 def unlockTables(self): 92 print "Unlocking tables"92 # print "Unlocking tables" 93 93 self.execute("UNLOCK TABLES") 94 94 … … 117 117 while (rs.next()): 118 118 tableName = rs.getString(1) 119 print "table: " + tableName119 # print "table: " + tableName 120 120 rs.close() 121 121 -
branches/eam_branches/ipp-20140717/ippToPsps/jython/objectbatch.py
r37219 r37241 155 155 156 156 157 self.logger.info(sql) 158 self.scratchDb.execute(sql) 157 try: self.scratchDb.execute(sql) 158 except: 159 self.logger.errorPair("failed update MeanObject", sql) 160 raise 159 161 160 162 # now set to null all MeanMagErr values > 0.5 (cut set by Gene, 2012-04-12) -
branches/eam_branches/ipp-20140717/ippToPsps/jython/scratchdb.py
r37239 r37241 427 427 # if no returned rows, return an error 428 428 if not rs.next(): 429 print "DVO lacks imageID ", imageID 430 print "sql: ", sql 429 self.logger.infoPair("DVO lacks imageID ", imageID) 431 430 return False 432 431 … … 436 435 437 436 else: 438 print "DVO has wrong imageID? ", imageID 439 print "result was ", rs.getInt(1) 440 print "sql: ", sql 437 self.logger.error("DVO has wrong imageID? ") 438 self.logger.error("imageID: ", imageID) 439 self.logger.error("EXTERN_ID: ", rs.getInt(1)) 440 self.logger.infoPair("sql: ", sql) 441 441 raise 442 442 -
branches/eam_branches/ipp-20140717/ippToPsps/jython/stackbatch.py
r37238 r37241 329 329 sqlLine.group("a."+filter+"infoFlag2", "(b.flags << 13)") 330 330 sql = sqlLine.makeEquals("WHERE a.objID = b.objID AND b.imageID = " + str(imageID)) 331 self.logger.infoPair('sql', sql)332 331 333 332 try: self.scratchDb.execute(sql) … … 351 350 352 351 sql = sqlLine.makeEquals("WHERE a." + filter + "ippDetectID=b.IPP_IDET") 353 self.logger.infoPair('sql', sql)354 352 355 353 # index the (f)ippDetectIDs for the next steps? … … 428 426 sql = sqlLine.makeEquals("WHERE a." + filter + "ippDetectID = b.IPP_IDET") 429 427 430 self.logger.infoPair('sql', sql)431 428 try: 432 429 self.scratchDb.execute(sql) … … 445 442 sql = sqlLine.makeEquals("WHERE a.objID = b.objID AND a." + filter + "ippDetectID = b.ippDetectID") 446 443 447 self.logger.infoPair('sql', sql)448 444 try: 449 445 self.scratchDb.execute(sql) … … 558 554 sql = sqlLine.makeEquals("WHERE a.objID = b.objID AND a." + filter + "ippDetectID = b.ippDetectID") 559 555 560 self.logger.infoPair('sql', sql)561 556 try: 562 557 self.scratchDb.execute(sql) … … 597 592 sql = sqlLine.makeEquals("WHERE a.objID = b.objID AND a.objID = c.objID") 598 593 599 self.logger.infoPair('sql', sql)600 594 try: 601 595 self.scratchDb.execute(sql) … … 817 811 818 812 sql = sqlLine.makeEquals("WHERE a." + filter + "ippDetectID = b.IPP_IDET AND " + psfCondition) 819 self.logger.infoPair("sql",sql) 813 820 814 self.scratchDb.execute(sql) 821 815 … … 840 834 sqlLine.group(field + "Std", field + "Std" + " * POW(10, 3.56 - 0.4* b.zp)") 841 835 sql = sqlLine.makeEquals("WHERE a.objID = b.objID AND a." + filter + "ippDetectID = b.ippDetectID") 842 self.logger.infoPair("sql",sql)843 836 self.scratchDb.execute(sql) 844 837
Note:
See TracChangeset
for help on using the changeset viewer.
