File Coverage

blib/lib/Daje/Database/Migrator.pm

Criterion	Covered	Total	%
statement	8	37	21.6
branch	0	4	0.0
condition			n/a
subroutine	3	4	75.0
pod	1	1	100.0
total	12	46	26.0

package Daje::Database::Migrator;
use Mojo::Base -base, -signatures;
use v5.40;

use Mojo::Loader qw(load_class);

# NAME
# ====
#
# Daje::Database::Migrator - It's the database migrate plugin for Daje::Workflow
#
# SYNOPSIS
# ========
#
#    use Daje::Database::Migrator;
#
#    push @{$migrations}, {class => 'Daje::Workflow::Database', name => 'workflow', migration => 2};
#
#    push @{$migrations}, {file => '/home/user/schema/users.sql', name => 'users'};
#
#    Daje::Database::Migrator->new(
#         pg            => $pg,
#         migrations    => $migrations,
#     )->migrate();
#
# DESCRIPTION
# ===========
#
# Daje::Database::Migrator is the Database migrate plugin for Daje
#
# LICENSE
# =======
#
# Copyright (C) janeskil1525.
#
# This library is free software; you can redistribute it and/or modify
# it under the same terms as Perl itself.
#
# AUTHOR
# ======
#
# janeskil1525 [e-mail]
#

our $VERSION = "1.05";

has 'pg';
has 'migrations';

sub migrate($self) {

    my $length = scalar @{$self->migrations};
    for (my $i = 0; $i < $length; $i++) {
        if (exists @{$self->migrations}[$i]->{class}) {
            try {
                my $cl = load_class @{$self->migrations}[$i]->{class};
                $self->pg->migrations->name(
                    @{$self->migrations}[$i]->{name}
                )->from_data(
                    @{$self->migrations}[$i]->{class},
                    @{$self->migrations}[$i]->{name}
                )->migrate(
                    @{$self->migrations}[$i]->{migration}
                );
            }
            catch($e) {
                say $e;
                say @{$self->migrations}[$i]->{class};
                say @{$self->migrations}[$i]->{name};
                say @{$self->migrations}[$i]->{migration};
            }
        }
        elsif (exists @{$self->migrations}[$i]->{file}) {
            $self->pg->migrations->name(
                @{$self->migrations}[$i]->{name}
            )->from_file(
                @{$self->migrations}[$i]->{file}
            )->migrate(
                @{$self->migrations}[$i]->{migration}
            );
        }
    }

    return 1;
}


1;
__END__