antevenio/pdo-mysql-select-iterator

PHP PDO Mysql select statement iterator implemented as multiple queries using LIMIT clauses

pdo-mysql-select-iterator

, _(*1)

PHP PDO Mysql select statement iterator implemented as multiple queries using LIMIT clauses., _(*2)

What is this thing

So, you want to iterate through millions of table rows coming as a result of some MySQL select query because you want to do your thingie with them, but alas!, your lovely database admin doesn't like queries that stay for too long running in his server, or even worse, the server itself isn't able to hold them!. What do we do?, we do issue several queries that would fetch smaller blocks of rows in place., _(*3)

This is an just a PHP iterator based on this concept. Upon receiving a SELECT query and a PDO database connection, an iterator is built so you can seamlessly traverse results without having to worry about anything else., _(*4)

Install

To add as a dependency using composer:, _(*5)

composer require antevenio/pdo-mysql-select-iterator, _(*6)

Usage example

<?php
$pdo = new PDO('mysql:host=localhost;dbname=kidsshouting', 'myuser', 'mypass');
$iterator = (new \PdoMysqlSelectIterator\Factory())
    ->create($pdo, "select a,b from tbl order by a", 1000);
// Get a total row count from the query if needed
$total = count($iterator);
foreach ($iterator as $item) {
    // Do your stuff with $item
}

Notes

The factory will throw a InvalidQueryException on non "select" queries., _(*7)

The factory will only return a LimitIterator when: * The blockSize is > 0 * The query has an "order by" clause * The query is not using any "rand()" functions, _(*8)

If any of the previous conditions is NOT met, the factory will return a non limit based iterator called "NativePDOIterator"., _(*9)

To ensure consistency among results, you might want to get the whole iteration and count inside a database transaction. The most suitable isolation level would be REPEATABLE-READ:, _(*10)

https://dev.mysql.com/doc/refman/5.7/en/innodb-transaction-isolation-levels.html#isolevel_repeatable-read, _(*11)