package SQL::Translator::Schema::Table;
-# ----------------------------------------------------------------------
-# $Id: Table.pm 1440 2009-01-17 16:31:57Z jawnsy $
-# ----------------------------------------------------------------------
-# Copyright (C) 2002-2009 SQLFairy Authors
-#
-# This program is free software; you can redistribute it and/or
-# modify it under the terms of the GNU General Public License as
-# published by the Free Software Foundation; version 2.
-#
-# This program is distributed in the hope that it will be useful, but
-# WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-# General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with this program; if not, write to the Free Software
-# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
-# 02111-1307 USA
-# -------------------------------------------------------------------
-
=pod
=head1 NAME
use SQL::Translator::Schema::Table;
my $table = SQL::Translator::Schema::Table->new( name => 'foo' );
-=head1 DESCSIPTION
+=head1 DESCRIPTION
C<SQL::Translator::Schema::Table> is the table object.
=cut
use strict;
+use warnings;
use SQL::Translator::Utils 'parse_list_arg';
use SQL::Translator::Schema::Constants;
use SQL::Translator::Schema::Constraint;
use SQL::Translator::Schema::Field;
use SQL::Translator::Schema::Index;
-use Data::Dumper;
+
+use Carp::Clan '^SQL::Translator';
+use List::Util 'max';
use base 'SQL::Translator::Schema::Object';
-use vars qw( $FIELD_ORDER );
+our $VERSION = '1.59';
# Stringify to our name, being careful not to pass any args through so we don't
# accidentally set it to undef. We also have to tweak bool so the object is
fallback => 1,
;
-# ----------------------------------------------------------------------
-
__PACKAGE__->_attributes( qw/schema name comments options order/ );
=pod
Object constructor.
- my $table = SQL::Translator::Schema::Table->new(
+ my $table = SQL::Translator::Schema::Table->new(
schema => $schema,
name => 'foo',
);
=cut
-# ----------------------------------------------------------------------
sub add_constraint {
=pod
=head2 add_constraint
-Add a constraint to the table. Returns the newly created
+Add a constraint to the table. Returns the newly created
C<SQL::Translator::Schema::Constraint> object.
my $c1 = $table->add_constraint(
else {
my %args = @_;
$args{'table'} = $self;
- $constraint = $constraint_class->new( \%args ) or
+ $constraint = $constraint_class->new( \%args ) or
return $self->error( $constraint_class->error );
}
if ( $pk && $constraint->type eq PRIMARY_KEY ) {
$self->primary_key( $constraint->fields );
$pk->name($constraint->name) if $constraint->name;
- my %extra = $constraint->extra;
+ my %extra = $constraint->extra;
$pk->extra(%extra) if keys %extra;
$constraint = $pk;
$ok = 0;
}
}
#
- # See if another constraint of the same type
+ # See if another constraint of the same type
# covers the same fields. -- This doesn't work! ky
#
# elsif ( $constraint->type ne CHECK_C ) {
# my @field_names = $constraint->fields;
-# for my $c (
-# grep { $_->type eq $constraint->type }
-# $self->get_constraints
+# for my $c (
+# grep { $_->type eq $constraint->type }
+# $self->get_constraints
# ) {
# my %fields = map { $_, 1 } $c->fields;
# for my $field_name ( @field_names ) {
# if ( $fields{ $field_name } ) {
# $constraint = $c;
-# $ok = 0;
+# $ok = 0;
# last;
# }
# }
return $constraint;
}
-# ----------------------------------------------------------------------
sub drop_constraint {
=pod
$constraint_name = shift;
}
- if ( ! grep { $_->name eq $constraint_name } @ { $self->{'constraints'} } ) {
+ if ( ! grep { $_->name eq $constraint_name } @ { $self->{'constraints'} } ) {
return $self->error(qq[Can't drop constraint: "$constraint_name" doesn't exist]);
}
return $constraint;
}
-# ----------------------------------------------------------------------
sub add_index {
=pod
else {
my %args = @_;
$args{'table'} = $self;
- $index = $index_class->new( \%args ) or return
+ $index = $index_class->new( \%args ) or return
$self->error( $index_class->error );
}
foreach my $ex_index ($self->get_indices) {
return $index;
}
-# ----------------------------------------------------------------------
sub drop_index {
=pod
$index_name = shift;
}
- if ( ! grep { $_->name eq $index_name } @{ $self->{'indices'} }) {
+ if ( ! grep { $_->name eq $index_name } @{ $self->{'indices'} }) {
return $self->error(qq[Can't drop index: "$index_name" doesn't exist]);
}
return $index;
}
-# ----------------------------------------------------------------------
sub add_field {
=pod
=head2 add_field
Add an field to the table. Returns the newly created
-C<SQL::Translator::Schema::Field> object. The "name" parameter is
-required. If you try to create a field with the same name as an
+C<SQL::Translator::Schema::Field> object. The "name" parameter is
+required. If you try to create a field with the same name as an
existing field, you will get an error and the field will not be created.
my $f1 = $table->add_field(
size => 11,
);
- my $f2 = SQL::Translator::Schema::Field->new(
- name => 'name',
+ my $f2 = SQL::Translator::Schema::Field->new(
+ name => 'name',
table => $table,
);
$f2 = $table->add_field( $field2 ) or die $table->error;
else {
my %args = @_;
$args{'table'} = $self;
- $field = $field_class->new( \%args ) or return
+ $field = $field_class->new( \%args ) or return
$self->error( $field_class->error );
}
- $field->order( ++$FIELD_ORDER );
+ my $existing_order = { map { $_->order => $_->name } $self->get_fields };
+
+ # supplied order, possible unordered assembly
+ if ( $field->order ) {
+ if($existing_order->{$field->order}) {
+ croak sprintf
+ "Requested order '%d' for column '%s' conflicts with already existing column '%s'",
+ $field->order,
+ $field->name,
+ $existing_order->{$field->order},
+ ;
+ }
+ }
+ else {
+ my $last_field_no = max(keys %$existing_order) || 0;
+ if ( $last_field_no != scalar keys %$existing_order ) {
+ croak sprintf
+ "Table '%s' field order incomplete - unable to auto-determine order for newly added field",
+ $self->name,
+ ;
+ }
+
+ $field->order( $last_field_no + 1 );
+ }
+
# We know we have a name as the Field->new above errors if none given.
my $field_name = $field->name;
- if ( exists $self->{'fields'}{ $field_name } ) {
+ if ( $self->get_field($field_name) ) {
return $self->error(qq[Can't create field: "$field_name" exists]);
}
else {
return $field;
}
-# ----------------------------------------------------------------------
+
sub drop_field {
=pod
=head2 drop_field
-Remove a field from the table. Returns the field object if the field was
-found and removed, an error otherwise. The single parameter can be either
+Remove a field from the table. Returns the field object if the field was
+found and removed, an error otherwise. The single parameter can be either
a field name or an C<SQL::Translator::Schema::Field> object.
$table->drop_field('myfield');
return $field;
}
-# ----------------------------------------------------------------------
sub comments {
=pod
=head2 comments
-Get or set the comments on a table. May be called several times to
+Get or set the comments on a table. May be called several times to
set and it will accumulate the comments. Called in an array context,
returns each comment individually; called in a scalar context, returns
all the comments joined on newlines.
}
if ( @{ $self->{'comments'} || [] } ) {
- return wantarray
+ return wantarray
? @{ $self->{'comments'} }
: join( "\n", @{ $self->{'comments'} } )
;
- }
+ }
else {
return wantarray ? () : undef;
}
}
-# ----------------------------------------------------------------------
sub get_constraints {
=pod
my $self = shift;
if ( ref $self->{'constraints'} ) {
- return wantarray
+ return wantarray
? @{ $self->{'constraints'} } : $self->{'constraints'};
}
else {
}
}
-# ----------------------------------------------------------------------
sub get_indices {
=pod
my $self = shift;
if ( ref $self->{'indices'} ) {
- return wantarray
- ? @{ $self->{'indices'} }
+ return wantarray
+ ? @{ $self->{'indices'} }
: $self->{'indices'};
}
else {
}
}
-# ----------------------------------------------------------------------
sub get_field {
=pod
my $field_name = shift or return $self->error('No field name');
my $case_insensitive = shift;
if ( $case_insensitive ) {
- $field_name = uc($field_name);
- foreach my $field ( keys %{$self->{fields}} ) {
- return $self->{fields}{$field} if $field_name eq uc($field);
- }
- return $self->error(qq[Field "$field_name" does not exist]);
+ $field_name = uc($field_name);
+ foreach my $field ( keys %{$self->{fields}} ) {
+ return $self->{fields}{$field} if $field_name eq uc($field);
+ }
+ return $self->error(qq[Field "$field_name" does not exist]);
}
return $self->error( qq[Field "$field_name" does not exist] ) unless
exists $self->{'fields'}{ $field_name };
return $self->{'fields'}{ $field_name };
}
-# ----------------------------------------------------------------------
sub get_fields {
=pod
=cut
my $self = shift;
- my @fields =
+ my @fields =
map { $_->[1] }
sort { $a->[0] <=> $b->[0] }
map { [ $_->order, $_ ] }
}
}
-# ----------------------------------------------------------------------
sub is_valid {
=pod
return $self->error('No name') unless $self->name;
return $self->error('No fields') unless $self->get_fields;
- for my $object (
- $self->get_fields, $self->get_indices, $self->get_constraints
+ for my $object (
+ $self->get_fields, $self->get_indices, $self->get_constraints
) {
return $object->error unless $object->is_valid;
}
return 1;
}
-# ----------------------------------------------------------------------
sub is_trivial_link {
=pod
my %fk = ();
foreach my $field ( $self->get_fields ) {
- next unless $field->is_foreign_key;
- $fk{$field->foreign_key_reference->reference_table}++;
- }
+ next unless $field->is_foreign_key;
+ $fk{$field->foreign_key_reference->reference_table}++;
+ }
foreach my $referenced (keys %fk){
- if($fk{$referenced} > 1){
- $self->{'is_trivial_link'} = 0;
- last;
- }
+ if($fk{$referenced} > 1){
+ $self->{'is_trivial_link'} = 0;
+ last;
+ }
}
return $self->{'is_trivial_link'};
return $self->{'is_data'};
}
-# ----------------------------------------------------------------------
sub can_link {
=pod
$self->{'can_link'}{ $table1->name }{ $table2->name } =
[ 'one2one', $fk{ $table2->name }, $fk{ $table1->name } ];
- # non-trivial traversal. one way to link table2,
+ # non-trivial traversal. one way to link table2,
# many ways to link table1
}
elsif ( scalar( @{ $fk{ $table1->name } } > 1 )
$self->{'can_link'}{ $table2->name }{ $table1->name } =
[ 'one2many', $fk{ $table2->name }, $fk{ $table1->name } ];
- # non-trivial traversal. one way to link table1,
+ # non-trivial traversal. one way to link table1,
# many ways to link table2
}
elsif ( scalar( @{ $fk{ $table1->name } } == 1 )
$self->{'can_link'}{ $table2->name }{ $table1->name } =
[ 'many2many', $fk{ $table2->name }, $fk{ $table1->name } ];
- # one of the tables didn't export a key
+ # one of the tables didn't export a key
# to this table, no linking possible
}
else {
return $self->{'can_link'}{ $table1->name }{ $table2->name };
}
-# ----------------------------------------------------------------------
sub name {
=pod
return $self->{'name'} || '';
}
-# ----------------------------------------------------------------------
sub schema {
=pod
return $self->{'schema'};
}
-# ----------------------------------------------------------------------
sub primary_key {
=pod
my $constraint;
if ( @$fields ) {
for my $f ( @$fields ) {
- return $self->error(qq[Invalid field "$f"]) unless
+ return $self->error(qq[Invalid field "$f"]) unless
$self->get_field($f);
}
$has_pk = 1;
$c->fields( @{ $c->fields }, @$fields );
$constraint = $c;
- }
+ }
}
unless ( $has_pk ) {
return;
}
-# ----------------------------------------------------------------------
sub options {
=pod
}
}
-# ----------------------------------------------------------------------
sub order {
=pod
return $self->{'order'} || 0;
}
-# ----------------------------------------------------------------------
sub field_names {
=head2 field_names
Read-only method to return a list or array ref of the field names. Returns undef
-or an empty list if the table has no fields set. Usefull if you want to
+or an empty list if the table has no fields set. Useful if you want to
avoid the overload magic of the Field objects returned by the get_fields method.
my @names = $constraint->field_names;
=cut
my $self = shift;
- my @fields =
+ my @fields =
map { $_->name }
sort { $a->order <=> $b->order }
values %{ $self->{'fields'} || {} };
}
}
-# ----------------------------------------------------------------------
sub equals {
=pod
my $self = shift;
my $other = shift;
my $case_insensitive = shift;
-
+
return 0 unless $self->SUPER::equals($other);
return 0 unless $case_insensitive ? uc($self->name) eq uc($other->name) : $self->name eq $other->name;
return 0 unless $self->_compare_objects(scalar $self->options, scalar $other->options);
# Go through our fields
my %checkedFields;
foreach my $field ( $self->get_fields ) {
- my $otherField = $other->get_field($field->name, $case_insensitive);
- return 0 unless $field->equals($otherField, $case_insensitive);
- $checkedFields{$field->name} = 1;
+ my $otherField = $other->get_field($field->name, $case_insensitive);
+ return 0 unless $field->equals($otherField, $case_insensitive);
+ $checkedFields{$field->name} = 1;
}
# Go through the other table's fields
foreach my $otherField ( $other->get_fields ) {
- next if $checkedFields{$otherField->name};
- return 0;
+ next if $checkedFields{$otherField->name};
+ return 0;
}
# Constraints
my %checkedConstraints;
CONSTRAINT:
foreach my $constraint ( $self->get_constraints ) {
- foreach my $otherConstraint ( $other->get_constraints ) {
- if ( $constraint->equals($otherConstraint, $case_insensitive) ) {
- $checkedConstraints{$otherConstraint} = 1;
- next CONSTRAINT;
- }
- }
- return 0;
+ foreach my $otherConstraint ( $other->get_constraints ) {
+ if ( $constraint->equals($otherConstraint, $case_insensitive) ) {
+ $checkedConstraints{$otherConstraint} = 1;
+ next CONSTRAINT;
+ }
+ }
+ return 0;
}
# Go through the other table's constraints
CONSTRAINT2:
foreach my $otherConstraint ( $other->get_constraints ) {
- next if $checkedFields{$otherConstraint};
- foreach my $constraint ( $self->get_constraints ) {
- if ( $otherConstraint->equals($constraint, $case_insensitive) ) {
- next CONSTRAINT2;
- }
- }
- return 0;
+ next if $checkedFields{$otherConstraint};
+ foreach my $constraint ( $self->get_constraints ) {
+ if ( $otherConstraint->equals($constraint, $case_insensitive) ) {
+ next CONSTRAINT2;
+ }
+ }
+ return 0;
}
# Indices
my %checkedIndices;
INDEX:
foreach my $index ( $self->get_indices ) {
- foreach my $otherIndex ( $other->get_indices ) {
- if ( $index->equals($otherIndex, $case_insensitive) ) {
- $checkedIndices{$otherIndex} = 1;
- next INDEX;
- }
- }
- return 0;
+ foreach my $otherIndex ( $other->get_indices ) {
+ if ( $index->equals($otherIndex, $case_insensitive) ) {
+ $checkedIndices{$otherIndex} = 1;
+ next INDEX;
+ }
+ }
+ return 0;
}
# Go through the other table's indices
INDEX2:
foreach my $otherIndex ( $other->get_indices ) {
- next if $checkedIndices{$otherIndex};
- foreach my $index ( $self->get_indices ) {
- if ( $otherIndex->equals($index, $case_insensitive) ) {
- next INDEX2;
- }
- }
- return 0;
+ next if $checkedIndices{$otherIndex};
+ foreach my $index ( $self->get_indices ) {
+ if ( $otherIndex->equals($index, $case_insensitive) ) {
+ next INDEX2;
+ }
+ }
+ return 0;
}
- return 1;
+ return 1;
}
-# ----------------------------------------------------------------------
-
=head1 LOOKUP METHODS
-The following are a set of shortcut methods for getting commonly used lists of
-fields and constraints. They all return lists or array refs of Field or
+The following are a set of shortcut methods for getting commonly used lists of
+fields and constraints. They all return lists or array refs of Field or
Constraint objects.
=over 4
return wantarray ? @fields : \@fields;
}
-# ----------------------------------------------------------------------
sub fkey_fields {
my $me = shift;
my @fields;
return wantarray ? @fields : \@fields;
}
-# ----------------------------------------------------------------------
sub nonpkey_fields {
my $me = shift;
my @fields = grep { !$_->is_primary_key } $me->get_fields;
return wantarray ? @fields : \@fields;
}
-# ----------------------------------------------------------------------
sub data_fields {
my $me = shift;
my @fields =
return wantarray ? @fields : \@fields;
}
-# ----------------------------------------------------------------------
sub unique_fields {
my $me = shift;
my @fields;
return wantarray ? @fields : \@fields;
}
-# ----------------------------------------------------------------------
sub unique_constraints {
my $me = shift;
my @cons = grep { $_->type eq UNIQUE } $me->get_constraints;
return wantarray ? @cons : \@cons;
}
-# ----------------------------------------------------------------------
sub fkey_constraints {
my $me = shift;
my @cons = grep { $_->type eq FOREIGN_KEY } $me->get_constraints;
return wantarray ? @cons : \@cons;
}
-# ----------------------------------------------------------------------
sub DESTROY {
my $self = shift;
undef $self->{'schema'}; # destroy cyclical reference
1;
-# ----------------------------------------------------------------------
-
=pod
=head1 AUTHORS
-Ken Y. Clark E<lt>kclark@cpan.orgE<gt>,
+Ken Youens-Clark E<lt>kclark@cpan.orgE<gt>,
Allen Day E<lt>allenday@ucla.eduE<gt>.
=cut