BUG 9321 executeQuery() does not return the number of records affected..SLOVED

- ExecuteQuery() is supposed to return the number of records affected by DELETE, UPDATE and INSERT commands.
- Adjustment in the number of records for different Engines.

gulliver/thirdparty/creole/drivers/mssql/MSSQLConnection.php

@@ -192,7 +192,8 @@ class MSSQLConnection extends ConnectionCommon implements Connection {
             throw new SQLException('Could not execute update', mssql_get_last_message(), $sql);
         }
         
-        return $this->getUpdateCount();
+        return (int) mssql_rows_affected($this->dblink);
+        // return $this->getUpdateCount();
     }
 
     /**

workflow/engine/classes/class.pmFunctions.php

@@ -250,19 +250,20 @@ function executeQuery ($SqlStatement, $DBConnectionUID = 'workflow', $aParameter
                     break;
                 case preg_match( "/^INSERT\s/i", $statement ):
                     $rs = $con->executeUpdate( $SqlStatement );
+                    $result = $con->getUpdateCount();
                     $con->commit();
                     //$result = $lastId->getId();
-                    $result = 1;
+                    // $result = 1;
                     break;
                 case preg_match( "/^UPDATE\s/i", $statement ):
                     $rs = $con->executeUpdate( $SqlStatement );
-                    $con->commit();
                     $result = $con->getUpdateCount();
+                    $con->commit();
                     break;
                 case preg_match( "/^DELETE\s/i", $statement ):
                     $rs = $con->executeUpdate( $SqlStatement );
-                    $con->commit();
                     $result = $con->getUpdateCount();
+                    $con->commit();
                     break;
             }
         } else {

workflow/engine/classes/class.pmScript.php

@@ -679,6 +679,7 @@ function executeQueryOci ($sql, $connection, $aParameter = array())
                 }
             }
             $objExecute = oci_execute( $stid, OCI_DEFAULT );
+            $result = oci_num_rows ($stid);
             if ($objExecute) {
                 oci_commit( $conn );
             } else {
@@ -688,7 +689,7 @@ function executeQueryOci ($sql, $connection, $aParameter = array())
             oci_free_statement( $stid );
             oci_close( $conn );
             if ($isValid) {
-                return true;
+                return $result;
             } else {
                 return oci_error();
             }