Merge pull request #161 from anathex/master

Fixed issue with non-empty raw data processing during init() on every fetchRow() and fetchOne() call

Author: isublimity

src/Statement.php

@@ -84,7 +84,7 @@ class Statement
     /**
      * @var int
      */
-    public $iterator=0;
+    public $iterator = 0;
 
 
     public function __construct(CurlerRequest $request)
@@ -214,6 +214,14 @@ private function check() : bool
         return true;
     }
 
+    /**
+     * @return bool
+     */
+    public function isInited()
+    {
+        return $this->_init;
+    }
+
     /**
      * @return bool
      * @throws Exception\TransportException
@@ -224,46 +232,39 @@ private function init()
             return false;
         }
 
-
         $this->check();
 
-
         $this->_rawData = $this->response()->rawDataOrJson($this->format);
 
         if (!$this->_rawData) {
             $this->_init = true;
             return false;
         }
-        $data=[];
+
+        $data = [];
         foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) {
 
             if (isset($this->_rawData[$key])) {
-                if ($key=='data')
-                {
+                if ($key=='data') {
                     $data=$this->_rawData[$key];
-                }
-                else{
+                } else {
                     $this->{$key} = $this->_rawData[$key];
                 }
-
             }
         }
 
         if (empty($this->meta)) {
-            throw  new QueryException('Can`t find meta');
+            throw new QueryException('Can`t find meta');
         }
 
         $isJSONCompact=(stripos($this->format,'JSONCompact')!==false?true:false);
         $this->array_data = [];
         foreach ($data as $rows) {
             $r = [];
 
-
-            if ($isJSONCompact)
-            {
-                $r[]=$rows;
-            }
-            else {
+            if ($isJSONCompact) {
+                $r[] = $rows;
+            } else {
                 foreach ($this->meta as $meta) {
                     $r[$meta['name']] = $rows[$meta['name']];
                 }
@@ -272,6 +273,7 @@ private function init()
             $this->array_data[] = $r;
         }
 
+        $this->_init = true;
 
         return true;
     }

tests/FetchTest.php

@@ -2,7 +2,6 @@
 
 namespace ClickHouseDB\Tests;
 
-use ClickHouseDB\Exception\QueryException;
 use PHPUnit\Framework\TestCase;
 
 /**
@@ -15,7 +14,6 @@ final class FetchTest extends TestCase
     use WithClient;
 
 
-
     public function testFetchRowKeys()
     {
         $result = $this->client->select(
@@ -33,6 +31,7 @@ public function testFetchRowKeys()
         $this->assertEquals(null,$result->fetchOne('q'));
         $this->assertEquals(0,$result->fetchOne('number'));
     }
+
     public function testFetchOne()
     {
         $result = $this->client->select(
@@ -52,4 +51,14 @@ public function testFetchOne()
         $this->assertEquals(1,$result->fetchRow('number'));
         $this->assertEquals(2,$result->fetchRow('number'));
     }
+
+    public function testCorrectInitOnFetchRow()
+    {
+        $result = $this->client->select(
+            'SELECT number FROM system.numbers LIMIT 5'
+        );
+
+        $result->fetchRow();
+        $this->assertTrue($result->isInited());
+    }
 }