commit d76ff7310293731324e1419fa1779f2e2e1199e6
author tledkov-gridgain <tledkov@gridgain.com> Sun Feb 17 18:50:10 2019 +0300
committer devozerov <ppozerov@gmail.com> Sun Feb 17 18:50:10 2019 +0300
tree 944efde7c1b8405f31be6f59b40b2fc0465658f9
parent b09f264194c56180caf5228087fa21ea0a7d7f2e

IGNITE-9171: SQL: redesigned lazy mode. This closes #5473.

tests/SqlFieldsQueryTest.php

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 @@
         $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 @@
         $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));
+        $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)->setLazy(false));
         $set = new Set();
         foreach ($cursor as $fields) {
             $this->checkCursorResult($fields);