File Coverage

blib/lib/Otogiri/Plugin/BulkInsert.pm

Criterion	Covered	Total	%
statement	20	20	100.0
branch			n/a
condition			n/a
subroutine	4	4	100.0
pod	1	1	100.0
total	25	25	100.0

package Otogiri::Plugin::BulkInsert;
use 5.008005;
use strict;
use warnings;

our $VERSION = "0.02";
our @EXPORT = qw(bulk_insert);

sub bulk_insert {
    my ($self, $table, $key_list, $row_list) = @_;

    my $keys = join(', ', @$key_list);
    my $binds = join(', ', map {'?'} @$key_list);

    my $sql = sprintf('INSERT INTO %s (%s) VALUES (%s)', $table, $keys, $binds);
    my $sth = $self->dbh->prepare($sql);

    my $txn = $self->txn_scope();

    for my $row (@$row_list) {
        my %rowdata = %$row;
        $sth->execute(@rowdata{@$key_list});
    }

    $txn->commit();

    $sth->finish;
}

1;
__END__