Data::Stream::Bulk::DBI: N-at-a-time iteration of dbi statement results.

VERSION

version 0.11

SYNOPSIS

        use Data::Stream::Bulk::DBI;

        my $sth = $dbh->prepare("SELECT hate FROM sql"); # very big resultset
        $sth->execute;

        return Data::Stream::Bulk::DBI->new(
                sth => $sth,
                max_rows => $n, # how many at a time
                slice => [ ... ], # if you want to pass the first param to fetchall_arrayref
        );

DESCRIPTION

This implementation of Data::Stream::Bulk api works with \s-1DBI\s0 statement handles, using \*(L"fetchall_arrayref\*(R" in \s-1DBI\s0.

It fetches \*(C`max_rows\*(C' at a time (defaults to 500).

ATTRIBUTES

sth: The statement handle to call \*(C`fetchall_arrayref\*(C' on.
slice: Passed verbatim as the first param to \*(C`fetchall_arrayref\*(C'. Should usually be \*(C`undef\*(C', provided for completetness.
max_rows: The second param to \*(C`fetchall_arrayref\*(C'. Controls the size of each buffer. Defaults to 500.

METHODS

get_more: See Data::Stream::Bulk::DoneFlag. Calls \*(C`fetchall_arrayref\*(C' to get the next chunk of rows.
all: Calls \*(C`fetchall_arrayref\*(C' to get the raminder of the data (without specifying \*(C`max_rows\*(C').

AUTHOR

Yuval Kogman <[email protected]>

COPYRIGHT AND LICENSE

This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.

Data::Stream::Bulk::DBI (3pm)