Changeset 33357 for trunk

Timestamp:

Feb 23, 2012, 4:19:12 PM (14 years ago)

Author:

rhenders

Message:

class variable to show if we are connected or not; method to check for other connections to this Db (used to determine if it is safe to use a particular scratch Db)

File:

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

trunk/ippToPsps/jython/mysql.py

@@ -21 +21 @@
 
     '''
-    def __init__(self, logger, config, dbType):
+    def __init__(self, logger, config, dbType, dbName=None):
 
         # set up logging
@@ -29 +29 @@
 
         # open config and grab database parameters
-        self.dbName = config.getDbName(dbType)
+        if not dbName: self.dbName = config.getDbName(dbType)
+        else: self.dbName = dbName
         self.dbHost = config.getDbHost(dbType)
         self.dbUser = config.getDbUser(dbType)
@@ -42 +43 @@
         except:
             self.logger.error("Unable to connect to " + self.url)
-            self.everythingOK = False
+            self.everythingOK = False # TODO need this?
+            self.connected = False
             return
 
         self.everythingOK = True
+        self.connected = True
 
     '''
@@ -52 +55 @@
     def disconnect(self):
         self.con.close()
+        self.connected = False
 
     '''
@@ -85 +89 @@
         sql = "KILL %d" % connectionID
         self.execute(sql)
+
+    '''
+    Checks whether there are any other connections to this database
+    '''
+    def anyOtherConnections(self):
+
+        sql = "SELECT COUNT(*) \
+               FROM INFORMATION_SCHEMA.PROCESSLIST \
+               WHERE DB='" + self.dbName + "'"
+        try:
+            rs = self.executeQuery(sql)
+            rs.first()
+            if rs.getInt(1) > 1: return True
+            else: return False
+        except:
+            self.logger.errorPair("Could not check for connection", sql)
+            pass
+
+        return True
 
     '''