File Coverage

blib/lib/DBIx/SimpleMigration/Migration.pm

Criterion	Covered	Total	%
statement	44	49	89.8
branch	7	16	43.7
condition	1	3	33.3
subroutine	8	8	100.0
pod	0	2	0.0
total	60	78	76.9

package DBIx::SimpleMigration::Migration;

use 5.10.0;
use strict;
use warnings;

use Carp;
use File::Basename;
use SQL::SplitStatement;

our $VERSION = '1.0.1';

sub new {
  my $self = bless {}, shift;

  return unless @_ % 2 == 0;
  my %args = @_;

  croak __PACKAGE__ . '->new: file option missing or does not exist'
    unless ($args{file} && -f $args{file});

  croak __PACKAGE__ . '->new: client missing' unless $args{client};

  $self->{_client} = $args{client};

  ($self->{_key}) = fileparse($args{file});

  my $contents;
  {
    local $/ = undef;
    open FH, '<', $args{file} or die 'Error opening file: ' . $!;
    $contents = ;
    close FH;
  }

  my $splitter = SQL::SplitStatement->new;
  my @statements = $splitter->split($contents);

  $self->{_statements} = \@statements;

  return $self;
}

sub apply {
  my ($self) = @_;

  say 'Applying ' . $self->{_key};

  if (!$self->{_client}->_lock_migrations_table) {
    die 'Error acquiring table lock';
  }

  eval {
    foreach my $query (@{$self->{_statements}}) {
      $self->{_client}->{dbh}->do($query)
    }
  };

  if ($@) {
    $self->{_client}->{dbh}->rollback or die 'Error rolling back transaction: ' . $self->{_client}->{dbh}->errstr;
    die 'Error applying changeset';
  }

  if (!$self->{_client}->_insert_migration($self->{_key})) {
    $self->{_client}->{dbh}->rollback;
    die;
  }

  $self->{_client}->{dbh}->commit;
}

1;

__END__