NAME

DBIx::BulkLoader::Mysql - Perl extension for mysql bulk loading

SYNOPSIS

            

              
              
use DBIx::BulkLoader::Mysql;
# non repeating portion of the insert statement
my $insert='insert into bulk_insert (col_a,col_b,col_c) values ';
# repeating portion of the insert statement
my $placeholders='(?,?,?)';
# how many rows to buffer until insert is called
my $bulk_insert_count=5;
# db connection
my $dbh=DBI->connect(db connection info here);
my $placeholder_count=3;
my ($bulk,$error)=DBIx::BulkLoader::Mysql->new(
                dbh=>$dbh
,sql_insert=>$insert
,placeholders=>$placeholders
 );
 die $error unless $bulk;
 for( 1 .. 50 ) {
   $bulk->insert(qw(a b c));
 }
 # inserted 50 rows at once
 $bulk->insert(qw(l l x));
 # inserted 0 rows
 $bulk->insert(qw(l l x));
 # inserted 0 rows
 $bulk->flush;
 # inserted 2 rows 1 at a time
            
          

DESCRIPTION

Simple buffering bulk loader interface for mysql.

EXPORT

None.

OO Methods

This section covers the OO methods for this package.

• my ($bulk,$error)=DBIx::BulkLoader::Mysql->new(%hash);

  Package constructor.

  
              
  
                
                
  $bulk is undef on error
  $error explains why $bulk is undef
              
            

  Constructor options

  
              
  
                
                
               dbh=>$dbh
  Sets the DBH object
               sql_insert=>$insert
  Contains the body of the sql statement minus the
  placeholder segment.
               placeholders=>$placeholders
  Placeholder segment of the sql statement
               placeholder_count=>3
  Optional argument
   If you get strange insert counts or dbi bails
   set this option manually
               bulk_insert_count=>50
  Optional argument
   Sets the number of rows to buffer for insert.
               prepare_args=>{}
  Optional argument
   Arguments to be passed to $dbh->prepare
   See DBD::mysql
              
            

• $bulk->flush;

  Empties the placeholder buffer

• $bulk->insert($x,$y,$z);

  Inserts the placeholder arguments onto the buffer stack. This does not cause an insert, unless the total number of rows is the same as the constructor call "bulk_insert_count=>50".

• my $columns=$bulk->get_placeholder_count;

  Gets the total number of column placeholders.

• my $buffer_size=$bulk->get_buffer_size;

  Gets the total size of the array used for insert.

• my $sql_single=$bulk->single_sql;

  Gets the raw sql statement used for single row inserts.

• my $bulk_sql=$bulk->bulk_sql;

  Gets the raw sql statement used for bulk row inserts.

• my $single_sth=$bulk->get_prepared_single_sth;

  Gets the prepared statement handle for single row inserts.

• my $bulk_sth=$bulk->get_prepared_bulk_sth;

  Gets the prepared statement handle for bulk row inserts.

• my @buffer=$bulk->get_buffered_data;

  Returns a list containing the current buffered data

SEE ALSO

DBI, DBD::mysql

Source Forge Project

If you find this software usefil please donate to the Source Forge Project.

DBIx BulkLoader Mysql

AUTHOR

Michael Shipper

COPYRIGHT AND LICENSE

Copyright (C) 2010 by Michael Shipper

This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself, either Perl version 5.8.4 or, at your option, any later version of Perl 5 you may have available.