diff options
| -rwxr-xr-x | src/illuminate/FirebirdConnection.php | 44 |
1 files changed, 42 insertions, 2 deletions
diff --git a/src/illuminate/FirebirdConnection.php b/src/illuminate/FirebirdConnection.php index b279632..5b2a286 100755 --- a/src/illuminate/FirebirdConnection.php +++ b/src/illuminate/FirebirdConnection.php @@ -43,7 +43,7 @@ class FirebirdConnection extends DatabaseConnection /** * Get a schema builder instance for this connection. * - * @return \Firebird\Illuminate\Schema\Builder + * @return \Firebird\Illuminate\Schema\FirebirdBuilder */ public function getSchemaBuilder(): FirebirdSchemaBuilder { @@ -77,7 +77,7 @@ class FirebirdConnection extends DatabaseConnection /** * Get a new query builder instance. * - * @return \Firebird\IlluminateQuery\FirebirdBuilder + * @return \Firebird\Illuminate\Query\FirebirdBuilder */ public function query() { @@ -158,6 +158,46 @@ class FirebirdConnection extends DatabaseConnection } /** + * Run a select statement against the database and returns a generator. + * + * @param string $query + * @param array $bindings + * @param bool $useReadPdo + * @return \Generator<int, \stdClass> + */ + public function cursor($query, $bindings = [], $useReadPdo = true) + { + $statement = $this->run($query, $bindings, function ($query, $bindings) use ($useReadPdo) { + if ($this->pretending()) { + return []; + } + + // First we will create a statement for the query. Then, we will set the fetch + // mode and prepare the bindings for the query. Once that's done we will be + // ready to execute the query against the database and return the cursor. + $statement = $this->prepared($this->getPdoForSelect($useReadPdo) + ->prepare($query)); + + $this->bindValues( + $statement, $this->prepareBindings($bindings) + ); + + // Next, we'll execute the query against the database and return the statement + // so we can return the cursor. The cursor will use a PHP generator to give + // back one row at a time without using a bunch of memory to render them. + $statement->execute(); + + return $statement; + }); + + while ($record = $statement->fetch()) { + $lowerCaseRow = array_change_key_case((array) $record, CASE_LOWER); + + yield (object) $lowerCaseRow; + } + } + + /** * Execute a stored procedure. * * @param string $procedure |