File Coverage

blib/lib/DBIx/SimpleMigration/Client.pm

Criterion	Covered	Total	%
statement	29	34	85.2
branch	3	6	50.0
condition			n/a
subroutine	6	7	85.7
pod	0	1	0.0
total	38	48	79.1

package DBIx::SimpleMigration::Client;

use Carp;

our $VERSION = '1.0.2';

sub new {
  my $self = bless {}, shift;
  return unless @_ % 2 == 0;
  my %args = @_;

  $self->{dbh} = $args{dbh};
  $self->{options} = $args{options};

  return $self;
}

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

  my $query = '
    CREATE TABLE IF NOT EXISTS ' . $self->{options}->{migrations_table} . ' (
      name varchar(255) primary key not null,
      applied datetime not null
    )
  ';

  $self->{dbh}->do($query) or croak __PACKAGE__ . ': Error creating table: ' . $self->{dbh}->errstr;

  return $self;
}

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

  return 0; # checking seems to be largely driver-dependent
}

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

  return 1; # to be overloaded per-DB
}

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

  my $query = '
    SELECT name, applied
    FROM ' . $self->{options}->{migrations_table};

  my $result = $self->{dbh}->selectall_arrayref($query, {Slice => {}});

  my %applied_migrations;
  foreach my $row (@{$result}) {
    $applied_migrations{$row->{name}} = $row->{applied};
  }

  return \%applied_migrations;
}

sub _insert_migration {
  my ($self, $key) = @_;

  eval {
    my $query = 'INSERT INTO ' . $self->{options}->{migrations_table} . ' (name, applied) VALUES (?, CURRENT_TIMESTAMP)';
    my $sth = $self->{dbh}->prepare($query);
    $sth->execute($key);
  };

  if ($@) {
    carp __PACKAGE__ . ': Error recording migration: ' . $self->{dbh}->errstr;
    return;
  }

  return 1;
}

1;

__END__