Ticket #442: pslib-0.6-affected_rows.patch

src/dataIO/psDB.c

@@ -706 +706 @@
 
     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;
@@ -719 +720 @@
 psS64 psDBDeleteRows(psDB *dbh, const char *tableName, psMetadata *where)
 {
     char            *query;
+    unsigned long   rowsAffected;
 
     query = psDBGenerateDeleteRowSQL(tableName, where);
     if (!query) {
@@ -744 +746 @@
         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 affected;
 }
 
 // database utility functions