Add warningCount to QueryResult

src/Commands/QueryCommand.php

@@ -13,6 +13,7 @@ class QueryCommand extends AbstractCommand
     public $fields;
     public $insertId;
     public $affectedRows;
+    public $warningCount;
 
     public function getId()
     {

src/Io/Connection.php

@@ -83,6 +83,8 @@ public function query($sql, array $params = array())
             $result = new QueryResult();
             $result->resultFields = $command->resultFields;
             $result->resultRows = $rows;
+            $result->warningCount = $command->warningCount;
+
             $rows = array();
 
             $deferred->resolve($result);
@@ -96,6 +98,7 @@ public function query($sql, array $params = array())
             $result = new QueryResult();
             $result->affectedRows = $command->affectedRows;
             $result->insertId = $command->insertId;
+            $result->warningCount = $command->warningCount;
 
             $deferred->resolve($result);
         });

src/Io/Parser.php

@@ -52,7 +52,7 @@ class Parser extends EventEmitter
 
     public $seq = 0;
 
-    public $warnCount;
+    public $warningCount;
     public $message;
 
     protected $serverVersion;
@@ -197,11 +197,11 @@ public function parse($data)
                 $this->affectedRows = $this->buffer->readIntLen();
                 $this->insertId     = $this->buffer->readIntLen();
                 $this->serverStatus = $this->buffer->readInt2();
-                $this->warnCount    = $this->buffer->readInt2();
+                $this->warningCount    = $this->buffer->readInt2();
 
                 $this->message      = $this->buffer->read($this->pctSize - $len + $this->buffer->length());
 
-                $this->debug(sprintf("AffectedRows: %d, InsertId: %d, WarnCount:%d", $this->affectedRows, $this->insertId, $this->warnCount));
+                $this->debug(sprintf("AffectedRows: %d, InsertId: %d, WarningCount:%d", $this->affectedRows, $this->insertId, $this->warningCount));
                 $this->onSuccess();
                 $this->nextRequest();
             } elseif ($fieldCount === 0xFE) {
@@ -307,7 +307,7 @@ protected function onSuccess()
         if ($command instanceof QueryCommand) {
             $command->affectedRows = $this->affectedRows;
             $command->insertId     = $this->insertId;
-            $command->warnCount    = $this->warnCount;
+            $command->warningCount    = $this->warningCount;
             $command->message      = $this->message;
         }
         $command->emit('success');

src/QueryResult.php

@@ -30,4 +30,10 @@ class QueryResult
      * @var array|null
      */
     public $resultRows;
+
+    /**
+     * number of warnings (if any)
+     * @var int|null
+     */
+    public $warningCount;
 }

tests/NoResultQueryTest.php

@@ -60,6 +60,29 @@ public function testUpdateSimpleReportsAffectedRow()
         $loop->run();
     }
 
+    public function testCreateTableAgainWillAddWarning()
+    {
+        $loop = \React\EventLoop\Factory::create();
+        $connection = $this->createConnection($loop);
+
+        $sql = '
+CREATE TABLE IF NOT EXISTS `book` (
+    `id`      INT(11)      NOT NULL AUTO_INCREMENT,
+    `name`    VARCHAR(255) NOT NULL,
+    `isbn`    VARCHAR(255) NULL,
+    `author`  VARCHAR(255) NULL,
+    `created` INT(11)      NULL,
+    PRIMARY KEY (`id`)
+)';
+
+        $connection->query($sql)->then(function (QueryResult $command) {
+            $this->assertEquals(1, $command->warningCount);
+        });
+
+        $connection->quit();
+        $loop->run();
+    }
+
     public function testPingMultipleWillBeExecutedInSameOrderTheyAreEnqueuedFromHandlers()
     {
         $this->expectOutputString('123');