sub import {
 my $self = shift;
 my @data;
 while (@data = $self->{reader}->row) {
  $self->{_query}->execute(@data);
 }
}