Changeset 37592 for trunk/ippToPsps/jython/forcedwarpbatch.py

Timestamp:

Nov 12, 2014, 2:58:40 PM (12 years ago)

Author:

heather

Message:

cleaning up the schema, and adding uniquePsps()id to all tables. Populated in
all except FO/FW/DF/DO (those are still in progress)

File:

• trunk/ippToPsps/jython/forcedwarpbatch.py (modified) (4 diffs)

trunk/ippToPsps/jython/forcedwarpbatch.py

@@ -224 +224 @@
         self.generateRandomIDs()
 
+        self.generateUniquePspsIDs()
+           
         # add indexes ForcedWarpMeasurement
         self.scratchDb.createIndex("ForcedWarpMeasurement", "objID")
@@ -249 +251 @@
         self.tablesToExport.append("ForcedWarpExtended")
 
+           # get dvo ids, 
+        # add in the psps unique ids from stuff
 
     '''
@@ -326 +330 @@
 
     def generateRandomIDs(self):
-           sql = "UPDATE ForcedWarpMeasurement set randomWarpID = FLOOR(RAND("+str(self.batchID)+")*9223372036854775807)";
+           sql = "UPDATE ForcedWarpMeasurement set randomWarpID = FLOOR(RAND("+str(self.batchID)+")*9223372036854775807)"
         try: self.scratchDb.execute(sql)
         except:
@@ -333 +337 @@
 
 
-
+    '''
+    Updates table and generates pspsuniqueids
+    '''
+
+    def generatePspsUniqueIDs(self):
+        sql = "UPDATE ForcedWarpMeasurement join (select @r:=@r+1 rownum, objID from \
+        (select @r:=0) r, ForcedWarpMeasurement t) as foo using (objID) set \
+        uniquePspsFWid = ((" +str(self.batchID)+ "*1000000000 ) + rownum)"
+        try: self.scratchDb.execute(sql)
+        except:
+           self.logger.errorPair('failed sql',sql)
+           return
+