FIX Revert using generators

This commit is contained in:
Steve Boyd 2022-09-02 11:15:09 +12:00
parent 0c2d67443a
commit 0a05cbcc17
1 changed files with 17 additions and 5 deletions

View File

@ -2,7 +2,6 @@
namespace SilverStripe\PostgreSQL; namespace SilverStripe\PostgreSQL;
use Iterator;
use SilverStripe\ORM\Connect\Query; use SilverStripe\ORM\Connect\Query;
/** /**
@ -57,11 +56,12 @@ class PostgreSQLQuery extends Query
} }
} }
public function getIterator(): Iterator public function seek($row)
{ {
while ($row = pg_fetch_array($this->handle, null, PGSQL_NUM)) { // Specifying the zero-th record here will reset the pointer
yield $this->parseResult($row); $result = pg_fetch_array($this->handle, $row, PGSQL_NUM);
}
return $this->parseResult($result);
} }
public function numRecords() public function numRecords()
@ -69,6 +69,18 @@ class PostgreSQLQuery extends Query
return pg_num_rows($this->handle); return pg_num_rows($this->handle);
} }
public function nextRecord()
{
$row = pg_fetch_array($this->handle, null, PGSQL_NUM);
// Correct non-string types
if ($row) {
return $this->parseResult($row);
}
return false;
}
/** /**
* @param array $row * @param array $row
* @return array * @return array