view release on metacpan or  search on metacpan

lib/Aniki/Schema/Relationships.pm  view on Meta::CPAN

package Aniki::Schema::Relationships;
use 5.014002;

use namespace::autoclean;
use Mouse v2.4.5;
use SQL::Translator::Schema::Constants;
use Aniki::Schema::Relationship;

has schema => (
    is       => 'ro',
    required => 1,
    weak_ref => 1,
);

has table => (
    is       => 'ro',
    required => 1,
);

has rule => (
    is      => 'rw',
    default => sub { +{} },
);

sub add {
    my $self = shift;
    my $relationship = Aniki::Schema::Relationship->new(schema => $self->schema, @_);

    my $name = $relationship->name;
    exists $self->rule->{$name}
        and die "already exists $name in rule. (table:@{[ $self->table->name ]})";
    $self->rule->{$name} = $relationship;
}

sub add_by_constraint {
    my ($self, $constraint) = @_;
    die "Invalid constraint: @{[ $constraint->name ]}. (table:@{[ $self->table->name ]})" if $constraint->type ne FOREIGN_KEY;

    if ($constraint->table->name eq $self->table->name) {
        $self->add(
            src_table_name  => $constraint->table->name,
            src_columns     => [$constraint->field_names],
            dest_table_name => $constraint->reference_table,
            dest_columns    => [$constraint->reference_fields],
        );
    }
    elsif ($constraint->reference_table eq $self->table->name) {
        $self->add(
            src_table_name  => $constraint->reference_table,
            src_columns     => [$constraint->reference_fields],
            dest_table_name => $constraint->table->name,
            dest_columns    => [$constraint->field_names],
        );
    }
    else {
        die "Invalid constraint: @{[ $constraint->name ]}. (table:@{[ $self->table->name ]})";
    }
}

sub names {
    my $self = shift;
    return keys %{ $self->rule };
}