Changeset 37917 for trunk/ippToPsps/jython/stackbatch.py

Timestamp:

Feb 20, 2015, 1:19:35 PM (11 years ago)

Author:

heather

Message:

current state of ipptopsps / sas37 - ob/p2/st/df work

File:

• trunk/ippToPsps/jython/stackbatch.py (modified) (7 diffs)

trunk/ippToPsps/jython/stackbatch.py

@@ -293 +293 @@
         self.generateRandomIDs()
 
+        self.logger.infoPair("Adding 'row' columns to", "StackObjectThin")
+        self.scratchDb.addRowCountColumn("StackObjectThin", "row")
+        self.logger.infoPair("Adding unique psps ids to", "StackObjectThin")
         self.generateStackDetectRowIDsAndPspsUniqueIDs()
+        self.logger.infoPair("Dropping row column from", "StackObjectThin table")
+        self.scratchDb.dropColumn("StackObjectThin", "row")
+
 
         # add indexes StackObjectThin
@@ -372 +378 @@
                 self.logger.errorPair('failed sql: ', sql)
                 raise
+
+
+            # we do not yet set bestdetection, this is a placeholder until we do
+            sql = "UPDATE StackObjectThin set bestDetection = 0"
+            try:
+                self.scratchDb.execute(sql)
+            except:
+                self.logger.errorPair('failed sql: ', sql)
+                raise
+
 
         self.tablesToExport.append("StackObjectThin")
@@ -756 +772 @@
 
         minRadius = 1
-        maxRadius = 10
+        maxRadius = 9
         if tablename == 'StackApFlx':
             minRadius = 3
@@ -765 +781 @@
 
         sqlLine = sqlUtility("UPDATE " + tablename + " SET")
-        for radius in [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]:
+        for radius in [1, 2, 3, 4, 5, 6, 7, 8, 9]:
             if radius < minRadius: continue
             if radius > maxRadius: continue
@@ -950 +966 @@
 
     def generateStackDetectRowIDsAndPspsUniqueIDs(self):
-        sql = "UPDATE StackObjectThin join (select @r:=@r+1 rownum, objID from \
-        (select @r:=0) r, StackObjectThin t) as foo using (objID) set \
-        stackDetectRowID = ((" + str(self.batchID) + " << 32 ) + rownum), \
-        uniquePspsSTid = ((" +str(self.batchID)+ "*1000000000 ) + rownum)";
+#        sql = "UPDATE StackObjectThin join (select @r:=@r+1 rownum, objID from \
+#        (select @r:=0) r, StackObjectThin t) as foo using (objID) set \
+#        stackDetectRowID = ((" + str(self.batchID) + " << 32 ) + rownum), \
+#        uniquePspsSTid = ((" +str(self.batchID)+ "*1000000000 ) + rownum)";
+        sql = "UPDATE StackObjectThin set uniquePspsSTid = (("+str(self.batchID)+"*1000000000 ) + row)"
+
         try: self.scratchDb.execute(sql)
         except:
@@ -1010 +1028 @@
             self.scratchDb.addColumn(table, filter + "haveData", "tinyint")
 
-        fields = "objID, ippObjID, randomStackObjID, primaryDetection, bestDetection, uniquePspsSTID, "
+        fields = "objID, ippObjID, randomStackObjID, primaryDetection, bestDetection, uniquePspsSTID, StackDetectRowID, "
 
         for i in range(len(self.filters)):
@@ -1016 +1034 @@
             fields += filter + "ippDetectID, "
             fields += filter + "stackDetectID, "
+#            fields += filter + "StackDetectRowID, " 
             fields += filter + "stackMetaID " # careful here: do not add comma to last entry
             if (i < len(self.filters) - 1):
                 fields += ", "
 
-        if (table == "StackObjectAttributes"):
-            fields += ", stackDetectRowID "
+        #if (table == "StackObjectAttributes"):
+        #    fields += ", stackDetectRowID "
         sql  = "INSERT INTO " + table + " (" + fields + ") "
         sql += "SELECT " + fields + " FROM " + mainTable