Changeset 33098 for branches/meh_branches/ppsub_test/ippToPsps/jython/mysql.py

Timestamp:

Jan 11, 2012, 11:19:21 PM (15 years ago)

Author:

mhuber

Message:

merged latest r33093 trunk changes to meh_branches/ppsub_test

Location:

branches/meh_branches/ppsub_test

Files:

• . (modified) (1 prop)
• ippToPsps/jython/mysql.py (modified) (4 diffs)

branches/meh_branches/ppsub_test/ippToPsps/jython/mysql.py

@@ -47 +47 @@
         self.everythingOK = True
 
-
     '''
     Disconnect from database
@@ -61 +60 @@
         self.logger.debug("MySql destructor")
         self.disconnect()
+    
+    '''
+    Locks a table. This is wait if the locks is already held by another session
+    '''
+    def lockTable(self, table):
+        self.execute("LOCK TABLES " + table + " WRITE")
+
+    '''
+    Unlocks all tables locked by this session.
+    '''
+    def unlockTables(self):
+        self.execute("UNLOCK TABLES")
 
     '''
@@ -215 +226 @@
         nBad = rs.getInt(1)
 
-        sql="DELETE from " + tableName + " WHERE " + columnName + " = " + value
-        self.execute(sql)
-        self.logger.info("%s '%s' values in %s    %5d deleted" % (columnName, value, tableName, nBad))
+        sql="DELETE FROM " + tableName + " WHERE " + columnName + " = " + value
+        self.execute(sql)
+        self.logger.debugPair("%s rows with %s" % (columnName, value), "%d deleted" % nBad)
+
+        return nBad
 
     '''
@@ -229 +242 @@
         nBad = rs.getInt(1)
 
-        sql="DELETE from " + tableName + " WHERE " + columnName + " IS NULL"
-        self.execute(sql)
-        self.logger.debugPair("NULL %s values" % columnName, "%d deleted" % nBad)
+        sql="DELETE FROM " + tableName + " WHERE " + columnName + " IS NULL"
+        self.execute(sql)
+        self.logger.debugPair("NULL %s values in %s" % (columnName, tableName), "%d deleted" % nBad)
 
         return nBad