Changeset 31971

Timestamp:

Aug 2, 2011, 1:22:21 PM (15 years ago)

Author:

rhenders

Message:

Added method to reset DVO tables when running dvoToMySQL

File:

• trunk/ippToPsps/jython/scratchdb.py (modified) (5 diffs)

trunk/ippToPsps/jython/scratchdb.py

@@ -23 +23 @@
 
         if useFull:
-            self.dvoMeta = "dvoMetaFull"
-            self.dvoDetection = "dvoDetectionFull"
+            self.dvoMetaTable = "dvoMetaFull"
+            self.dvoDetectionTable = "dvoDetectionFull"
+            self.dvoDoneTable = "dvoDone"
         else:
-            self.dvoMeta = "dvoMeta"
-            self.dvoDetection = "dvoDetection"
-
-        self.logger.debug("ScratchDb constructor, using DVO tables: " + self.dvoMeta + " and " + self.dvoDetection)
+            self.dvoMetaTable = "dvoMeta"
+            self.dvoDetectionTable = "dvoDetection"
+
+        self.logger.debug("ScratchDb constructor, using DVO tables: " + self.dvoMetaTable + " and " + self.dvoDetectionTable)
 
     '''
@@ -59 +60 @@
         imageID = -1 
                
-        sql = "SELECT imageID FROM " + self.dvoMeta + " WHERE sourceID = %s AND externID = %s" % (sourceID, externID) 
+        sql = "SELECT imageID FROM " + self.dvoMetaTable + " WHERE sourceID = %s AND externID = %s" % (sourceID, externID) 
         try: 
             rs = self.executeQuery(sql)   
@@ -76 +77 @@
         flags = 0
 
-        sql = "SELECT flags FROM " + self.dvoMeta + " WHERE sourceID = %s AND externID = %s" % (sourceID, externID)
+        sql = "SELECT flags FROM " + self.dvoMetaTable + " WHERE sourceID = %s AND externID = %s" % (sourceID, externID)
         try:
             rs = self.executeQuery(sql)  
@@ -92 +93 @@
         photcode = -1
 
-        sql = "SELECT photcode FROM " + self.dvoMeta + " WHERE sourceID = %s AND externID = %s" % (sourceID, externID)
+        sql = "SELECT photcode FROM " + self.dvoMetaTable + " WHERE sourceID = %s AND externID = %s" % (sourceID, externID)
         try:
             rs = self.executeQuery(sql)  
@@ -194 +195 @@
         except: 
             self.logger.error("Unable to create DVO detection database table")
+
+
+    '''
+    Drops and recreates tables necessary for dvoToMySQL program. Be very careful before using this...
+    '''
+    def resetDvoToMysqlTables(self):
+
+       self.logger.infoPair("Dropping table", self.dvoMetaTable)
+       self.dropTable(self.dvoMetaTable)
+       self.logger.infoPair("Dropping table", self.dvoDetectionTable)
+       self.dropTable(self.dvoDetectionTable)
+       self.logger.infoPair("Dropping table", self.dvoDoneTable)
+       self.dropTable(self.dvoDoneTable) 
+
+       self.logger.infoPair("Creating table", self.dvoMetaTable)
+       sql = "CREATE TABLE " + self.dvoMetaTable + " LIKE dvoMeta"
+       try: self.execute(sql)
+       except: self.logger.error("Unable to create table " + self.dvoMetaTable)
+
+       self.logger.infoPair("Creating table", self.dvoDetectionTable)
+       sql = "CREATE TABLE " + self.dvoDetectionTable + " LIKE dvoDetection"
+       try: self.execute(sql)
+       except: self.logger.error("Unable to create table " + self.dvoDetectionTable)
+
+       self.logger.infoPair("Creating table", self.dvoDoneTable )
+       sql = "CREATE TABLE " + self.dvoDoneTable + " (name VARCHAR(100))"
+       try: self.execute(sql)
+       except: self.logger.error("Unable to create table " + self.dvoDoneTable)
+
+
+