Upped version numbers, cleaned up code, fixed my name.
[dbsrgits/SQL-Translator.git] / lib / SQL / Translator / Schema / Trigger.pm
index 8aa4171..83ff30f 100644 (file)
@@ -1,9 +1,7 @@
 package SQL::Translator::Schema::Trigger;
 
 # ----------------------------------------------------------------------
-# $Id: Trigger.pm,v 1.9 2006-06-07 16:37:33 schiffbruechige Exp $
-# ----------------------------------------------------------------------
-# Copyright (C) 2002-4 SQLFairy Authors
+# 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
@@ -30,13 +28,13 @@ SQL::Translator::Schema::Trigger - SQL::Translator trigger object
 
   use SQL::Translator::Schema::Trigger;
   my $trigger = SQL::Translator::Schema::Trigger->new(
-      name                => 'foo',
-      perform_action_when => 'before', # or after
-      database_event      => 'insert', # or update, update_on, delete
-      fields              => [],       # fields if event is "update"
-      on_table            => 'foo',    # table name
-      action              => '...',    # text of trigger
-      schema              => $schema,  # Schema object
+    name                => 'foo',
+    perform_action_when => 'before', # or after
+    database_events     => [qw/update insert/], # also update, update_on, delete
+    fields              => [],       # if event is "update"
+    on_table            => 'foo',    # table name
+    action              => '...',    # text of trigger
+    schema              => $schema,  # Schema object
   );
 
 =head1 DESCRIPTION
@@ -52,15 +50,17 @@ use SQL::Translator::Utils 'parse_list_arg';
 
 use base 'SQL::Translator::Schema::Object';
 
+use Carp;
+
 use vars qw($VERSION $TABLE_COUNT $VIEW_COUNT);
 
-$VERSION = sprintf "%d.%02d", q$Revision: 1.9 $ =~ /(\d+)\.(\d+)/;
+$VERSION = '1.60';
 
 # ----------------------------------------------------------------------
 
 __PACKAGE__->_attributes( qw/
-    name schema perform_action_when database_event fields table on_table action
-    order
+    name schema perform_action_when database_events database_event 
+    fields table on_table action order
 /);
 
 =pod
@@ -111,27 +111,50 @@ sub database_event {
 
 =head2 database_event
 
-Gets or sets the event that triggers the trigger.
+Obsolete please use database_events!
 
-  my $ok = $trigger->database_event('insert');
+=cut
+    
+    my $self = shift;
+
+    return $self->database_events( @_ );
+}
+    
+# ----------------------------------------------------------------------
+sub database_events {
+
+=pod
+
+=head2 database_events
+
+Gets or sets the events that triggers the trigger.
+
+  my $ok = $trigger->database_events('insert');
 
 =cut
 
     my $self = shift;
-
-    if ( my $arg = shift ) {
-        $arg =  lc $arg;
-        $arg =~ s/\s+/ /g;
-        if ( $arg =~ /^(insert|update|update_on|delete)$/ ) {
-            $self->{'database_event'} = $arg;
-        }
-        else {
-            return 
-                $self->error("Invalid argument '$arg' to database_event");
+    my @args = ref $_[0] eq 'ARRAY' ? @{ $_[0] } : @_;
+
+    if ( @args ) {
+        @args       = map { s/\s+/ /g; lc $_ } @args;
+        my %valid   = map { $_, 1 } qw[ insert update update_on delete ];
+        my @invalid = grep { !defined $valid{ $_ } } @args;
+        
+        if ( @invalid ) {
+            return $self->error(
+                sprintf("Invalid events '%s' in database_events",
+                    join(', ', @invalid)
+                )
+            );
         }
+
+        $self->{'database_events'} = [ @args ];
     }
 
-    return $self->{'database_event'};
+    return wantarray 
+        ? @{ $self->{'database_events'} || [] }
+        : $self->{'database_events'};
 }
 
 # ----------------------------------------------------------------------
@@ -256,9 +279,9 @@ Determine whether the trigger is valid or not.
     my $self = shift;
 
     for my $attr ( 
-        qw[ name perform_action_when database_event on_table action ] 
+        qw[ name perform_action_when database_events on_table action ] 
     ) {
-        return $self->error("No $attr") unless $self->$attr();
+        return $self->error("Invalid: missing '$attr'") unless $self->$attr();
     }
     
     return $self->error("Missing fields for UPDATE ON") if 
@@ -332,6 +355,35 @@ Get or set the trigger's schema object.
 }
 
 # ----------------------------------------------------------------------
+sub compare_arrays {
+
+=pod
+
+=head2 compare_arrays
+
+Compare two arrays.
+
+=cut
+    
+    my ($first, $second) = @_;
+    no warnings;  # silence spurious -w undef complaints
+
+    return 0 unless (ref $first eq 'ARRAY' and ref $second eq 'ARRAY' ) ;
+
+    return 0 unless @$first == @$second;
+
+    my @first = sort @$first;
+
+    my @second = sort @$second;
+
+    for (my $i = 0; $i < scalar @first; $i++) {
+        return 0 if @first[$i] ne @second[$i];
+    }
+
+    return 1;
+}
+
+# ----------------------------------------------------------------------
 sub equals {
 
 =pod
@@ -340,22 +392,50 @@ sub equals {
 
 Determines if this trigger is the same as another
 
-  my $isIdentical = $trigger1->equals( $trigger2 );
+  my $is_identical = $trigger1->equals( $trigger2 );
 
 =cut
 
-    my $self = shift;
-    my $other = shift;
+    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->is_valid eq $other->is_valid;
-    return 0 unless $self->perform_action_when eq $other->perform_action_when;
-    return 0 unless $self->database_event eq $other->database_event;
-    return 0 unless $self->on_table eq $other->on_table;
-    return 0 unless $self->action eq $other->action;
-    return 0 unless $self->_compare_objects(scalar $self->extra, scalar $other->extra);
+
+    my %names;
+    for my $name ( $self->name, $other->name ) { 
+        $name = lc $name if $case_insensitive;
+        $names{ $name }++;
+    }
+
+    if ( keys %names > 1 ) {
+        return $self->error('Names not equal');
+    }
+
+    if ( !$self->perform_action_when eq $other->perform_action_when ) {
+        return $self->error('perform_action_when differs');
+    }
+
+    if ( 
+        !compare_arrays( [$self->database_events], [$other->database_events] ) 
+    ) {
+        return $self->error('database_events differ');
+    }
+
+    if ( $self->on_table ne $other->on_table ) {
+        return $self->error('on_table differs');
+    }
+
+    if ( $self->action ne $other->action ) {
+        return $self->error('action differs');
+    }
+
+    if ( 
+        !$self->_compare_objects( scalar $self->extra, scalar $other->extra )
+    ) {
+        return $self->error('extras differ');
+    }
+
     return 1;
 }
 
@@ -371,8 +451,9 @@ sub DESTROY {
 
 =pod
 
-=head1 AUTHOR
+=head1 AUTHORS
 
-Ken Y. Clark E<lt>kclark@cpan.orgE<gt>.
+Anonymous,
+Ken Youens-Clark E<lt>kclark@cpan.orgE<gt>.
 
 =cut