connection = $connection; } public function forAttributeCode(string $attributeCode): \Iterator { $sql = << :searchAfterId ORDER BY ao.id LIMIT :limit SQL; $searchAfterId = 0; do { $results = $this->connection->executeQuery( $sql, [ 'attributeCode' => $attributeCode, 'searchAfterId' => $searchAfterId, 'limit' => self::BATCH_QUERY_SIZE, ], ['limit' => \PDO::PARAM_INT] )->fetchAllAssociative(); foreach ($results as $result) { yield $result['code']; $searchAfterId = $result['id']; } } while (count($results) === self::BATCH_QUERY_SIZE); } }