[ignite-php-thin-client] 05/05: IGNITE-9171: SQL: redesigned lazy mode. This closes #5473.

[isapego]

This is an automated email from the ASF dual-hosted git repository.

isapego pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-php-thin-client.git

commit d76ff7310293731324e1419fa1779f2e2e1199e6
Author: tledkov-gridgain <tled...@gridgain.com>
AuthorDate: Sun Feb 17 18:50:10 2019 +0300

    IGNITE-9171: SQL: redesigned lazy mode. This closes #5473.
---
 tests/SqlFieldsQueryTest.php | 32 ++++++++++++++++++++++++++++----
 1 file changed, 28 insertions(+), 4 deletions(-)

diff --git a/tests/SqlFieldsQueryTest.php b/tests/SqlFieldsQueryTest.php
index 3e74ca0..802f738 100644
--- a/tests/SqlFieldsQueryTest.php
+++ b/tests/SqlFieldsQueryTest.php
@@ -64,10 +64,22 @@ final class SqlFieldsQueryTestCase extends TestCase
         $this->assertEquals($set->count(), self::ELEMENTS_NUMBER);
     }
 
-    public function testGetAllWithPageSize(): void
+    public function testGetAllWithPageSizeLazyTrue(): void
     {
         $cache = self::$cache;
-        $cursor = $cache->query((new 
SqlFieldsQuery(self::$selectFromTable))->setPageSize(1));
+        $cursor = $cache->query((new 
SqlFieldsQuery(self::$selectFromTable))->setPageSize(1)->setLazy(true));
+        $set = new Set();
+        foreach ($cursor->getAll() as $fields) {
+            $this->checkCursorResult($fields);
+            $set->add($fields[0]);
+        }
+        $this->assertEquals($set->count(), self::ELEMENTS_NUMBER);
+    }
+
+    public function testGetAllWithPageSizeLazyFalse(): void
+    {
+        $cache = self::$cache;
+        $cursor = $cache->query((new 
SqlFieldsQuery(self::$selectFromTable))->setPageSize(1)->setLazy(false));
         $set = new Set();
         foreach ($cursor->getAll() as $fields) {
             $this->checkCursorResult($fields);
@@ -88,10 +100,22 @@ final class SqlFieldsQueryTestCase extends TestCase
         $this->assertEquals($set->count(), self::ELEMENTS_NUMBER);
     }
 
-    public function testIterateCursorWithPageSize(): void
+    public function testIterateCursorWithPageSizeLazyTrue(): void
+    {
+        $cache = self::$cache;
+        $cursor = $cache->query((new 
SqlFieldsQuery(self::$selectFromTable))->setPageSize(2)->setLazy(true));
+        $set = new Set();
+        foreach ($cursor as $fields) {
+            $this->checkCursorResult($fields);
+            $set->add($fields[0]);
+        }
+        $this->assertEquals($set->count(), self::ELEMENTS_NUMBER);
+    }
+
+    public function testIterateCursorWithPageSizeLazyFalse(): void
     {
         $cache = self::$cache;
-        $cursor = $cache->query((new 
SqlFieldsQuery(self::$selectFromTable))->setPageSize(2));
+        $cursor = $cache->query((new 
SqlFieldsQuery(self::$selectFromTable))->setPageSize(2)->setLazy(false));
         $set = new Set();
         foreach ($cursor as $fields) {
             $this->checkCursorResult($fields);