<?php

header('Content-type: text/plain');

$pg = pg_connect('host=darius port=5432 dbname=unstable_steekr_com user=******* password=**********');

pg_query($pg, 'BEGIN;');

pg_query($pg, 'CREATE TEMP TABLE pwet ON COMMIT DROP TABLESPACE tbs_index AS SELECT * FROM users;');

pg_query($pg, 'DECLARE pwet_cursor SCROLL CURSOR FOR (SELECT * FROM pwet);');

$offset = 0;
$limit = 10;

while (true)
{
    $move   = pg_query($pg, 'MOVE FORWARD '.$offset.' FROM pwet_cursor;');
    $fetch  = pg_query($pg, 'FETCH FORWARD '.$limit.' FROM pwet_cursor;');

    if ($offset !== pg_affected_rows($move))
    {
        echo 'OOOOOOOOOOPSS =======> ';
    }

    echo pg_affected_rows($move).' => '.pg_affected_rows($fetch)."\n";

    $offset = $offset + $limit;

    if (!pg_affected_rows($fetch))
    {
        break;
    }
}

pg_query($pg, 'CLOSE pwet_cursor;');
pg_query($pg, 'COMMIT;');

?>