Paola ruby patch row

src/Illuminate/Database/Connection.php

@@ -763,7 +763,7 @@ protected function run($query, $bindings, Closure $callback)
         // then log the query, bindings, and execution time so we will report them on
         // the event that the developer needs them. We'll log time in milliseconds.
         $this->logQuery(
-            $query, $bindings, $this->getElapsedTime($start)
+            $query, $bindings, $this->getElapsedTime($start), $this->getRowCount($result)
         );
 
         return $result;
@@ -821,16 +821,17 @@ protected function isUniqueConstraintError(Exception $exception)
      * @param  string  $query
      * @param  array  $bindings
      * @param  float|null  $time
+     * @param  int|null  $count
      * @return void
      */
-    public function logQuery($query, $bindings, $time = null)
+    public function logQuery($query, $bindings, $time = null, $count = null)
     {
         $this->totalQueryDuration += $time ?? 0.0;
 
-        $this->event(new QueryExecuted($query, $bindings, $time, $this));
+        $this->event(new QueryExecuted($query, $bindings, $time, $this, $count));
 
         if ($this->loggingQueries) {
-            $this->queryLog[] = compact('query', 'bindings', 'time');
+            $this->queryLog[] = compact('query', 'bindings', 'time', 'count');
         }
     }
 
@@ -845,6 +846,17 @@ protected function getElapsedTime($start)
         return round((microtime(true) - $start) * 1000, 2);
     }
 
+    /**
+     * Get the affected row count.
+     *
+     * @param  mixed  $result
+     * @return int|null
+     */
+    protected function getRowCount($result)
+    {
+        return is_array($result) ? count($result) : (is_int($result) ? $result : null);
+    }
+
     /**
      * Register a callback to be invoked when the connection queries for longer than a given amount of time.
      *

src/Illuminate/Database/Events/QueryExecuted.php

@@ -39,21 +39,30 @@ class QueryExecuted
      */
     public $connectionName;
 
+    /**
+     * The affected row count.
+     *
+     * @var int
+     */
+    public $count;
+
     /**
      * Create a new event instance.
      *
      * @param  string  $sql
      * @param  array  $bindings
      * @param  float|null  $time
      * @param  \Illuminate\Database\Connection  $connection
+     * @param  int|null  $count
      * @return void
      */
-    public function __construct($sql, $bindings, $time, $connection)
+    public function __construct($sql, $bindings, $time, $connection, $count)
     {
         $this->sql = $sql;
         $this->time = $time;
         $this->bindings = $bindings;
         $this->connection = $connection;
         $this->connectionName = $connection->getName();
+        $this->count = $count;
     }
 }