Ticket #442: pslib-0.6.0-affected_rows.patch

src/dataIO/psDB.c

@@ -758 +758 @@
 
     psFree(bind);
 
+    // mysql_stmt_affected_rows() must be called before a commit
+    rowsAffected = mysql_stmt_affected_rows(stmt);
+
     // point of no return
     mysql_commit(dbh->mysql);
 
-    rowsAffected = mysql_stmt_affected_rows(stmt);
-
     mysql_stmt_close(stmt);
 
     return rowsAffected;
@@ -771 +772 @@
 psS64 psDBDeleteRows(psDB *dbh, const char *tableName, psMetadata *where)
 {
     char            *query;
+    unsigned long   rowsAffected;
 
     query = psDBGenerateDeleteRowSQL(tableName, where);
     if (!query) {
@@ -796 +798 @@
         return 1;
     }
 
+    // mysql_affected_rows() must be called before a commit
+    rowsAffected = (psS64)mysql_affected_rows(dbh->mysql);
+
     // point of no return
     mysql_commit(dbh->mysql);
 
-    return (psS64)mysql_affected_rows(dbh->mysql);
+    return rowsAffected;
 }
 
 // database utility functions